--- rpl/src/gestion_processus.c	2015/02/19 11:01:20	1.78
+++ rpl/src/gestion_processus.c	2024/01/09 07:33:48	1.104
@@ -1,7 +1,7 @@
 /*
 ================================================================================
-  RPL/2 (R) version 4.1.21
-  Copyright (C) 1989-2015 Dr. BERTRAND Joël
+  RPL/2 (R) version 4.1.35
+  Copyright (C) 1989-2024 Dr. BERTRAND Joël
 
   This file is part of RPL/2.
 
@@ -83,7 +83,7 @@ surveillance_processus(void *argument)
 		BUG(1, uprintf("General mutex error!\n"));
 	}
 
-	insertion_thread_surveillance(s_etat_processus, s_argument_thread);
+	nombre_threads_surveillance_processus++;
 
 	if (pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus)) != 0)
 	{
@@ -91,6 +91,8 @@ surveillance_processus(void *argument)
 		BUG(1, uprintf("General mutex error!\n"));
 	}
 
+	insertion_thread_surveillance(s_etat_processus, s_argument_thread);
+
 	attente.tv_sec = 0;
 	attente.tv_nsec = GRANULARITE_us * 1000;
 
@@ -362,7 +364,8 @@ surveillance_processus(void *argument)
 							}
 						}
 
-						envoi_signal_thread((*s_argument_thread).thread_pere,
+						envoi_signal_thread(NULL,
+								(*s_argument_thread).thread_pere,
 								rpl_siginject);
 						break;
 					}
@@ -389,7 +392,6 @@ surveillance_processus(void *argument)
 			}
 			else
 			{
-				perror("read");
 				(*s_etat_processus).erreur_systeme = d_es_processus;
 			}
 
@@ -630,7 +632,8 @@ surveillance_processus(void *argument)
 									d_es_processus;
 						}
 
-						envoi_signal_thread((*s_argument_thread).thread_pere,
+						envoi_signal_thread(NULL,
+								(*s_argument_thread).thread_pere,
 								rpl_siginject);
 
 						if (pthread_mutex_lock(&((*s_etat_processus)
@@ -1426,8 +1429,22 @@ surveillance_processus(void *argument)
 			fflush(stdout);
 		}
 
+		if (pthread_mutex_unlock(&((*s_etat_processus)
+				.mutex_pile_processus)) != 0)
+		{
+			(*s_etat_processus).erreur_systeme_processus_fils = d_es_processus;
+		}
+
 		retrait_thread_surveillance(s_etat_processus, s_argument_thread);
 
+		if (pthread_mutex_lock(&((*s_etat_processus)
+				.mutex_pile_processus)) != 0)
+		{
+			(*s_etat_processus).erreur_systeme_processus_fils = d_es_processus;
+		}
+
+		nombre_threads_surveillance_processus--;
+
 		if (pthread_mutex_unlock(&((*s_etat_processus)
 				.mutex_pile_processus)) != 0)
 		{
@@ -1436,7 +1453,6 @@ surveillance_processus(void *argument)
 	}
 
 	pthread_exit(NULL);
-	return(NULL);
 }
 
 
@@ -2997,43 +3013,25 @@ lecture_pipe(struct_processus *s_etat_pr
 void
 scrutation_injection(struct_processus *s_etat_processus)
 {
-	fd_set							ensemble_descripteurs;
-
 	logical1						drapeau_erreur;
 	logical1						registre_arret_si_exception;
 
-#	ifdef PSELECT
-		struct timespec				timeout;
-#	else
-		struct timeval				timeout;
-#	endif
+	struct pollfd					fds;
 
 	unsigned char					tampon;
 	unsigned char					tampon_profilage[20];
 
-	// Si on est dans le processus père, il n'y a rien à surveiller.
-
 	scrutation_interruptions(s_etat_processus);
 
+	// Si on est dans le processus père, il n'y a rien à surveiller.
+
 	if ((*s_etat_processus).var_volatile_processus_racine == 0)
 	{
-		FD_ZERO(&ensemble_descripteurs);
-		FD_SET((*s_etat_processus).pipe_nombre_injections,
-				&ensemble_descripteurs);
-
-#		ifdef PSELECT
-		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
+		fds.fd = (*s_etat_processus).pipe_nombre_injections;
+		fds.events = POLLIN;
+		fds.revents = 0;
+
+		if (poll(&fds, 1, 0) > 0)
 		{
 			if (read_atomic(s_etat_processus,
 					(*s_etat_processus).pipe_nombre_injections,
@@ -3190,7 +3188,6 @@ scrutation_injection(struct_processus *s
 				}
 			}
 		}
-
 	}
 
 	return;