--- rpl/src/gestion_objets.c 2012/05/21 17:25:42 1.82 +++ rpl/src/gestion_objets.c 2015/02/16 19:50:18 1.119 @@ -1,7 +1,7 @@ /* ================================================================================ - RPL/2 (R) version 4.1.9 - 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. @@ -112,9 +112,11 @@ initialisation_allocateur(struct_process (*s_etat_processus).pointeur_maillons = 0; (*s_etat_processus).pointeur_variables_noeud = 0; + (*s_etat_processus).pointeur_variables_partagees_noeud = 0; (*s_etat_processus).pointeur_variables_feuille = 0; (*s_etat_processus).pointeur_variables_variable = 0; (*s_etat_processus).pointeur_variables_tableau_noeuds = 0; + (*s_etat_processus).pointeur_variables_tableau_noeuds_partages = 0; return; } @@ -150,12 +152,17 @@ liberation_allocateur(struct_processus * for(i = 0; i < (*s_etat_processus).pointeur_variables_noeud; free((*s_etat_processus).variables_noeud[i++])); + for(i = 0; i < (*s_etat_processus).pointeur_variables_partagees_noeud; + free((*s_etat_processus).variables_partagees_noeud[i++])); for(i = 0; i < (*s_etat_processus).pointeur_variables_feuille; free((*s_etat_processus).variables_feuille[i++])); for(i = 0; i < (*s_etat_processus).pointeur_variables_variable; free((*s_etat_processus).variables_variable[i++])); for(i = 0; i < (*s_etat_processus).pointeur_variables_tableau_noeuds; free((*s_etat_processus).variables_tableau_noeuds[i++])); + for(i = 0; i < (*s_etat_processus) + .pointeur_variables_tableau_noeuds_partages; + free((*s_etat_processus).variables_tableau_noeuds_partages[i++])); { struct_liste_chainee *l_element_courant; @@ -238,6 +245,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); } } @@ -311,6 +319,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); } @@ -346,8 +355,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); } @@ -373,6 +384,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); } @@ -399,6 +412,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); } @@ -411,6 +426,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); } @@ -430,6 +446,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); } @@ -453,6 +471,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); } @@ -478,6 +498,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); } @@ -501,6 +523,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); } @@ -524,6 +548,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); } @@ -540,6 +566,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); } @@ -559,6 +586,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); } @@ -578,6 +607,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); } @@ -596,6 +626,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); } @@ -614,6 +646,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); } @@ -626,6 +659,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); } @@ -637,6 +671,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); } @@ -649,6 +684,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); } @@ -667,6 +703,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); } @@ -688,6 +726,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); } @@ -710,6 +750,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); } @@ -732,6 +774,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); } @@ -776,7 +820,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) { @@ -815,7 +859,7 @@ liberation(struct_processus *s_etat_proc } else { - free((unsigned long *) ((*s_objet).objet)); + free((*s_objet).objet); } break; @@ -882,7 +926,7 @@ liberation(struct_processus *s_etat_proc return; } - free((unsigned char *) ((*s_objet).objet)); + free((unsigned char *) (*s_objet).objet); break; } @@ -1350,7 +1394,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 *) @@ -1545,8 +1589,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) { @@ -1597,8 +1641,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; } @@ -1663,7 +1707,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' @@ -1715,7 +1759,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))); @@ -1809,7 +1853,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' @@ -2016,7 +2060,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 @@ -2051,9 +2095,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) @@ -2075,9 +2118,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++) { @@ -2118,9 +2161,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) @@ -2142,9 +2185,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++) @@ -2185,9 +2228,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) @@ -2209,9 +2251,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++) { @@ -2283,12 +2325,17 @@ copie_objet(struct_processus *s_etat_pro return(s_objet); } + // Un objet de type NON est un objet encapsulé dans une + // structure de type struct_objet. Elle peut très bien contenir + // une donnée, mais c'est à l'utilisateur de la libérer + // explicitement avec un free(). + if ((s_nouvel_objet = allocation(s_etat_processus, NON)) == NULL) { return(NULL); } - (*s_nouvel_objet).objet = NULL; + (*s_nouvel_objet).objet = (*s_objet).objet; break; } @@ -2576,8 +2623,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); } @@ -2637,8 +2685,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 @@ -2680,8 +2728,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 @@ -2723,8 +2771,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 @@ -2787,15 +2835,16 @@ 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); } - if ((s_nouvel_etat_processus = malloc(sizeof(struct_processus))) == NULL) + if ((s_nouvel_etat_processus = sys_malloc(sizeof(struct_processus))) + == NULL) { (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; return(NULL); @@ -2803,9 +2852,22 @@ copie_etat_processus(struct_processus *s (*s_nouvel_etat_processus) = (*s_etat_processus); - // On réinitialise l'allocateur. + // On réinitialise les allocateurs. + + pthread_mutexattr_init(&attributs_mutex); + pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_NORMAL); + pthread_mutex_init(&((*s_nouvel_etat_processus).mutex_allocation_buffer), + &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_allocation), + &attributs_mutex); + pthread_mutexattr_destroy(&attributs_mutex); initialisation_allocateur(s_nouvel_etat_processus); + initialisation_allocateur_buffer(s_nouvel_etat_processus); /* * (*s_etat_processus).definition_chainee, @@ -2815,8 +2877,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 @@ -2883,9 +2945,9 @@ copie_etat_processus(struct_processus *s // Copie de la localisation - if (((*s_nouvel_etat_processus).localisation = malloc((strlen( - (*s_etat_processus).localisation) + 1) * sizeof(unsigned char))) - == NULL) + if (((*s_nouvel_etat_processus).localisation = rpl_malloc( + s_nouvel_etat_processus, (strlen((*s_etat_processus).localisation) + + 1) * sizeof(unsigned char))) == NULL) { (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; return(NULL); @@ -2899,7 +2961,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); @@ -2919,7 +2982,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); @@ -2940,7 +3004,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); @@ -2960,11 +3025,13 @@ copie_etat_processus(struct_processus *s if (((*s_etat_processus).instruction_courante != NULL) && (*s_etat_processus).evaluation_expression_compilee == 'N') { - if (((*s_nouvel_etat_processus).instruction_courante = malloc((strlen( + if (((*s_nouvel_etat_processus).instruction_courante = rpl_malloc( + s_nouvel_etat_processus, (strlen( (*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); @@ -2984,11 +3051,13 @@ copie_etat_processus(struct_processus *s if ((*s_etat_processus).label_x != NULL) { - if (((*s_nouvel_etat_processus).label_x = malloc((strlen( + if (((*s_nouvel_etat_processus).label_x = rpl_malloc( + s_nouvel_etat_processus, (strlen( (*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); @@ -3008,11 +3077,12 @@ copie_etat_processus(struct_processus *s if ((*s_etat_processus).label_y != NULL) { - if (((*s_nouvel_etat_processus).label_y = malloc((strlen( - (*s_etat_processus).label_y) + 1) * - sizeof(unsigned char))) == NULL) + if (((*s_nouvel_etat_processus).label_y = rpl_malloc( + s_nouvel_etat_processus, (strlen((*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); @@ -3032,11 +3102,12 @@ copie_etat_processus(struct_processus *s if ((*s_etat_processus).label_z != NULL) { - if (((*s_nouvel_etat_processus).label_z = malloc((strlen( - (*s_etat_processus).label_z) + 1) * - sizeof(unsigned char))) == NULL) + if (((*s_nouvel_etat_processus).label_z = rpl_malloc( + s_nouvel_etat_processus, (strlen((*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); @@ -3056,11 +3127,12 @@ copie_etat_processus(struct_processus *s if ((*s_etat_processus).titre != NULL) { - if (((*s_nouvel_etat_processus).titre = malloc((strlen( - (*s_etat_processus).titre) + 1) * - sizeof(unsigned char))) == NULL) + if (((*s_nouvel_etat_processus).titre = rpl_malloc( + s_nouvel_etat_processus, (strlen((*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); @@ -3080,11 +3152,12 @@ copie_etat_processus(struct_processus *s if ((*s_etat_processus).legende != NULL) { - if (((*s_nouvel_etat_processus).legende = malloc((strlen( - (*s_etat_processus).legende) + 1) * - sizeof(unsigned char))) == NULL) + if (((*s_nouvel_etat_processus).legende = rpl_malloc( + s_nouvel_etat_processus, (strlen((*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); @@ -3106,6 +3179,7 @@ copie_etat_processus(struct_processus *s * Copie de la table des variables */ + (*s_nouvel_etat_processus).l_liste_variables_statiques = NULL; copie_arbre_variables(s_etat_processus, s_nouvel_etat_processus); if ((*s_nouvel_etat_processus).erreur_systeme != d_es) @@ -3113,65 +3187,10 @@ copie_etat_processus(struct_processus *s return(NULL); } - /* - * Copie de la table des variables statiques - */ - - if (((*s_nouvel_etat_processus).s_liste_variables_statiques = - malloc((*s_etat_processus).nombre_variables_statiques_allouees * - sizeof(struct_variable_statique))) == NULL) - { - if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0) - { - (*s_etat_processus).erreur_systeme = d_es_processus; - return(NULL); - } - - (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; - return(NULL); - } - - for(i = 0; i < (*s_etat_processus).nombre_variables_statiques; i++) - { - if (((*s_nouvel_etat_processus).s_liste_variables_statiques[i].nom = - malloc((strlen((*s_etat_processus).s_liste_variables_statiques - [i].nom) + 1) * sizeof(unsigned char))) == NULL) - { - if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0) - { - (*s_etat_processus).erreur_systeme = d_es_processus; - return(NULL); - } - - (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; - return(NULL); - } - - strcpy((*s_nouvel_etat_processus).s_liste_variables_statiques[i].nom, - (*s_etat_processus).s_liste_variables_statiques[i].nom); - - (*s_nouvel_etat_processus).s_liste_variables_statiques[i].origine = - (*s_etat_processus).s_liste_variables_statiques[i].origine; - (*s_nouvel_etat_processus).s_liste_variables_statiques[i].niveau = - (*s_etat_processus).s_liste_variables_statiques[i].niveau; - (*s_nouvel_etat_processus).s_liste_variables_statiques[i] - .variable_statique = (*s_etat_processus) - .s_liste_variables_statiques[i].variable_statique; - - if (((*s_nouvel_etat_processus).s_liste_variables_statiques[i].objet = - copie_objet(s_etat_processus, (*s_etat_processus) - .s_liste_variables_statiques[i].objet, 'P')) == NULL) - { - if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0) - { - (*s_etat_processus).erreur_systeme = d_es_processus; - return(NULL); - } - - (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; - return(NULL); - } - } + (*(*s_nouvel_etat_processus).l_liste_variables_partagees) = + (*(*s_etat_processus).l_liste_variables_partagees); + (*(*s_nouvel_etat_processus).s_arbre_variables_partagees) = + (*(*s_etat_processus).s_arbre_variables_partagees); /* * Copie de la pile opérationnelle @@ -3183,9 +3202,11 @@ copie_etat_processus(struct_processus *s while(l_element_lecture != NULL) { - if ((l_element_suivant = malloc(sizeof(struct_liste_chainee))) == NULL) + if ((l_element_suivant = rpl_malloc(s_nouvel_etat_processus, + 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); @@ -3198,7 +3219,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); @@ -3234,7 +3256,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); @@ -3256,7 +3279,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); @@ -3288,9 +3312,11 @@ copie_etat_processus(struct_processus *s while(l_element_lecture != NULL) { - if ((l_element_suivant = malloc(sizeof(struct_liste_chainee))) == NULL) + if ((l_element_suivant = rpl_malloc(s_nouvel_etat_processus, + 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); @@ -3303,7 +3329,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); @@ -3334,9 +3361,11 @@ copie_etat_processus(struct_processus *s while(l_element_lecture != NULL) { - if ((l_element_suivant = malloc(sizeof(struct_liste_chainee))) == NULL) + if ((l_element_suivant = rpl_malloc(s_nouvel_etat_processus, + 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); @@ -3349,7 +3378,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); @@ -3385,9 +3415,11 @@ copie_etat_processus(struct_processus *s while(l_element_lecture != NULL) { - if ((l_element_suivant = malloc(sizeof(struct_liste_chainee))) == NULL) + if ((l_element_suivant = rpl_malloc(s_nouvel_etat_processus, + 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); @@ -3400,7 +3432,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); @@ -3431,9 +3464,11 @@ copie_etat_processus(struct_processus *s while(l_element_lecture != NULL) { - if ((l_element_suivant = malloc(sizeof(struct_liste_chainee))) == NULL) + if ((l_element_suivant = rpl_malloc(s_nouvel_etat_processus, + 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); @@ -3443,8 +3478,8 @@ copie_etat_processus(struct_processus *s return(NULL); } - if (((*l_element_suivant).donnee = malloc(sizeof(struct_bibliotheque))) - == NULL) + if (((*l_element_suivant).donnee = rpl_malloc(s_nouvel_etat_processus, + sizeof(struct_bibliotheque))) == NULL) { (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; return(NULL); @@ -3459,10 +3494,12 @@ copie_etat_processus(struct_processus *s = (*((struct_bibliotheque *) (*l_element_lecture).donnee)).tid; if (((*((struct_bibliotheque *) (*l_element_suivant).donnee)).nom = - malloc((strlen((*((struct_bibliotheque *) (*l_element_lecture) + rpl_malloc(s_nouvel_etat_processus, + (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); @@ -3493,7 +3530,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 * + rpl_malloc(s_nouvel_etat_processus, ((size_t) + (*s_etat_processus).nombre_instructions_externes) * sizeof(struct_instruction_externe))) == NULL) { (*s_etat_processus).erreur_systeme = d_es_processus; @@ -3503,7 +3541,8 @@ copie_etat_processus(struct_processus *s for(i = 0; i < (*s_etat_processus).nombre_instructions_externes; i++) { if (((*s_nouvel_etat_processus).s_instructions_externes[i].nom = - malloc((strlen((*s_etat_processus).s_instructions_externes + rpl_malloc(s_nouvel_etat_processus, + (strlen((*s_etat_processus).s_instructions_externes [i].nom) + 1) * sizeof(unsigned char))) == NULL) { (*s_etat_processus).erreur_systeme = d_es_processus; @@ -3514,9 +3553,9 @@ copie_etat_processus(struct_processus *s (*s_etat_processus).s_instructions_externes[i].nom); if (((*s_nouvel_etat_processus).s_instructions_externes[i] - .nom_bibliotheque = malloc((strlen((*s_etat_processus) - .s_instructions_externes[i].nom_bibliotheque) + 1) * - sizeof(unsigned char))) == NULL) + .nom_bibliotheque = rpl_malloc(s_nouvel_etat_processus, + (strlen((*s_etat_processus).s_instructions_externes[i] + .nom_bibliotheque) + 1) * sizeof(unsigned char))) == NULL) { (*s_etat_processus).erreur_systeme = d_es_processus; return(NULL); @@ -3538,16 +3577,23 @@ copie_etat_processus(struct_processus *s 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_allocation), + 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); - 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);