--- rpl/src/interruptions.c 2013/05/21 13:30:56 1.126 +++ rpl/src/interruptions.c 2013/05/22 12:05:42 1.128 @@ -99,17 +99,23 @@ thread_surveillance_signaux(void *argume if (sem_wait(semaphore_signalisation) == 0) # endif { + if ((*s_queue_signaux).requete_arret == d_vrai) + { +# if (!defined(SEMAPHORES_NOMMES)) || defined(IPCS_SYSV) + sem_post(&(*s_queue_signaux).signalisation); +# else + sem_post(semaphore_signalisation); +# endif + + break; + } + # if (!defined(SEMAPHORES_NOMMES)) || defined(IPCS_SYSV) sem_post(&(*s_queue_signaux).signalisation); # else sem_post(semaphore_signalisation); # endif - if ((*s_queue_signaux).requete_arret == d_vrai) - { - break; - } - nombre_signaux_envoyes = 0; sched_yield(); @@ -153,14 +159,27 @@ thread_surveillance_signaux(void *argume if ((*((struct_thread *) (*l_element_courant).donnee)).pid == getpid()) { - if ((*(*((struct_thread *) (*l_element_courant).donnee)) - .s_etat_processus).pointeur_signal_ecriture != - (*(*((struct_thread *) (*l_element_courant).donnee)) - .s_etat_processus).pointeur_signal_lecture) + if (pthread_mutex_lock(&mutex_interruptions) != 0) { - nombre_signaux_envoyes++; - pthread_kill((*((struct_thread *) (*l_element_courant) - .donnee)).tid, SIGALRM); + (*s_etat_processus).erreur_systeme = d_es_processus; + } + else + { + if ((*(*((struct_thread *) (*l_element_courant).donnee)) + .s_etat_processus).pointeur_signal_ecriture != + (*(*((struct_thread *) (*l_element_courant) + .donnee)).s_etat_processus) + .pointeur_signal_lecture) + { + nombre_signaux_envoyes++; + pthread_kill((*((struct_thread *) + (*l_element_courant).donnee)).tid, SIGALRM); + } + + if (pthread_mutex_unlock(&mutex_interruptions) != 0) + { + (*s_etat_processus).erreur_systeme = d_es_processus; + } } } @@ -3356,12 +3375,24 @@ destruction_queue_signaux(struct_process unsigned char *nom; # endif - // Incrémenter le sémaphore pour être sûr de le débloquer. +# if (!defined(SEMAPHORES_NOMMES)) || defined(IPCS_SYSV) + sem_wait(&((*s_queue_signaux).signalisation)); +# else + sem_wait(semaphore_signalisation); +# endif (*s_queue_signaux).requete_arret = d_vrai; # if (!defined(SEMAPHORES_NOMMES)) || defined(IPCS_SYSV) sem_post(&((*s_queue_signaux).signalisation)); +# else + sem_post(semaphore_signalisation); +# endif + + // Incrémenter le sémaphore pour être sûr de le débloquer. + +# if (!defined(SEMAPHORES_NOMMES)) || defined(IPCS_SYSV) + sem_post(&((*s_queue_signaux).signalisation)); # else sem_post(semaphore_signalisation); # endif