version 1.70, 2013/09/06 10:30:51
|
version 1.84, 2016/03/22 17:12:14
|
Line 1
|
Line 1
|
/* |
/* |
================================================================================ |
================================================================================ |
RPL/2 (R) version 4.1.16 |
RPL/2 (R) version 4.1.25 |
Copyright (C) 1989-2013 Dr. BERTRAND Joël |
Copyright (C) 1989-2016 Dr. BERTRAND Joël |
|
|
This file is part of RPL/2. |
This file is part of RPL/2. |
|
|
Line 73 surveillance_processus(void *argument)
|
Line 73 surveillance_processus(void *argument)
|
|
|
sigfillset(&set); |
sigfillset(&set); |
pthread_sigmask(SIG_BLOCK, &set, NULL); |
pthread_sigmask(SIG_BLOCK, &set, NULL); |
|
nombre_thread_surveillance_processus++; |
|
|
s_argument_thread = argument; |
s_argument_thread = argument; |
s_etat_processus = (*s_argument_thread).s_etat_processus; |
s_etat_processus = (*s_argument_thread).s_etat_processus; |
Line 1435 surveillance_processus(void *argument)
|
Line 1436 surveillance_processus(void *argument)
|
} |
} |
} |
} |
|
|
|
nombre_thread_surveillance_processus--; |
pthread_exit(NULL); |
pthread_exit(NULL); |
return(NULL); |
|
} |
} |
|
|
|
|
Line 2997 lecture_pipe(struct_processus *s_etat_pr
|
Line 2998 lecture_pipe(struct_processus *s_etat_pr
|
void |
void |
scrutation_injection(struct_processus *s_etat_processus) |
scrutation_injection(struct_processus *s_etat_processus) |
{ |
{ |
fd_set ensemble_descripteurs; |
|
|
|
logical1 drapeau_erreur; |
logical1 drapeau_erreur; |
logical1 registre_arret_si_exception; |
logical1 registre_arret_si_exception; |
|
|
# ifdef PSELECT |
struct pollfd fds; |
struct timespec timeout; |
|
# else |
|
struct timeval timeout; |
|
# endif |
|
|
|
unsigned char tampon; |
unsigned char tampon; |
unsigned char tampon_profilage[20]; |
unsigned char tampon_profilage[20]; |
Line 3017 scrutation_injection(struct_processus *s
|
Line 3012 scrutation_injection(struct_processus *s
|
|
|
if ((*s_etat_processus).var_volatile_processus_racine == 0) |
if ((*s_etat_processus).var_volatile_processus_racine == 0) |
{ |
{ |
FD_ZERO(&ensemble_descripteurs); |
fds.fd = (*s_etat_processus).pipe_nombre_injections; |
FD_SET((*s_etat_processus).pipe_nombre_injections, |
fds.events = POLLIN; |
&ensemble_descripteurs); |
fds.revents = 0; |
|
|
# ifdef PSELECT |
if (poll(&fds, 1, 0) > 0) |
timeout.tv_sec = 0; |
|
timeout.tv_nsec = 0; |
|
|
|
if (pselect((*s_etat_processus).pipe_nombre_injections + 1, |
|
&ensemble_descripteurs, NULL, NULL, &timeout, NULL) > 0) |
|
# else |
|
timeout.tv_sec = 0; |
|
timeout.tv_usec = 0; |
|
|
|
if (select((*s_etat_processus).pipe_nombre_injections + 1, |
|
&ensemble_descripteurs, NULL, NULL, &timeout) > 0) |
|
# endif |
|
{ |
{ |
if (read_atomic(s_etat_processus, |
if (read_atomic(s_etat_processus, |
(*s_etat_processus).pipe_nombre_injections, |
(*s_etat_processus).pipe_nombre_injections, |