version 1.38, 2011/06/24 20:31:40
|
version 1.43, 2011/09/14 14:34:28
|
Line 1
|
Line 1
|
/* |
/* |
================================================================================ |
================================================================================ |
RPL/2 (R) version 4.1.0.prerelease.4 |
RPL/2 (R) version 4.1.3 |
Copyright (C) 1989-2011 Dr. BERTRAND Joël |
Copyright (C) 1989-2011 Dr. BERTRAND Joël |
|
|
This file is part of RPL/2. |
This file is part of RPL/2. |
Line 48 instruction_spawn(struct_processus *s_et
|
Line 48 instruction_spawn(struct_processus *s_et
|
pthread_t thread_id; |
pthread_t thread_id; |
pthread_t thread_surveillance; |
pthread_t thread_surveillance; |
|
|
sigset_t oldset; |
|
sigset_t set; |
|
|
|
struct_descripteur_thread *s_argument_thread; |
struct_descripteur_thread *s_argument_thread; |
|
|
struct_liste_chainee *l_element_courant; |
struct_liste_chainee *l_element_courant; |
Line 236 instruction_spawn(struct_processus *s_et
|
Line 233 instruction_spawn(struct_processus *s_et
|
} |
} |
} |
} |
|
|
if (sigemptyset(&set) != 0) |
|
{ |
|
(*s_etat_processus).erreur_systeme = d_es_processus; |
|
return; |
|
} |
|
|
|
if (sigaddset(&set, SIGSTART) != 0) |
|
{ |
|
(*s_etat_processus).erreur_systeme = d_es_processus; |
|
return; |
|
} |
|
|
|
/* |
|
* Le signal SIGFSTOP doit être traité ! |
|
*/ |
|
|
|
if (sigaddset(&set, SIGFSTOP) != 0) |
|
{ |
|
(*s_etat_processus).erreur_systeme = d_es_processus; |
|
return; |
|
} |
|
|
|
if (sigaddset(&set, SIGFABORT) != 0) |
|
{ |
|
(*s_etat_processus).erreur_systeme = d_es_processus; |
|
return; |
|
} |
|
|
|
if (sigaddset(&set, SIGURG) != 0) |
|
{ |
|
(*s_etat_processus).erreur_systeme = d_es_processus; |
|
return; |
|
} |
|
|
|
if (pthread_sigmask(SIG_BLOCK, &set, &oldset) != 0) |
|
{ |
|
(*s_etat_processus).erreur_systeme = d_es_processus; |
|
return; |
|
} |
|
|
|
if ((s_argument_thread = malloc(sizeof(struct_descripteur_thread))) == NULL) |
if ((s_argument_thread = malloc(sizeof(struct_descripteur_thread))) == NULL) |
{ |
{ |
(*s_etat_processus).erreur_systeme = d_es_processus; |
(*s_etat_processus).erreur_systeme = d_es_processus; |
Line 460 instruction_spawn(struct_processus *s_et
|
Line 417 instruction_spawn(struct_processus *s_et
|
(*s_argument_thread).destruction_objet = d_faux; |
(*s_argument_thread).destruction_objet = d_faux; |
} |
} |
|
|
(*s_argument_thread).set = set; |
|
(*s_argument_thread).oldset = oldset; |
|
(*s_argument_thread).thread_actif = d_faux; |
(*s_argument_thread).thread_actif = d_faux; |
|
|
if (pthread_create(&thread_id, &attributs, lancement_thread, |
if (pthread_create(&thread_id, &attributs, lancement_thread, |
Line 680 instruction_spawn(struct_processus *s_et
|
Line 635 instruction_spawn(struct_processus *s_et
|
|
|
// Le fils peut être présent sans être en attente du signal de départ. |
// Le fils peut être présent sans être en attente du signal de départ. |
|
|
if (pthread_kill((*s_argument_thread).tid, SIGSTART) != 0) |
if (envoi_signal_thread((*s_argument_thread).tid, rpl_sigstart) != 0) |
{ |
|
(*s_etat_processus).erreur_systeme = d_es_processus; |
|
return; |
|
} |
|
|
|
if (pthread_sigmask(SIG_SETMASK, &oldset, NULL) != 0) |
|
{ |
{ |
(*s_etat_processus).erreur_systeme = d_es_processus; |
(*s_etat_processus).erreur_systeme = d_es_processus; |
return; |
return; |
} |
} |
|
|
sigpending(&set); |
|
|
|
return; |
return; |
} |
} |
|
|