--- rpl/src/interruptions.c 2016/03/01 22:12:35 1.165 +++ rpl/src/interruptions.c 2016/03/09 17:49:12 1.166 @@ -109,7 +109,6 @@ thread_surveillance_signaux(void *argume sem_post(semaphore_signalisation); nombre_signaux_envoyes = 0; - sched_yield(); // Dans un premier temps, on verrouille la queue des signaux // affectée au processus courant pour vérifier s'il y a quelque @@ -128,6 +127,7 @@ thread_surveillance_signaux(void *argume nombre_signaux_envoyes++; kill(getpid(), SIGALRM); + sched_yield(); } sem_post(semaphore_queue_signaux); @@ -160,6 +160,7 @@ thread_surveillance_signaux(void *argume nombre_signaux_envoyes++; pthread_kill((*((struct_thread *) (*l_element_courant).donnee)).tid, SIGALRM); + sched_yield(); } pthread_mutex_unlock(&((*(*((struct_thread *) @@ -2658,6 +2659,7 @@ envoi_signal_processus(pid_t pid, enum s if (msync(s_queue_signaux, sizeof(s_queue_signaux), MS_ASYNC | MS_INVALIDATE) != 0) { + sem_post(semaphore_queue_signaux); return(1); } # endif @@ -3002,7 +3004,8 @@ creation_queue_signaux(struct_processus (*s_queue_signaux).requete_arret = d_faux; - if (msync(s_queue_signaux, sizeof(struct_queue_signaux), MS_SYNC)) + if (msync(s_queue_signaux, sizeof(struct_queue_signaux), + MS_ASYNC | MS_INVALIDATE) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return; @@ -3168,6 +3171,16 @@ creation_queue_signaux(struct_processus } (*s_queue_signaux).controle = getpid(); + +# ifndef IPCS_SYSV + if (msync(s_queue_signaux, sizeof(s_queue_signaux), + MS_ASYNC | MS_INVALIDATE) != 0) + { + (*s_etat_processus).erreur_systeme = d_es_processus; + return; + } +# endif + return; }