version 1.35, 2010/08/13 21:00:37
|
version 1.45, 2010/12/14 15:46:24
|
Line 1
|
Line 1
|
/* |
/* |
================================================================================ |
================================================================================ |
RPL/2 (R) version 4.0.18 |
RPL/2 (R) version 4.0.20 |
Copyright (C) 1989-2010 Dr. BERTRAND Joël |
Copyright (C) 1989-2010 Dr. BERTRAND Joël |
|
|
This file is part of RPL/2. |
This file is part of RPL/2. |
Line 890 instruction_detach(struct_processus *s_e
|
Line 890 instruction_detach(struct_processus *s_e
|
return; |
return; |
} |
} |
|
|
# ifdef _BROKEN_SIGINFO |
|
if ((*s_etat_processus).langue == 'F') |
|
{ |
|
printf("+++Attention : Support des processus multiples indisponible\n"); |
|
} |
|
else |
|
{ |
|
printf("+++Attention : Multiprocess unavailable\n"); |
|
} |
|
|
|
return; |
|
# endif |
|
|
|
if (test_cfsf(s_etat_processus, 31) == d_vrai) |
if (test_cfsf(s_etat_processus, 31) == d_vrai) |
{ |
{ |
if (empilement_pile_last(s_etat_processus, 1) == d_erreur) |
if (empilement_pile_last(s_etat_processus, 1) == d_erreur) |
Line 1172 instruction_detach(struct_processus *s_e
|
Line 1159 instruction_detach(struct_processus *s_e
|
|
|
verrouillage_threads_concurrents(s_etat_processus); |
verrouillage_threads_concurrents(s_etat_processus); |
(*s_argument_thread).pid = fork(); |
(*s_argument_thread).pid = fork(); |
|
|
# ifdef OS2 |
|
if ((*s_argument_thread).pid == 0) |
|
{ |
|
sem_init(&semaphore_liste_threads, 0, 1); |
|
sem_init(&semaphore_gestionnaires_signaux, 0, 0); |
|
sem_init(&semaphore_gestionnaires_signaux_atomique, 0, 1); |
|
sem_init(&((*s_etat_processus).semaphore_fork), 0, 0); |
|
} |
|
# endif |
|
|
|
deverrouillage_threads_concurrents(s_etat_processus); |
deverrouillage_threads_concurrents(s_etat_processus); |
|
|
pthread_sigmask(SIG_SETMASK, &oldset2, NULL); |
pthread_sigmask(SIG_SETMASK, &oldset2, NULL); |
Line 1196 instruction_detach(struct_processus *s_e
|
Line 1172 instruction_detach(struct_processus *s_e
|
pthread_mutex_init(&((*s_argument_thread).mutex), &attributs_mutex); |
pthread_mutex_init(&((*s_argument_thread).mutex), &attributs_mutex); |
pthread_mutexattr_destroy(&attributs_mutex); |
pthread_mutexattr_destroy(&attributs_mutex); |
|
|
|
pthread_mutexattr_init(&attributs_mutex); |
|
pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_RECURSIVE); |
|
pthread_mutex_init(&((*s_argument_thread).mutex_nombre_references), |
|
&attributs_mutex); |
|
pthread_mutexattr_destroy(&attributs_mutex); |
|
|
if ((*s_argument_thread).pid > 0) |
if ((*s_argument_thread).pid > 0) |
{ |
{ |
/* |
/* |
Line 1341 instruction_detach(struct_processus *s_e
|
Line 1323 instruction_detach(struct_processus *s_e
|
* Processus fils |
* Processus fils |
*/ |
*/ |
|
|
|
# ifdef _BROKEN_SIGINFO |
|
liberation_fifos_signaux(s_etat_processus); |
|
creation_fifos_signaux(s_etat_processus); |
|
# endif |
|
|
if ((*s_etat_processus).debug == d_vrai) |
if ((*s_etat_processus).debug == d_vrai) |
if (((*s_etat_processus).type_debug & |
if (((*s_etat_processus).type_debug & |
d_debug_processus) != 0) |
d_debug_processus) != 0) |
Line 1530 instruction_detach(struct_processus *s_e
|
Line 1517 instruction_detach(struct_processus *s_e
|
} |
} |
} |
} |
|
|
|
# ifdef _BROKEN_SIGINFO |
|
destruction_fifos_signaux(s_etat_processus); |
|
# endif |
|
|
BUG(1, uprintf("Process management error line %d\n", __LINE__)); |
BUG(1, uprintf("Process management error line %d\n", __LINE__)); |
exit(EXIT_FAILURE); |
exit(EXIT_FAILURE); |
} |
} |
Line 1560 instruction_detach(struct_processus *s_e
|
Line 1551 instruction_detach(struct_processus *s_e
|
} |
} |
} |
} |
|
|
|
# ifdef _BROKEN_SIGINFO |
|
destruction_fifos_signaux(s_etat_processus); |
|
# endif |
|
|
BUG(1, uprintf("Process management error line %d\n", __LINE__)); |
BUG(1, uprintf("Process management error line %d\n", __LINE__)); |
exit(EXIT_FAILURE); |
exit(EXIT_FAILURE); |
} |
} |
Line 1593 instruction_detach(struct_processus *s_e
|
Line 1588 instruction_detach(struct_processus *s_e
|
} |
} |
} |
} |
|
|
|
# ifdef _BROKEN_SIGINFO |
|
destruction_fifos_signaux(s_etat_processus); |
|
# endif |
|
|
BUG(1, uprintf("Process management error line %d\n", __LINE__)); |
BUG(1, uprintf("Process management error line %d\n", __LINE__)); |
exit(EXIT_FAILURE); |
exit(EXIT_FAILURE); |
} |
} |
Line 1604 instruction_detach(struct_processus *s_e
|
Line 1603 instruction_detach(struct_processus *s_e
|
} |
} |
|
|
(*s_etat_processus).var_volatile_processus_pere = 0; |
(*s_etat_processus).var_volatile_processus_pere = 0; |
|
(*s_etat_processus).var_volatile_processus_racine = 0; |
|
|
// On réinitialise toutes les interruptions. |
// On réinitialise toutes les interruptions. |
|
|
Line 1741 instruction_detach(struct_processus *s_e
|
Line 1741 instruction_detach(struct_processus *s_e
|
} |
} |
} |
} |
|
|
|
# ifdef _BROKEN_SIGINFO |
|
destruction_fifos_signaux(s_etat_processus); |
|
# endif |
|
|
BUG(1, uprintf("Process management error line %d\n", __LINE__)); |
BUG(1, uprintf("Process management error line %d\n", __LINE__)); |
exit(EXIT_FAILURE); |
exit(EXIT_FAILURE); |
} |
} |
Line 1757 instruction_detach(struct_processus *s_e
|
Line 1761 instruction_detach(struct_processus *s_e
|
(*s_argument_thread2).nombre_references--; |
(*s_argument_thread2).nombre_references--; |
|
|
BUG((*s_argument_thread2).nombre_references < 0, |
BUG((*s_argument_thread2).nombre_references < 0, |
|
# ifdef _BROKEN_SIGINFO |
|
destruction_fifos_signaux(s_etat_processus), |
|
# endif |
printf("(*s_argument_thread2).nombre_references = %d\n", |
printf("(*s_argument_thread2).nombre_references = %d\n", |
(int) (*s_argument_thread2).nombre_references)); |
(int) (*s_argument_thread2).nombre_references)); |
|
|
Line 1820 instruction_detach(struct_processus *s_e
|
Line 1827 instruction_detach(struct_processus *s_e
|
} |
} |
} |
} |
|
|
|
# ifdef _BROKEN_SIGINFO |
|
destruction_fifos_signaux(s_etat_processus); |
|
# endif |
|
|
BUG(1, uprintf("Process management error line %d\n", __LINE__)); |
BUG(1, uprintf("Process management error line %d\n", __LINE__)); |
exit(EXIT_FAILURE); |
exit(EXIT_FAILURE); |
} |
} |
Line 1884 instruction_detach(struct_processus *s_e
|
Line 1895 instruction_detach(struct_processus *s_e
|
} |
} |
} |
} |
|
|
|
# ifdef _BROKEN_SIGINFO |
|
destruction_fifos_signaux(s_etat_processus); |
|
# endif |
|
|
BUG(1, uprintf("Process management error line %d\n", __LINE__)); |
BUG(1, uprintf("Process management error line %d\n", __LINE__)); |
exit(EXIT_FAILURE); |
exit(EXIT_FAILURE); |
} |
} |
Line 1936 instruction_detach(struct_processus *s_e
|
Line 1951 instruction_detach(struct_processus *s_e
|
} |
} |
} |
} |
|
|
|
# ifdef _BROKEN_SIGINFO |
|
destruction_fifos_signaux(s_etat_processus); |
|
# endif |
|
|
BUG(1, uprintf("Process management error line %d\n", __LINE__)); |
BUG(1, uprintf("Process management error line %d\n", __LINE__)); |
exit(EXIT_FAILURE); |
exit(EXIT_FAILURE); |
} |
} |
Line 2484 instruction_detach(struct_processus *s_e
|
Line 2503 instruction_detach(struct_processus *s_e
|
registre_stop; |
registre_stop; |
} |
} |
|
|
|
# ifdef _BROKEN_SIGINFO |
|
destruction_fifos_signaux(s_etat_processus); |
|
# endif |
|
|
(*s_etat_processus).erreur_systeme = d_es_signal; |
(*s_etat_processus).erreur_systeme = d_es_signal; |
exit(EXIT_FAILURE); |
exit(EXIT_FAILURE); |
} |
} |
Line 2518 instruction_detach(struct_processus *s_e
|
Line 2541 instruction_detach(struct_processus *s_e
|
|
|
if (sigaction(SIGPIPE, ®istre, NULL) != 0) |
if (sigaction(SIGPIPE, ®istre, NULL) != 0) |
{ |
{ |
|
# ifdef _BROKEN_SIGINFO |
|
destruction_fifos_signaux(s_etat_processus); |
|
# endif |
|
|
pthread_mutex_unlock(&((*s_etat_processus).mutex)); |
pthread_mutex_unlock(&((*s_etat_processus).mutex)); |
|
|
(*s_etat_processus).erreur_systeme = d_es_signal; |
(*s_etat_processus).erreur_systeme = d_es_signal; |
Line 2834 instruction_detach(struct_processus *s_e
|
Line 2861 instruction_detach(struct_processus *s_e
|
|
|
liberation(s_etat_processus, s_objet); |
liberation(s_etat_processus, s_objet); |
|
|
# if !defined(Cygwin) |
# if !defined(Cygwin) && !defined(OpenBSD) |
(*s_etat_processus).pile_signal.ss_flags = SS_DISABLE; |
do |
sigaltstack(&((*s_etat_processus).pile_signal), NULL); |
{ |
|
(*s_etat_processus).pile_signal.ss_flags = SS_DISABLE; |
|
} |
|
while(sigaltstack(&((*s_etat_processus).pile_signal), NULL) != 0); |
free((*s_etat_processus).pile_signal.ss_sp); |
free((*s_etat_processus).pile_signal.ss_sp); |
# endif |
# endif |
|
|
Line 2911 instruction_detach(struct_processus *s_e
|
Line 2941 instruction_detach(struct_processus *s_e
|
|
|
clear_history(); |
clear_history(); |
|
|
|
# ifdef _BROKEN_SIGINFO |
|
destruction_fifos_signaux(s_etat_processus); |
|
# endif |
|
|
free(s_etat_processus); |
free(s_etat_processus); |
|
|
# ifdef DEBUG_MEMOIRE |
# ifdef DEBUG_MEMOIRE |
Line 2990 instruction_detach(struct_processus *s_e
|
Line 3024 instruction_detach(struct_processus *s_e
|
|
|
// Être sûr que le processus fils soit déjà présent... |
// Être sûr que le processus fils soit déjà présent... |
|
|
|
attente.tv_sec = 0; |
|
attente.tv_nsec = GRANULARITE_us * 1000; |
|
|
while(kill((*s_argument_thread).pid, 0) != 0) |
while(kill((*s_argument_thread).pid, 0) != 0) |
{ |
{ |
//if ((errno != ESRCH) && (errno != EAGAIN)) |
//if ((errno != ESRCH) && (errno != EAGAIN)) |
Line 3001 instruction_detach(struct_processus *s_e
|
Line 3038 instruction_detach(struct_processus *s_e
|
} |
} |
|
|
nanosleep(&attente, NULL); |
nanosleep(&attente, NULL); |
|
INCR_GRANULARITE(attente.tv_nsec); |
} |
} |
|
|
// 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. |