--- rpl/src/gestion_objets.c 2012/12/19 09:58:23 1.93 +++ rpl/src/gestion_objets.c 2015/01/08 14:29:51 1.114 @@ -1,7 +1,7 @@ /* ================================================================================ - RPL/2 (R) version 4.1.12 - Copyright (C) 1989-2012 Dr. BERTRAND Joël + RPL/2 (R) version 4.1.20 + Copyright (C) 1989-2015 Dr. BERTRAND Joël This file is part of RPL/2. @@ -117,6 +117,7 @@ initialisation_allocateur(struct_process (*s_etat_processus).pointeur_variables_variable = 0; (*s_etat_processus).pointeur_variables_tableau_noeuds = 0; (*s_etat_processus).pointeur_variables_tableau_noeuds_partages = 0; + (*s_etat_processus).pointeur_enveloppes_buffers = 0; return; } @@ -215,6 +216,8 @@ liberation_allocateur(struct_processus * } } + for(i = 0; i < (*s_etat_processus).pointeur_enveloppes_buffers; + free((*s_etat_processus).enveloppes_buffers[i++])); return; } @@ -245,6 +248,7 @@ allocation_maillon(struct_processus *s_e { if ((s_maillon = malloc(sizeof(struct_liste_chainee))) == NULL) { + (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; return(NULL); } } @@ -318,6 +322,7 @@ allocation(struct_processus *s_etat_proc if ((s_objet = malloc(sizeof(struct_objet))) == NULL) { + (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; return(NULL); } @@ -353,8 +358,10 @@ allocation(struct_processus *s_etat_proc } else { - if (((*s_objet).objet = malloc(sizeof(unsigned long))) == NULL) + if (((*s_objet).objet = malloc(sizeof(integer8))) == NULL) { + (*s_etat_processus).erreur_systeme = + d_es_allocation_memoire; free(s_objet); return(NULL); } @@ -380,6 +387,8 @@ allocation(struct_processus *s_etat_proc { if (((*s_objet).objet = malloc(sizeof(logical8))) == NULL) { + (*s_etat_processus).erreur_systeme = + d_es_allocation_memoire; free(s_objet); return(NULL); } @@ -406,6 +415,8 @@ allocation(struct_processus *s_etat_proc if (((*s_objet).objet = malloc(sizeof(struct_complexe16))) == NULL) { + (*s_etat_processus).erreur_systeme = + d_es_allocation_memoire; free(s_objet); return(NULL); } @@ -418,6 +429,7 @@ allocation(struct_processus *s_etat_proc { if (((*s_objet).objet = malloc(sizeof(struct_fichier))) == NULL) { + (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; free(s_objet); return(NULL); } @@ -437,6 +449,8 @@ allocation(struct_processus *s_etat_proc if (((*s_objet).objet = malloc(sizeof(struct_fonction))) == NULL) { + (*s_etat_processus).erreur_systeme = + d_es_allocation_memoire; free(s_objet); return(NULL); } @@ -460,6 +474,8 @@ allocation(struct_processus *s_etat_proc { if (((*s_objet).objet = malloc(sizeof(integer8))) == NULL) { + (*s_etat_processus).erreur_systeme = + d_es_allocation_memoire; free(s_objet); return(NULL); } @@ -485,6 +501,8 @@ allocation(struct_processus *s_etat_proc { if (((*s_objet).objet = malloc(sizeof(struct_matrice))) == NULL) { + (*s_etat_processus).erreur_systeme = + d_es_allocation_memoire; free(s_objet); return(NULL); } @@ -508,6 +526,8 @@ allocation(struct_processus *s_etat_proc { if (((*s_objet).objet = malloc(sizeof(struct_matrice))) == NULL) { + (*s_etat_processus).erreur_systeme = + d_es_allocation_memoire; free(s_objet); return(NULL); } @@ -531,6 +551,8 @@ allocation(struct_processus *s_etat_proc { if (((*s_objet).objet = malloc(sizeof(struct_matrice))) == NULL) { + (*s_etat_processus).erreur_systeme = + d_es_allocation_memoire; free(s_objet); return(NULL); } @@ -547,6 +569,7 @@ allocation(struct_processus *s_etat_proc { if (((*s_objet).objet = malloc(sizeof(struct_mutex))) == NULL) { + (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; free(s_objet); return(NULL); } @@ -566,6 +589,8 @@ allocation(struct_processus *s_etat_proc { if (((*s_objet).objet = malloc(sizeof(struct_nom))) == NULL) { + (*s_etat_processus).erreur_systeme = + d_es_allocation_memoire; free(s_objet); return(NULL); } @@ -585,6 +610,7 @@ allocation(struct_processus *s_etat_proc if (((*s_objet).objet = malloc(sizeof(struct_processus_fils))) == NULL) { + (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; free(s_objet); return(NULL); } @@ -603,6 +629,8 @@ allocation(struct_processus *s_etat_proc { if (((*s_objet).objet = malloc(sizeof(real8))) == NULL) { + (*s_etat_processus).erreur_systeme = + d_es_allocation_memoire; free(s_objet); return(NULL); } @@ -621,6 +649,7 @@ allocation(struct_processus *s_etat_proc { if (((*s_objet).objet = malloc(sizeof(struct_socket))) == NULL) { + (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; free(s_objet); return(NULL); } @@ -633,6 +662,7 @@ allocation(struct_processus *s_etat_proc if (((*s_objet).objet = malloc(sizeof(struct_bibliotheque))) == NULL) { + (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; free(s_objet); return(NULL); } @@ -644,6 +674,7 @@ allocation(struct_processus *s_etat_proc { if (((*s_objet).objet = malloc(sizeof(struct_semaphore))) == NULL) { + (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; free(s_objet); return(NULL); } @@ -656,6 +687,7 @@ allocation(struct_processus *s_etat_proc if (((*s_objet).objet = malloc(sizeof(struct_connecteur_sql))) == NULL) { + (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; free(s_objet); return(NULL); } @@ -674,6 +706,8 @@ allocation(struct_processus *s_etat_proc { if (((*s_objet).objet = malloc(sizeof(struct_tableau))) == NULL) { + (*s_etat_processus).erreur_systeme = + d_es_allocation_memoire; free(s_objet); return(NULL); } @@ -695,6 +729,8 @@ allocation(struct_processus *s_etat_proc { if (((*s_objet).objet = malloc(sizeof(struct_vecteur))) == NULL) { + (*s_etat_processus).erreur_systeme = + d_es_allocation_memoire; free(s_objet); return(NULL); } @@ -717,6 +753,8 @@ allocation(struct_processus *s_etat_proc { if (((*s_objet).objet = malloc(sizeof(struct_vecteur))) == NULL) { + (*s_etat_processus).erreur_systeme = + d_es_allocation_memoire; free(s_objet); return(NULL); } @@ -739,6 +777,8 @@ allocation(struct_processus *s_etat_proc { if (((*s_objet).objet = malloc(sizeof(struct_vecteur))) == NULL) { + (*s_etat_processus).erreur_systeme = + d_es_allocation_memoire; free(s_objet); return(NULL); } @@ -783,7 +823,7 @@ liberation(struct_processus *s_etat_proc struct_liste_chainee *l_element_courant; struct_liste_chainee *l_element_suivant; - unsigned long i; + integer8 i; if (s_objet == NULL) { @@ -822,7 +862,7 @@ liberation(struct_processus *s_etat_proc } else { - free((unsigned long *) ((*s_objet).objet)); + free((*s_objet).objet); } break; @@ -1357,7 +1397,7 @@ liberation(struct_processus *s_etat_proc .nombre_occurrences <= 1, pthread_mutex_unlock(&((*s_objet).mutex)), printf("(*((*((struct_tableau *) (*s_objet).objet))" - ".element[%lu])).nombre_occurrences=%ld\n", i, + ".element[%lld])).nombre_occurrences=%ld\n", i, (*((*((struct_tableau *) (*s_objet).objet)) .elements[i])).nombre_occurrences)); liberation(s_etat_processus, (*((struct_tableau *) @@ -1552,8 +1592,8 @@ copie_objet(struct_processus *s_etat_pro struct_objet *s_nouvel_objet; struct_objet *s_objet_tampon; - unsigned long i; - unsigned long j; + integer8 i; + integer8 j; if (pthread_mutex_lock(&((*s_objet).mutex)) != 0) { @@ -1604,8 +1644,8 @@ copie_objet(struct_processus *s_etat_pro return(NULL); } - (*((unsigned long *) ((*s_nouvel_objet).objet))) = - (*((unsigned long *) ((*s_objet).objet))); + (*((integer8 *) ((*s_nouvel_objet).objet))) = + (*((integer8 *) ((*s_objet).objet))); break; } @@ -1670,7 +1710,7 @@ copie_objet(struct_processus *s_etat_pro (*l_element_courant_lecture).suivant; } - (*s_nouvel_objet).objet = (void *) ((struct_liste_chainee *) + (*s_nouvel_objet).objet = ((struct_liste_chainee *) l_element_base); } else // type == 'P' @@ -1722,7 +1762,7 @@ copie_objet(struct_processus *s_etat_pro return(NULL); } - (*s_nouvel_objet).objet = (void *) ((unsigned char *) + (*s_nouvel_objet).objet = ((unsigned char *) malloc((strlen((unsigned char *) ((*s_objet).objet)) + 1) * sizeof(unsigned char))); @@ -1816,7 +1856,7 @@ copie_objet(struct_processus *s_etat_pro (*l_element_courant_lecture).suivant; } - (*s_nouvel_objet).objet = (void *) ((struct_liste_chainee *) + (*s_nouvel_objet).objet = ((struct_liste_chainee *) l_element_base); } else // type == 'P' @@ -2023,7 +2063,7 @@ copie_objet(struct_processus *s_etat_pro (*l_element_courant_lecture).suivant; } - (*s_nouvel_objet).objet = (void *) ((struct_liste_chainee *) + (*s_nouvel_objet).objet = ((struct_liste_chainee *) l_element_base); } else @@ -2058,9 +2098,8 @@ copie_objet(struct_processus *s_etat_pro } (*((struct_matrice *) ((*s_nouvel_objet).objet))).tableau = - (void **) ((integer8 **) malloc( - ((*((struct_matrice *) ((*s_objet).objet))).nombre_lignes) - * sizeof(integer8 *))); + malloc(((size_t) ((*((struct_matrice *) + ((*s_objet).objet))).nombre_lignes)) * sizeof(integer8 *)); if ((*((struct_matrice *) ((*s_nouvel_objet).objet))).tableau == NULL) @@ -2082,9 +2121,9 @@ copie_objet(struct_processus *s_etat_pro { if ((((integer8 **) ((*((struct_matrice *) ((*s_nouvel_objet).objet))).tableau))[i] = - (void *) ((integer8 *) malloc( + ((integer8 *) malloc(((size_t) ((*((struct_matrice *) ((*s_objet).objet))) - .nombre_colonnes) * sizeof(integer8)))) == NULL) + .nombre_colonnes)) * sizeof(integer8)))) == NULL) { for(j = 0; j < i; j++) { @@ -2125,9 +2164,9 @@ copie_objet(struct_processus *s_etat_pro } (*((struct_matrice *) ((*s_nouvel_objet).objet))).tableau = - (void **) ((struct_complexe16 **) malloc( - ((*((struct_matrice *) ((*s_objet).objet))).nombre_lignes) - * sizeof(struct_complexe16 *))); + malloc(((size_t) ((*((struct_matrice *) + ((*s_objet).objet))).nombre_lignes)) + * sizeof(struct_complexe16 *)); if ((*((struct_matrice *) ((*s_nouvel_objet).objet))).tableau == NULL) @@ -2149,9 +2188,9 @@ copie_objet(struct_processus *s_etat_pro { if ((((struct_complexe16 **) ((*((struct_matrice *) ((*s_nouvel_objet).objet))).tableau))[i] = - (void *) ((struct_complexe16 *) malloc( + ((struct_complexe16 *) malloc(((size_t) ((*((struct_matrice *) ((*s_objet).objet))) - .nombre_colonnes) * sizeof(struct_complexe16)))) + .nombre_colonnes)) * sizeof(struct_complexe16)))) == NULL) { for(j = 0; j < i; j++) @@ -2192,9 +2231,8 @@ copie_objet(struct_processus *s_etat_pro } (*((struct_matrice *) ((*s_nouvel_objet).objet))).tableau = - (void **) ((real8 **) malloc( - ((*((struct_matrice *) ((*s_objet).objet))).nombre_lignes) - * sizeof(real8 *))); + malloc(((size_t) ((*((struct_matrice *) + ((*s_objet).objet))).nombre_lignes)) * sizeof(real8 *)); if ((*((struct_matrice *) ((*s_nouvel_objet).objet))).tableau == NULL) @@ -2216,9 +2254,9 @@ copie_objet(struct_processus *s_etat_pro { if ((((real8 **) ((*((struct_matrice *) ((*s_nouvel_objet).objet))).tableau))[i] = - (void *) ((real8 *) malloc( + ((real8 *) malloc(((size_t) ((*((struct_matrice *) ((*s_objet).objet))) - .nombre_colonnes) * sizeof(real8)))) == NULL) + .nombre_colonnes)) * sizeof(real8)))) == NULL) { for(j = 0; j < i; j++) { @@ -2588,8 +2626,9 @@ copie_objet(struct_processus *s_etat_pro (*s_objet).objet)).nombre_elements; if (((*((struct_tableau *) (*s_nouvel_objet).objet)).elements = - malloc((*((struct_tableau *) (*s_objet).objet)) - .nombre_elements * sizeof(struct_objet *))) == NULL) + malloc(((size_t) (*((struct_tableau *) + (*s_objet).objet)).nombre_elements) + * sizeof(struct_objet *))) == NULL) { return(NULL); } @@ -2649,8 +2688,8 @@ copie_objet(struct_processus *s_etat_pro } (*((struct_vecteur *) ((*s_nouvel_objet).objet))).tableau = - (void *) ((integer8 *) malloc( - ((*((struct_vecteur *) ((*s_objet).objet))).taille) + ((integer8 *) malloc(((size_t) + ((*((struct_vecteur *) ((*s_objet).objet))).taille)) * sizeof(integer8))); if ((*((struct_vecteur *) ((*s_nouvel_objet).objet))).tableau @@ -2692,8 +2731,8 @@ copie_objet(struct_processus *s_etat_pro } (*((struct_vecteur *) ((*s_nouvel_objet).objet))).tableau = - (void *) ((struct_complexe16 *) malloc( - ((*((struct_vecteur *) ((*s_objet).objet))).taille) + ((struct_complexe16 *) malloc(((size_t) + ((*((struct_vecteur *) ((*s_objet).objet))).taille)) * sizeof(struct_complexe16))); if ((*((struct_vecteur *) ((*s_nouvel_objet).objet))).tableau @@ -2735,8 +2774,8 @@ copie_objet(struct_processus *s_etat_pro } (*((struct_vecteur *) ((*s_nouvel_objet).objet))).tableau = - (void *) ((real8 *) malloc( - ((*((struct_vecteur *) ((*s_objet).objet))).taille) + ((real8 *) malloc(((size_t) + ((*((struct_vecteur *) ((*s_objet).objet))).taille)) * sizeof(real8))); if ((*((struct_vecteur *) ((*s_nouvel_objet).objet))).tableau @@ -2799,9 +2838,9 @@ copie_etat_processus(struct_processus *s struct_processus *s_nouvel_etat_processus; - unsigned long i; + integer8 i; - if (pthread_mutex_lock(&((*s_etat_processus).mutex)) != 0) + if (pthread_mutex_lock(&((*s_etat_processus).mutex_pile_processus)) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return(NULL); @@ -2827,9 +2866,8 @@ copie_etat_processus(struct_processus *s * n'ont aucune raison de changer. */ - pthread_mutexattr_init(&attributs_mutex); - pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_NORMAL); (*s_nouvel_etat_processus).sections_critiques = 0; + (*s_nouvel_etat_processus).initialisation_scheduler = d_faux; // Les sémaphores sont initialisés dans le nouveau thread. Il // s'agit d'une limitation de l'implantation de l'émulation @@ -2912,7 +2950,8 @@ copie_etat_processus(struct_processus *s if (((*s_nouvel_etat_processus).indep = copie_objet(s_etat_processus, (*s_etat_processus).indep, 'P')) == NULL) { - if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0) + if (pthread_mutex_unlock(&((*s_etat_processus) + .mutex_pile_processus)) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return(NULL); @@ -2932,7 +2971,8 @@ copie_etat_processus(struct_processus *s if (((*s_nouvel_etat_processus).depend = copie_objet(s_etat_processus, (*s_etat_processus).depend, 'P')) == NULL) { - if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0) + if (pthread_mutex_unlock(&((*s_etat_processus) + .mutex_pile_processus)) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return(NULL); @@ -2953,7 +2993,8 @@ copie_etat_processus(struct_processus *s copie_objet(s_etat_processus, (*s_etat_processus) .parametres_courbes_de_niveau, 'P')) == NULL) { - if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0) + if (pthread_mutex_unlock(&((*s_etat_processus) + .mutex_pile_processus)) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return(NULL); @@ -2977,7 +3018,8 @@ copie_etat_processus(struct_processus *s (*s_etat_processus).instruction_courante) + 1) * sizeof(unsigned char))) == NULL) { - if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0) + if (pthread_mutex_unlock(&((*s_etat_processus) + .mutex_pile_processus)) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return(NULL); @@ -3001,7 +3043,8 @@ copie_etat_processus(struct_processus *s (*s_etat_processus).label_x) + 1) * sizeof(unsigned char))) == NULL) { - if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0) + if (pthread_mutex_unlock(&((*s_etat_processus) + .mutex_pile_processus)) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return(NULL); @@ -3025,7 +3068,8 @@ copie_etat_processus(struct_processus *s (*s_etat_processus).label_y) + 1) * sizeof(unsigned char))) == NULL) { - if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0) + if (pthread_mutex_unlock(&((*s_etat_processus) + .mutex_pile_processus)) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return(NULL); @@ -3049,7 +3093,8 @@ copie_etat_processus(struct_processus *s (*s_etat_processus).label_z) + 1) * sizeof(unsigned char))) == NULL) { - if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0) + if (pthread_mutex_unlock(&((*s_etat_processus) + .mutex_pile_processus)) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return(NULL); @@ -3073,7 +3118,8 @@ copie_etat_processus(struct_processus *s (*s_etat_processus).titre) + 1) * sizeof(unsigned char))) == NULL) { - if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0) + if (pthread_mutex_unlock(&((*s_etat_processus) + .mutex_pile_processus)) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return(NULL); @@ -3097,7 +3143,8 @@ copie_etat_processus(struct_processus *s (*s_etat_processus).legende) + 1) * sizeof(unsigned char))) == NULL) { - if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0) + if (pthread_mutex_unlock(&((*s_etat_processus) + .mutex_pile_processus)) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return(NULL); @@ -3144,7 +3191,8 @@ copie_etat_processus(struct_processus *s { if ((l_element_suivant = malloc(sizeof(struct_liste_chainee))) == NULL) { - if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0) + if (pthread_mutex_unlock(&((*s_etat_processus) + .mutex_pile_processus)) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return(NULL); @@ -3157,7 +3205,8 @@ copie_etat_processus(struct_processus *s if (((*l_element_suivant).donnee = copie_objet(s_etat_processus, (*l_element_lecture).donnee, 'P')) == NULL) { - if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0) + if (pthread_mutex_unlock(&((*s_etat_processus) + .mutex_pile_processus)) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return(NULL); @@ -3193,7 +3242,8 @@ copie_etat_processus(struct_processus *s if ((*s_nouvel_etat_processus).erreur_systeme != d_es) { - if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0) + if (pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus)) + != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return(NULL); @@ -3215,7 +3265,8 @@ copie_etat_processus(struct_processus *s if ((*s_nouvel_etat_processus).erreur_systeme != d_es) { - if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0) + if (pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus)) + != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return(NULL); @@ -3249,7 +3300,8 @@ copie_etat_processus(struct_processus *s { if ((l_element_suivant = malloc(sizeof(struct_liste_chainee))) == NULL) { - if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0) + if (pthread_mutex_unlock(&((*s_etat_processus) + .mutex_pile_processus)) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return(NULL); @@ -3262,7 +3314,8 @@ copie_etat_processus(struct_processus *s if (((*l_element_suivant).donnee = copie_objet(s_etat_processus, (*l_element_lecture).donnee, 'P')) == NULL) { - if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0) + if (pthread_mutex_unlock(&((*s_etat_processus) + .mutex_pile_processus)) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return(NULL); @@ -3295,7 +3348,8 @@ copie_etat_processus(struct_processus *s { if ((l_element_suivant = malloc(sizeof(struct_liste_chainee))) == NULL) { - if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0) + if (pthread_mutex_unlock(&((*s_etat_processus) + .mutex_pile_processus)) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return(NULL); @@ -3308,7 +3362,8 @@ copie_etat_processus(struct_processus *s if (((*l_element_suivant).donnee = copie_objet(s_etat_processus, (*l_element_lecture).donnee, 'P')) == NULL) { - if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0) + if (pthread_mutex_unlock(&((*s_etat_processus) + .mutex_pile_processus)) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return(NULL); @@ -3346,7 +3401,8 @@ copie_etat_processus(struct_processus *s { if ((l_element_suivant = malloc(sizeof(struct_liste_chainee))) == NULL) { - if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0) + if (pthread_mutex_unlock(&((*s_etat_processus) + .mutex_pile_processus)) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return(NULL); @@ -3359,7 +3415,8 @@ copie_etat_processus(struct_processus *s if (((*l_element_suivant).donnee = copie_objet(s_etat_processus, (*l_element_lecture).donnee, 'P')) == NULL) { - if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0) + if (pthread_mutex_unlock(&((*s_etat_processus) + .mutex_pile_processus)) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return(NULL); @@ -3392,7 +3449,8 @@ copie_etat_processus(struct_processus *s { if ((l_element_suivant = malloc(sizeof(struct_liste_chainee))) == NULL) { - if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0) + if (pthread_mutex_unlock(&((*s_etat_processus) + .mutex_pile_processus)) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return(NULL); @@ -3421,7 +3479,8 @@ copie_etat_processus(struct_processus *s malloc((strlen((*((struct_bibliotheque *) (*l_element_lecture) .donnee)).nom) + 1) * sizeof(unsigned char))) == NULL) { - if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0) + if (pthread_mutex_unlock(&((*s_etat_processus) + .mutex_pile_processus)) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return(NULL); @@ -3452,7 +3511,8 @@ copie_etat_processus(struct_processus *s if ((*s_etat_processus).nombre_instructions_externes != 0) { if (((*s_nouvel_etat_processus).s_instructions_externes = - malloc((*s_etat_processus).nombre_instructions_externes * + malloc(((size_t) (*s_etat_processus) + .nombre_instructions_externes) * sizeof(struct_instruction_externe))) == NULL) { (*s_etat_processus).erreur_systeme = d_es_processus; @@ -3495,9 +3555,24 @@ copie_etat_processus(struct_processus *s (*s_nouvel_etat_processus).s_instructions_externes = NULL; } + initialisation_allocateur_buffer(s_nouvel_etat_processus); + pthread_mutexattr_init(&attributs_mutex); pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_NORMAL); - pthread_mutex_init(&((*s_nouvel_etat_processus).mutex), &attributs_mutex); + pthread_mutex_init(&((*s_nouvel_etat_processus).mutex_pile_processus), + &attributs_mutex); + pthread_mutexattr_destroy(&attributs_mutex); + + pthread_mutexattr_init(&attributs_mutex); + pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_NORMAL); + pthread_mutex_init(&((*s_nouvel_etat_processus).mutex_interruptions), + &attributs_mutex); + pthread_mutexattr_destroy(&attributs_mutex); + + pthread_mutexattr_init(&attributs_mutex); + pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_NORMAL); + pthread_mutex_init(&((*s_nouvel_etat_processus).mutex_signaux), + &attributs_mutex); pthread_mutexattr_destroy(&attributs_mutex); pthread_mutexattr_init(&attributs_mutex); @@ -3506,7 +3581,7 @@ copie_etat_processus(struct_processus *s &attributs_mutex); pthread_mutexattr_destroy(&attributs_mutex); - if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0) + if (pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus)) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return(NULL);