--- rpl/src/instructions_s10.c 2013/05/21 12:10:12 1.74 +++ rpl/src/instructions_s10.c 2013/05/28 22:09:55 1.78 @@ -399,13 +399,39 @@ instruction_spawn(struct_processus *s_et attente.tv_sec = 0; attente.tv_nsec = GRANULARITE_us * 1000; + if (pthread_mutex_lock(&((*s_argument_thread).mutex)) != 0) + { + (*s_etat_processus).erreur_systeme = d_es_processus; + return; + } + while((*s_argument_thread).thread_actif == d_faux) { scrutation_interruptions(s_etat_processus); + + if (pthread_mutex_unlock(&((*s_argument_thread).mutex)) != 0) + { + (*s_etat_processus).erreur_systeme = d_es_processus; + return; + } + nanosleep(&attente, NULL); + + if (pthread_mutex_lock(&((*s_argument_thread).mutex)) != 0) + { + (*s_etat_processus).erreur_systeme = d_es_processus; + return; + } + INCR_GRANULARITE(attente.tv_nsec); } + if (pthread_mutex_unlock(&((*s_argument_thread).mutex)) != 0) + { + (*s_etat_processus).erreur_systeme = d_es_processus; + return; + } + if (pthread_attr_destroy(&attributs) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; @@ -494,25 +520,41 @@ instruction_spawn(struct_processus *s_et (*(*l_element_courant).donnee).objet)).thread) .tid, (*s_argument_thread).tid) != 0) { - if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0) + scrutation_injection(s_etat_processus); + + if (pthread_mutex_lock(&((*s_etat_processus) + .mutex_interruptions)) != 0) { + pthread_mutex_unlock(&((*s_etat_processus).mutex)); (*s_etat_processus).erreur_systeme = d_es_processus; return; } - scrutation_injection(s_etat_processus); - if ((*s_etat_processus).nombre_interruptions_non_affectees != 0) { affectation_interruptions_logicielles(s_etat_processus); } + if (pthread_mutex_unlock(&((*s_etat_processus) + .mutex_interruptions)) != 0) + { + pthread_mutex_unlock(&((*s_etat_processus).mutex)); + (*s_etat_processus).erreur_systeme = d_es_processus; + return; + } + if ((*s_etat_processus).nombre_interruptions_en_queue != 0) { traitement_interruptions_logicielles(s_etat_processus); } + if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0) + { + (*s_etat_processus).erreur_systeme = d_es_processus; + return; + } + nanosleep(&attente, NULL); INCR_GRANULARITE(attente.tv_nsec);