--- rpl/src/gestion_processus.c 2012/03/01 10:14:04 1.52 +++ rpl/src/gestion_processus.c 2013/04/01 15:29:34 1.65 @@ -1,7 +1,7 @@ /* ================================================================================ - RPL/2 (R) version 4.1.7 - Copyright (C) 1989-2012 Dr. BERTRAND Joël + RPL/2 (R) version 4.1.14 + Copyright (C) 1989-2013 Dr. BERTRAND Joël This file is part of RPL/2. @@ -40,7 +40,6 @@ void * surveillance_processus(void *argument) { - int iostat; int status; integer8 nombre_donnees; @@ -57,6 +56,7 @@ surveillance_processus(void *argument) pthread_t tid_candidat; + ssize_t iostat; ssize_t longueur_ecriture; struct_descripteur_thread *s_argument_thread; @@ -70,8 +70,13 @@ surveillance_processus(void *argument) unsigned char caractere; - unsigned int tampon_erreur_execution; - unsigned int tampon_erreur_systeme; + int tampon_erreur_execution; + int tampon_erreur_systeme; + + sigset_t set; + + sigfillset(&set); + pthread_sigmask(SIG_BLOCK, &set, NULL); s_argument_thread = argument; s_etat_processus = (*s_argument_thread).s_etat_processus; @@ -1855,8 +1860,8 @@ ecriture_pipe(struct_processus *s_etat_p struct timespec attente; - unsigned long i; - unsigned long j; + integer8 i; + integer8 j; size_t longueur; ssize_t longueur_ecriture; @@ -1986,7 +1991,7 @@ ecriture_pipe(struct_processus *s_etat_p while((longueur_ecriture = write_atomic(s_etat_processus, pipe, &((*((struct_vecteur *) (*s_objet).objet)) - .taille), sizeof(unsigned long))) != sizeof(unsigned long)) + .taille), sizeof(integer8))) != sizeof(integer8)) { if (longueur_ecriture == -1) { @@ -2039,7 +2044,7 @@ ecriture_pipe(struct_processus *s_etat_p while((longueur_ecriture = write_atomic(s_etat_processus, pipe, &((*((struct_vecteur *) (*s_objet).objet)) - .taille), sizeof(unsigned long))) != sizeof(unsigned long)) + .taille), sizeof(integer8))) != sizeof(integer8)) { if (longueur_ecriture == -1) { @@ -2092,7 +2097,7 @@ ecriture_pipe(struct_processus *s_etat_p while((longueur_ecriture = write_atomic(s_etat_processus, pipe, &((*((struct_vecteur *) (*s_objet).objet)) - .taille), sizeof(unsigned long))) != sizeof(unsigned long)) + .taille), sizeof(integer8))) != sizeof(integer8)) { if (longueur_ecriture == -1) { @@ -2145,7 +2150,7 @@ ecriture_pipe(struct_processus *s_etat_p while((longueur_ecriture = write_atomic(s_etat_processus, pipe, &((*((struct_matrice *) (*s_objet).objet)).nombre_lignes), - sizeof(unsigned long))) != sizeof(unsigned long)) + sizeof(integer8))) != sizeof(integer8)) { if (longueur_ecriture == -1) { @@ -2161,7 +2166,7 @@ ecriture_pipe(struct_processus *s_etat_p while((longueur_ecriture = write_atomic(s_etat_processus, pipe, &((*((struct_matrice *) (*s_objet).objet)).nombre_colonnes), - sizeof(unsigned long))) != sizeof(unsigned long)) + sizeof(integer8))) != sizeof(integer8)) { if (longueur_ecriture == -1) { @@ -2220,7 +2225,7 @@ ecriture_pipe(struct_processus *s_etat_p while((longueur_ecriture = write_atomic(s_etat_processus, pipe, &((*((struct_matrice *) (*s_objet).objet)).nombre_lignes), - sizeof(unsigned long))) != sizeof(unsigned long)) + sizeof(integer8))) != sizeof(integer8)) { if (longueur_ecriture == -1) { @@ -2236,7 +2241,7 @@ ecriture_pipe(struct_processus *s_etat_p while((longueur_ecriture = write_atomic(s_etat_processus, pipe, &((*((struct_matrice *) (*s_objet).objet)).nombre_colonnes), - sizeof(unsigned long))) != sizeof(unsigned long)) + sizeof(integer8))) != sizeof(integer8)) { if (longueur_ecriture == -1) { @@ -2295,7 +2300,7 @@ ecriture_pipe(struct_processus *s_etat_p while((longueur_ecriture = write_atomic(s_etat_processus, pipe, &((*((struct_matrice *) (*s_objet).objet)).nombre_lignes), - sizeof(unsigned long))) != sizeof(unsigned long)) + sizeof(integer8))) != sizeof(integer8)) { if (longueur_ecriture == -1) { @@ -2311,7 +2316,7 @@ ecriture_pipe(struct_processus *s_etat_p while((longueur_ecriture = write_atomic(s_etat_processus, pipe, &((*((struct_matrice *) (*s_objet).objet)).nombre_colonnes), - sizeof(unsigned long))) != sizeof(unsigned long)) + sizeof(integer8))) != sizeof(integer8)) { if (longueur_ecriture == -1) { @@ -2505,7 +2510,7 @@ ecriture_pipe(struct_processus *s_etat_p while((longueur_ecriture = write_atomic(s_etat_processus, pipe, &((*((struct_fonction *) (*s_objet).objet)).nombre_arguments), - sizeof(unsigned long))) != sizeof(unsigned long)) + sizeof(integer8))) != sizeof(integer8)) { if (longueur_ecriture == -1) { @@ -2647,7 +2652,7 @@ ecriture_pipe(struct_processus *s_etat_p while((longueur_ecriture = write_atomic(s_etat_processus, pipe, &((*((struct_tableau *) (*s_objet).objet)).nombre_elements), - sizeof(unsigned long))) != sizeof(unsigned long)) + sizeof(integer8))) != sizeof(integer8)) { if (longueur_ecriture == -1) { @@ -2703,8 +2708,8 @@ lecture_pipe(struct_processus *s_etat_pr struct timespec attente; - unsigned long i; - unsigned long j; + integer8 i; + integer8 j; if ((s_objet = allocation(s_etat_processus, NON)) == NULL) { @@ -2791,15 +2796,15 @@ lecture_pipe(struct_processus *s_etat_pr while(read_atomic(s_etat_processus, pipe, &((*((struct_vecteur *) (*s_objet).objet)).taille), - sizeof(unsigned long)) != sizeof(unsigned long)) + sizeof(integer8)) != sizeof(integer8)) { nanosleep(&attente, NULL); INCR_GRANULARITE(attente.tv_nsec); } if (((*((struct_vecteur *) (*s_objet).objet)).tableau = - malloc((*((struct_vecteur *) (*s_objet).objet)).taille * - sizeof(integer8))) == NULL) + malloc(((size_t) (*((struct_vecteur *) (*s_objet).objet)) + .taille) * sizeof(integer8))) == NULL) { (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; return(NULL); @@ -2835,15 +2840,15 @@ lecture_pipe(struct_processus *s_etat_pr while(read_atomic(s_etat_processus, pipe, &((*((struct_vecteur *) (*s_objet).objet)).taille), - sizeof(unsigned long)) != sizeof(unsigned long)) + sizeof(integer8)) != sizeof(integer8)) { nanosleep(&attente, NULL); INCR_GRANULARITE(attente.tv_nsec); } if (((*((struct_vecteur *) (*s_objet).objet)).tableau = - malloc((*((struct_vecteur *) (*s_objet).objet)).taille * - sizeof(real8))) == NULL) + malloc(((size_t) (*((struct_vecteur *) (*s_objet).objet)) + .taille) * sizeof(real8))) == NULL) { (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; return(NULL); @@ -2879,15 +2884,15 @@ lecture_pipe(struct_processus *s_etat_pr while(read_atomic(s_etat_processus, pipe, &((*((struct_vecteur *) (*s_objet).objet)).taille), - sizeof(unsigned long)) != sizeof(unsigned long)) + sizeof(integer8)) != sizeof(integer8)) { nanosleep(&attente, NULL); INCR_GRANULARITE(attente.tv_nsec); } if (((*((struct_vecteur *) (*s_objet).objet)).tableau = - malloc((*((struct_vecteur *) (*s_objet).objet)).taille * - sizeof(complex16))) == NULL) + malloc(((size_t) (*((struct_vecteur *) (*s_objet).objet)) + .taille) * sizeof(complex16))) == NULL) { (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; return(NULL); @@ -2923,7 +2928,7 @@ lecture_pipe(struct_processus *s_etat_pr while(read_atomic(s_etat_processus, pipe, &((*((struct_matrice *) (*s_objet).objet)).nombre_lignes), - sizeof(unsigned long)) != sizeof(unsigned long)) + sizeof(integer8)) != sizeof(integer8)) { nanosleep(&attente, NULL); INCR_GRANULARITE(attente.tv_nsec); @@ -2934,15 +2939,15 @@ lecture_pipe(struct_processus *s_etat_pr while(read_atomic(s_etat_processus, pipe, &((*((struct_matrice *) (*s_objet).objet)).nombre_colonnes), - sizeof(unsigned long)) != sizeof(unsigned long)) + sizeof(integer8)) != sizeof(integer8)) { nanosleep(&attente, NULL); INCR_GRANULARITE(attente.tv_nsec); } if (((*((struct_matrice *) (*s_objet).objet)).tableau = - malloc((*((struct_matrice *) (*s_objet).objet)).nombre_lignes * - sizeof(integer8 *))) == NULL) + malloc(((size_t) (*((struct_matrice *) (*s_objet).objet)) + .nombre_lignes) * sizeof(integer8 *))) == NULL) { (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; return(NULL); @@ -2952,8 +2957,8 @@ lecture_pipe(struct_processus *s_etat_pr (*s_objet).objet)).nombre_lignes; i++) { if ((((*((struct_matrice *) (*s_objet).objet)).tableau)[i] = - malloc((*((struct_matrice *) (*s_objet).objet)) - .nombre_colonnes * sizeof(integer8))) == NULL) + malloc(((size_t) (*((struct_matrice *) (*s_objet).objet)) + .nombre_colonnes) * sizeof(integer8))) == NULL) { (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; return(NULL); @@ -2991,7 +2996,7 @@ lecture_pipe(struct_processus *s_etat_pr while(read_atomic(s_etat_processus, pipe, &((*((struct_matrice *) (*s_objet).objet)).nombre_lignes), - sizeof(unsigned long)) != sizeof(unsigned long)) + sizeof(integer8)) != sizeof(integer8)) { nanosleep(&attente, NULL); INCR_GRANULARITE(attente.tv_nsec); @@ -3002,15 +3007,15 @@ lecture_pipe(struct_processus *s_etat_pr while(read_atomic(s_etat_processus, pipe, &((*((struct_matrice *) (*s_objet).objet)).nombre_colonnes), - sizeof(unsigned long)) != sizeof(unsigned long)) + sizeof(integer8)) != sizeof(integer8)) { nanosleep(&attente, NULL); INCR_GRANULARITE(attente.tv_nsec); } if (((*((struct_matrice *) (*s_objet).objet)).tableau = - malloc((*((struct_matrice *) (*s_objet).objet)).nombre_lignes * - sizeof(real8 *))) == NULL) + malloc(((size_t) (*((struct_matrice *) (*s_objet).objet)) + .nombre_lignes) * sizeof(real8 *))) == NULL) { (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; return(NULL); @@ -3020,8 +3025,8 @@ lecture_pipe(struct_processus *s_etat_pr (*s_objet).objet)).nombre_lignes; i++) { if ((((*((struct_matrice *) (*s_objet).objet)).tableau)[i] = - malloc((*((struct_matrice *) (*s_objet).objet)) - .nombre_colonnes * sizeof(real8))) == NULL) + malloc(((size_t) (*((struct_matrice *) (*s_objet).objet)) + .nombre_colonnes) * sizeof(real8))) == NULL) { (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; return(NULL); @@ -3059,7 +3064,7 @@ lecture_pipe(struct_processus *s_etat_pr while(read_atomic(s_etat_processus, pipe, &((*((struct_matrice *) (*s_objet).objet)).nombre_lignes), - sizeof(unsigned long)) != sizeof(unsigned long)) + sizeof(integer8)) != sizeof(integer8)) { nanosleep(&attente, NULL); INCR_GRANULARITE(attente.tv_nsec); @@ -3070,15 +3075,15 @@ lecture_pipe(struct_processus *s_etat_pr while(read_atomic(s_etat_processus, pipe, &((*((struct_matrice *) (*s_objet).objet)).nombre_colonnes), - sizeof(unsigned long)) != sizeof(unsigned long)) + sizeof(integer8)) != sizeof(integer8)) { nanosleep(&attente, NULL); INCR_GRANULARITE(attente.tv_nsec); } if (((*((struct_matrice *) (*s_objet).objet)).tableau = - malloc((*((struct_matrice *) (*s_objet).objet)).nombre_lignes * - sizeof(complex16 *))) == NULL) + malloc(((size_t) (*((struct_matrice *) (*s_objet).objet)) + .nombre_lignes) * sizeof(complex16 *))) == NULL) { (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; return(NULL); @@ -3088,8 +3093,8 @@ lecture_pipe(struct_processus *s_etat_pr (*s_objet).objet)).nombre_lignes; i++) { if ((((*((struct_matrice *) (*s_objet).objet)).tableau)[i] = - malloc((*((struct_matrice *) (*s_objet).objet)) - .nombre_colonnes * sizeof(complex16))) == NULL) + malloc(((size_t) (*((struct_matrice *) (*s_objet).objet)) + .nombre_colonnes) * sizeof(complex16))) == NULL) { (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; return(NULL); @@ -3217,8 +3222,8 @@ lecture_pipe(struct_processus *s_etat_pr while(read_atomic(s_etat_processus, pipe, &((*((struct_fonction *) (*s_objet).objet)) - .nombre_arguments), sizeof(unsigned long)) != - sizeof(unsigned long)) + .nombre_arguments), sizeof(integer8)) != + sizeof(integer8)) { nanosleep(&attente, NULL); INCR_GRANULARITE(attente.tv_nsec); @@ -3338,15 +3343,15 @@ lecture_pipe(struct_processus *s_etat_pr while(read_atomic(s_etat_processus, pipe, &((*((struct_tableau *) (*s_objet).objet)).nombre_elements), - sizeof(unsigned long)) != sizeof(unsigned long)) + sizeof(integer8)) != sizeof(integer8)) { nanosleep(&attente, NULL); INCR_GRANULARITE(attente.tv_nsec); } if (((*((struct_tableau *) (*s_objet).objet)).elements = malloc( - (*((struct_tableau *) (*s_objet).objet)).nombre_elements * - sizeof(struct_objet *))) == NULL) + ((size_t) (*((struct_tableau *) (*s_objet).objet)) + .nombre_elements) * sizeof(struct_objet *))) == NULL) { (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; return(NULL);