--- rpl/src/gestion_objets.c 2010/08/06 15:26:45 1.33 +++ rpl/src/gestion_objets.c 2011/01/03 12:08:03 1.44 @@ -1,7 +1,7 @@ /* ================================================================================ - RPL/2 (R) version 4.0.18 - Copyright (C) 1989-2010 Dr. BERTRAND Joël + RPL/2 (R) version 4.0.20 + Copyright (C) 1989-2011 Dr. BERTRAND Joël This file is part of RPL/2. @@ -57,7 +57,7 @@ decrementation_atomique(struct_objet *s_ return((*s_objet).nombre_occurrences); } -inline void +void initialisation_objet(struct_objet *s_objet) { pthread_mutexattr_t attributs_mutex; @@ -758,6 +758,9 @@ liberation(struct_processus *s_etat_proc { logical1 drapeau; + sigset_t oldset; + sigset_t set; + struct_liste_chainee *l_element_courant; struct_liste_chainee *l_element_suivant; @@ -1127,9 +1130,15 @@ liberation(struct_processus *s_etat_proc case PRC : { + sigfillset(&set); + pthread_sigmask(SIG_BLOCK, &set, &oldset); + if (pthread_mutex_lock(&((*(*((struct_processus_fils *) - (*s_objet).objet)).thread).mutex)) != 0) + (*s_objet).objet)).thread).mutex_nombre_references)) != 0) { + pthread_sigmask(SIG_SETMASK, &oldset, NULL); + sigpending(&set); + (*s_etat_processus).erreur_systeme = d_es_processus; return; } @@ -1155,18 +1164,25 @@ liberation(struct_processus *s_etat_proc } if (pthread_mutex_unlock(&((*(*((struct_processus_fils *) - (*s_objet).objet)).thread).mutex)) != 0) + (*s_objet).objet)).thread).mutex_nombre_references)) != 0) { + pthread_sigmask(SIG_SETMASK, &oldset, NULL); + sigpending(&set); + (*s_etat_processus).erreur_systeme = d_es_processus; return; } + pthread_sigmask(SIG_SETMASK, &oldset, NULL); + sigpending(&set); + if (drapeau == d_vrai) { pthread_mutex_destroy(&((*(*((struct_processus_fils *) (*s_objet).objet)).thread).mutex)); + pthread_mutex_destroy(&((*(*((struct_processus_fils *) + (*s_objet).objet)).thread).mutex_nombre_references)); free((*((struct_processus_fils *) (*s_objet).objet)).thread); - } if (decrementation_atomique(s_objet) > 0) @@ -1497,6 +1513,9 @@ struct_objet * copie_objet(struct_processus *s_etat_processus, struct_objet *s_objet, unsigned char type) { + sigset_t oldset; + sigset_t set; + struct_liste_chainee *l_element_base; struct_liste_chainee *l_element_courant; struct_liste_chainee *l_element_courant_ecriture; @@ -2267,9 +2286,15 @@ copie_objet(struct_processus *s_etat_pro case PRC : { + sigfillset(&set); + pthread_sigmask(SIG_BLOCK, &set, &oldset); + if (pthread_mutex_lock(&((*(*((struct_processus_fils *) - (*s_objet).objet)).thread).mutex)) != 0) + (*s_objet).objet)).thread).mutex_nombre_references)) != 0) { + pthread_sigmask(SIG_SETMASK, &oldset, NULL); + sigpending(&set); + return(NULL); } @@ -2277,11 +2302,17 @@ copie_objet(struct_processus *s_etat_pro .nombre_references++; if (pthread_mutex_unlock(&((*(*((struct_processus_fils *) - (*s_objet).objet)).thread).mutex)) != 0) + (*s_objet).objet)).thread).mutex_nombre_references)) != 0) { + pthread_sigmask(SIG_SETMASK, &oldset, NULL); + sigpending(&set); + return(NULL); } + pthread_sigmask(SIG_SETMASK, &oldset, NULL); + sigpending(&set); + if (type != 'O') { incrementation_atomique(s_objet); @@ -2295,7 +2326,6 @@ copie_objet(struct_processus *s_etat_pro (*((struct_processus_fils *) (*s_nouvel_objet).objet)) = (*((struct_processus_fils *) (*s_objet).objet)); - break; } @@ -2799,6 +2829,7 @@ copie_etat_processus(struct_processus *s # endif (*s_nouvel_etat_processus).var_volatile_processus_pere = 0; + (*s_nouvel_etat_processus).var_volatile_processus_racine = 0; (*s_nouvel_etat_processus).fichiers_graphiques = NULL; (*s_nouvel_etat_processus).entree_standard = NULL; (*s_nouvel_etat_processus).s_marques = NULL; @@ -2842,10 +2873,17 @@ copie_etat_processus(struct_processus *s if ((*s_nouvel_etat_processus).generateur_aleatoire != NULL) { - (*s_nouvel_etat_processus).generateur_aleatoire = NULL; - } + if (((*s_nouvel_etat_processus).generateur_aleatoire = + gsl_rng_clone((*s_etat_processus).generateur_aleatoire)) + == NULL) + { + (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; + return(NULL); + } - (*s_nouvel_etat_processus).type_generateur_aleatoire = NULL; + gsl_rng_set((*s_nouvel_etat_processus).generateur_aleatoire, + gsl_rng_get((*s_etat_processus).generateur_aleatoire)); + } // Copie de la localisation @@ -3973,8 +4011,23 @@ debug_fork() pthread_mutex_lock(&mutex_allocation); pid = fork(); +# ifdef OS2 if (pid == 0) { + sem_init(&semaphore_liste_threads, 0, 1); + sem_init(&semaphore_gestionnaires_signaux, 0, 0); + sem_init(&semaphore_gestionnaires_signaux_atomique, 0, 1); + sem_init(&((*s_etat_processus).semaphore_fork), 0, 0); + } +# endif + + if (pid == 0) + { +# ifdef _BROKEN_SIGINFO + liberation_fifos_signaux(s_etat_processus); + creation_fifos_signaux(s_etat_processus); +# endif + pthread_mutex_destroy(&mutex_allocation); debug_memoire_initialisation(); }