version 1.73, 2013/04/01 15:29:37
|
version 1.76, 2013/05/22 13:40:12
|
Line 233 instruction_spawn(struct_processus *s_et
|
Line 233 instruction_spawn(struct_processus *s_et
|
return; |
return; |
} |
} |
|
|
if (pipe((*s_argument_thread).pipe_nombre_interruptions_attente) != 0) |
if (pipe((*s_argument_thread).pipe_nombre_elements_attente) != 0) |
{ |
{ |
(*s_etat_processus).erreur_systeme = d_es_processus; |
(*s_etat_processus).erreur_systeme = d_es_processus; |
return; |
return; |
Line 251 instruction_spawn(struct_processus *s_et
|
Line 251 instruction_spawn(struct_processus *s_et
|
return; |
return; |
} |
} |
|
|
if (pipe((*s_argument_thread).pipe_nombre_objets_attente) != 0) |
|
{ |
|
(*s_etat_processus).erreur_systeme = d_es_processus; |
|
return; |
|
} |
|
|
|
if (pipe((*s_argument_thread).pipe_injections) != 0) |
if (pipe((*s_argument_thread).pipe_injections) != 0) |
{ |
{ |
(*s_etat_processus).erreur_systeme = d_es_processus; |
(*s_etat_processus).erreur_systeme = d_es_processus; |
Line 293 instruction_spawn(struct_processus *s_et
|
Line 287 instruction_spawn(struct_processus *s_et
|
|
|
(*s_nouvel_etat_processus).pipe_donnees = |
(*s_nouvel_etat_processus).pipe_donnees = |
(*s_argument_thread).pipe_objets[1]; |
(*s_argument_thread).pipe_objets[1]; |
(*s_nouvel_etat_processus).pipe_nombre_objets_attente = |
(*s_nouvel_etat_processus).pipe_nombre_elements_attente = |
(*s_argument_thread).pipe_nombre_objets_attente[1]; |
(*s_argument_thread).pipe_nombre_elements_attente[1]; |
(*s_nouvel_etat_processus).pipe_interruptions = |
(*s_nouvel_etat_processus).pipe_interruptions = |
(*s_argument_thread).pipe_interruptions[1]; |
(*s_argument_thread).pipe_interruptions[1]; |
(*s_nouvel_etat_processus).pipe_nombre_interruptions_attente = |
|
(*s_argument_thread).pipe_nombre_interruptions_attente[1]; |
|
(*s_nouvel_etat_processus).pipe_injections = |
(*s_nouvel_etat_processus).pipe_injections = |
(*s_argument_thread).pipe_injections[0]; |
(*s_argument_thread).pipe_injections[0]; |
(*s_nouvel_etat_processus).pipe_nombre_injections = |
(*s_nouvel_etat_processus).pipe_nombre_injections = |
Line 407 instruction_spawn(struct_processus *s_et
|
Line 399 instruction_spawn(struct_processus *s_et
|
attente.tv_sec = 0; |
attente.tv_sec = 0; |
attente.tv_nsec = GRANULARITE_us * 1000; |
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) |
while((*s_argument_thread).thread_actif == d_faux) |
{ |
{ |
scrutation_interruptions(s_etat_processus); |
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); |
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); |
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) |
if (pthread_attr_destroy(&attributs) != 0) |
{ |
{ |
(*s_etat_processus).erreur_systeme = d_es_processus; |
(*s_etat_processus).erreur_systeme = d_es_processus; |