--- rpl/src/gestion_processus.c	2013/04/01 15:29:34	1.65
+++ rpl/src/gestion_processus.c	2013/05/21 12:10:11	1.66
@@ -47,15 +47,11 @@ surveillance_processus(void *argument)
 	logical1						drapeau;
 	logical1						drapeau_fin;
 	logical1						drapeau_fin_scrutation;
-	logical1						drapeau_interruptions_traitees;
-	logical1						drapeau_objets_traites;
+	logical1						drapeau_elements_traites;
 
 	pid_t							pid;
-	pid_t							pid_candidat;
 	pid_t							pid_erreur;
 
-	pthread_t						tid_candidat;
-
 	ssize_t							iostat;
 	ssize_t							longueur_ecriture;
 
@@ -100,8 +96,7 @@ surveillance_processus(void *argument)
 
 	status = 0;
 
-	drapeau_interruptions_traitees = d_faux;
-	drapeau_objets_traites = d_faux;
+	drapeau_elements_traites = d_faux;
 
 	if ((*s_etat_processus).debug == d_vrai)
 		if (((*s_etat_processus).type_debug &
@@ -146,13 +141,12 @@ surveillance_processus(void *argument)
 	 */
 
 	while(read_atomic(s_etat_processus,
-			(*s_argument_thread).pipe_nombre_objets_attente[0],
+			(*s_argument_thread).pipe_nombre_elements_attente[0],
 			&caractere, sizeof(caractere)) == 0)
 	{
 		if ((*s_etat_processus).var_volatile_requete_arret != 0)
 		{
-			drapeau_objets_traites = d_vrai;
-			drapeau_interruptions_traitees = d_vrai;
+			drapeau_elements_traites = d_vrai;
 		}
 
 		nanosleep(&attente, NULL);
@@ -166,373 +160,222 @@ surveillance_processus(void *argument)
 			 * Le processus est un processus détaché.
 			 */
 
-			// Scrutation de l'envoi de données par le fils.
-
-			pid_candidat = 0;
-
-			if (drapeau_objets_traites == d_vrai)
+			if (drapeau_elements_traites == d_vrai)
 			{
 				nanosleep(&attente, NULL);
 			}
 			else if ((iostat = read_atomic(s_etat_processus,
-					(*s_argument_thread).pipe_nombre_objets_attente[0],
-					&pid_candidat, sizeof(pid_candidat))) == 0)
+					(*s_argument_thread).pipe_nombre_elements_attente[0],
+					&caractere, sizeof(caractere))) == 0)
 			{
 				// Rien dans le pipe
-
 				nanosleep(&attente, NULL);
 			}
-			else if (iostat != sizeof(pid_candidat))
-			{
-				(*s_etat_processus).erreur_systeme_processus_fils =
-						d_es_processus;
-			}
-			else
+			else if (iostat == sizeof(caractere))
 			{
-				// Un pid est dans le pipe. On vérifie que les deux pids
-				// correspondent.
+				// Un objet supplémentaire est dans le pipe correspondant
+				// au processus surveillé par ce thread.
 
-				if (pid_candidat == -2)
-				{
-					drapeau_objets_traites = d_vrai;
-				}
-				else if (pid_candidat == -1)
+				if (pthread_mutex_lock(&((*s_etat_processus).mutex)) != 0)
 				{
+					(*s_etat_processus).erreur_systeme_processus_fils =
+							d_es_processus;
 				}
-				else if ((iostat = read_atomic(s_etat_processus,
-						(*s_argument_thread).pipe_nombre_objets_attente[0],
-						&pid_candidat, sizeof(pid_candidat))) ==
-						sizeof(pid_candidat))
+
+				l_element_courant = (struct_liste_chainee *)
+						(*s_etat_processus).l_base_pile_processus;
+
+				while(l_element_courant != NULL)
 				{
-					if ((*s_argument_thread).pid != pid_candidat)
+					if ((*(*((struct_processus_fils *)
+							(*(*l_element_courant).donnee).objet))
+							.thread).processus_detache == d_faux)
 					{
-						(*s_etat_processus).erreur_systeme_processus_fils =
-								d_es_processus;
-						BUG(1, printf("Spurious process identifier"));
+						l_element_courant = (*l_element_courant)
+								.suivant;
+						continue;
 					}
 
-					// Un objet supplémentaire est dans le pipe correspondant
-					// au processus surveillé par ce thread.
-
-					if (pthread_mutex_lock(&((*s_etat_processus).mutex)) != 0)
+					if ((*(*((struct_processus_fils *)
+							(*(*l_element_courant).donnee).objet))
+							.thread).pid == (*s_argument_thread).pid)
 					{
-						(*s_etat_processus).erreur_systeme_processus_fils =
-								d_es_processus;
+						break;
 					}
-					else
-					{
-						l_element_courant = (struct_liste_chainee *)
-								(*s_etat_processus).l_base_pile_processus;
 
-						while(l_element_courant != NULL)
-						{
-							if ((*(*((struct_processus_fils *)
-									(*(*l_element_courant).donnee).objet))
-									.thread).processus_detache == d_faux)
-							{
-								l_element_courant = (*l_element_courant)
-										.suivant;
-								continue;
-							}
+					l_element_courant = (*l_element_courant).suivant;
+				}
 
-							if ((*(*((struct_processus_fils *)
-									(*(*l_element_courant).donnee).objet))
-									.thread).pid == pid_candidat)
-							{
-								if ((*s_etat_processus).debug == d_vrai)
-									if (((*s_etat_processus).type_debug &
-											d_debug_processus) != 0)
-								{
-									if ((*s_etat_processus).langue == 'F')
-									{
-										printf("[%d] Données en provenance "
-												"du processus %d\n",
-												(int) getpid(),
-												(int) (*s_argument_thread).pid);
-										fflush(stdout);
-									}
-									else
-									{
-										printf("[%d] Data from process %d\n",
-												(int) getpid(),
-												(int) (*s_argument_thread).pid);
-										fflush(stdout);
-									}
-								}
+				BUG(l_element_courant == NULL,
+						printf("Process or thread not found"));
 
-								if (pthread_mutex_lock(
-										&((*(*((struct_processus_fils *)
-										(*(*l_element_courant).donnee).objet))
-										.thread).mutex)) != 0)
+				switch(caractere)
+				{
+					case 1:
+					case 2:
+					{
+						if ((*s_etat_processus).debug == d_vrai)
+							if (((*s_etat_processus).type_debug &
+									d_debug_processus) != 0)
+						{
+							if ((*s_etat_processus).langue == 'F')
+							{
+								if (caractere == 1)
 								{
-									(*s_etat_processus).erreur_systeme =
-											d_es_processus;
+									printf("[%d] Données en provenance "
+											"du processus %d\n", (int) getpid(),
+											(int) (*s_argument_thread).pid);
 								}
-
-								(*(*((struct_processus_fils *)
-										(*(*l_element_courant).donnee).objet))
-										.thread).nombre_objets_dans_pipe++;
-
-								if (pthread_mutex_unlock(
-										&((*(*((struct_processus_fils *)
-										(*(*l_element_courant).donnee).objet))
-										.thread).mutex)) != 0)
+								else
 								{
-									(*s_etat_processus).erreur_systeme =
-											d_es_processus;
+									printf("[%d] Interrution logicielle "
+											"en provenance du processus "
+											"%d\n", (int) getpid(),
+											(int) (*s_argument_thread).pid);
 								}
 
-								while((longueur_ecriture =
-										write_atomic(s_etat_processus,
-										(*(*((struct_processus_fils *)
-										(*(*l_element_courant).donnee).objet))
-										.thread).pipe_acquittement[1], "-",
-										sizeof(unsigned char))) !=
-										sizeof(unsigned char))
+								fflush(stdout);
+							}
+							else
+							{
+								if (caractere == 1)
 								{
-									if (longueur_ecriture == -1)
-									{
-										(*s_etat_processus)
-												.erreur_systeme_processus_fils =
-												d_es_processus;
-									}
+									printf("[%d] Data from process %d\n",
+											(int) getpid(),
+											(int) (*s_argument_thread).pid);
 								}
-
-								if ((*s_etat_processus).debug == d_vrai)
-									if (((*s_etat_processus).type_debug &
-											d_debug_processus) != 0)
+								else
 								{
-									if ((*s_etat_processus).langue == 'F')
-									{
-										printf("[%d] Données acquittées "
-												"en provenance du "
-												"processus %d\n",
-												(int) getpid(),
-												(int) (*s_argument_thread).pid);
-										fflush(stdout);
-									}
-									else
-									{
-										printf("[%d] Data acknowklegment "
-												"from process %d\n",
-												(int) getpid(),
-												(int) (*s_argument_thread).pid);
-										fflush(stdout);
-									}
+									printf("[%d] Software interrupt "
+											"from process %d\n", (int) getpid(),
+											(int) (*s_argument_thread).pid);
 								}
 
-								break;
+								fflush(stdout);
 							}
-
-							l_element_courant = (*l_element_courant).suivant;
 						}
 
-						BUG(l_element_courant == NULL,
-								printf("Process or thread not found"));
-
-						if (pthread_mutex_unlock(&((*s_etat_processus).mutex))
-								!= 0)
+						if (pthread_mutex_lock(&((*(*((struct_processus_fils *)
+								(*(*l_element_courant).donnee).objet))
+								.thread).mutex)) != 0)
 						{
-							(*s_etat_processus).erreur_systeme_processus_fils =
+							(*s_etat_processus).erreur_systeme =
 									d_es_processus;
 						}
 
-						envoi_signal_thread((*s_argument_thread).thread_pere,
-								rpl_siginject);
-					}
-				}
-				else
-				{
-					(*s_etat_processus).erreur_systeme_processus_fils =
-							d_es_processus;
-				}
-			}
-
-			// Scrutation de l'envoi d'interruptions par le fils.
-
-			if (drapeau_interruptions_traitees == d_vrai)
-			{
-				nanosleep(&attente, NULL);
-			}
-			else if ((iostat = read_atomic(s_etat_processus,
-					(*s_argument_thread).pipe_nombre_interruptions_attente[0],
-					&pid_candidat, sizeof(pid_candidat))) == 0)
-			{
-				// Rien dans le pipe
-
-				nanosleep(&attente, NULL);
-			}
-			else if (iostat != sizeof(pid_candidat))
-			{
-				(*s_etat_processus).erreur_systeme_processus_fils =
-						d_es_processus;
-			}
-			else
-			{
-				// Un pid est dans le pipe. On vérifie que les deux pids
-				// correspondent.
-
-				if (pid_candidat == -2)
-				{
-					drapeau_interruptions_traitees = d_vrai;
-				}
-				else if (pid_candidat == -1)
-				{
-				}
-				else if ((iostat = read_atomic(s_etat_processus,
-						(*s_argument_thread).pipe_nombre_interruptions_attente
-						[0], &pid_candidat, sizeof(pid_candidat)))
-						== sizeof(pid_candidat))
-				{
-					if ((*s_argument_thread).pid != pid_candidat)
-					{
-						(*s_etat_processus).erreur_systeme_processus_fils =
-								d_es_processus;
-						BUG(1, printf("Spurious interrupt"));
-					}
-
-					// Une interruption supplémentaire est dans le pipe
-					// correspondant au processus surveillé par ce thread.
+						if (caractere == 1)
+						{
+							(*(*((struct_processus_fils *)
+									(*(*l_element_courant).donnee).objet))
+									.thread).nombre_objets_dans_pipe++;
+						}
+						else
+						{
+							(*(*((struct_processus_fils *)
+									(*(*l_element_courant).donnee).objet))
+							 		.thread).nombre_interruptions_dans_pipe++;
+							(*s_etat_processus)
+									.nombre_interruptions_non_affectees++;
+						}
 
-					if (pthread_mutex_lock(&((*s_etat_processus).mutex)) != 0)
-					{
-						(*s_etat_processus).erreur_systeme_processus_fils =
-								d_es_processus;
-					}
-					else
-					{
-						l_element_courant = (struct_liste_chainee *)
-								(*s_etat_processus).l_base_pile_processus;
+						if (pthread_mutex_unlock(
+								&((*(*((struct_processus_fils *)
+								(*(*l_element_courant).donnee).objet))
+								.thread).mutex)) != 0)
+						{
+							(*s_etat_processus).erreur_systeme =
+									d_es_processus;
+						}
 
-						while(l_element_courant != NULL)
+						while((longueur_ecriture =
+								write_atomic(s_etat_processus,
+								(*(*((struct_processus_fils *)
+								(*(*l_element_courant).donnee).objet))
+								.thread).pipe_acquittement[1], "-",
+								sizeof(unsigned char))) !=
+								sizeof(unsigned char))
 						{
-							if ((*(*((struct_processus_fils *)
-									(*(*l_element_courant).donnee).objet))
-									.thread).processus_detache == d_faux)
+							if (longueur_ecriture == -1)
 							{
-								l_element_courant = (*l_element_courant)
-										.suivant;
-								continue;
+								(*s_etat_processus)
+										.erreur_systeme_processus_fils =
+										d_es_processus;
 							}
+						}
 
-							if ((*(*((struct_processus_fils *)
-									(*(*l_element_courant).donnee).objet))
-									.thread).pid == pid_candidat)
+						if ((*s_etat_processus).debug == d_vrai)
+							if (((*s_etat_processus).type_debug &
+									d_debug_processus) != 0)
+						{
+							if ((*s_etat_processus).langue == 'F')
 							{
-								if ((*s_etat_processus).debug == d_vrai)
-									if (((*s_etat_processus).type_debug &
-											d_traitement_interruption) != 0)
+								if (caractere == 1)
 								{
-									if ((*s_etat_processus).langue == 'F')
-									{
-										printf("[%d] Interrution logicielle "
-												"en provenance du processus "
-												"%d\n", (int) getpid(),
-												(int) (*s_argument_thread).pid);
-										fflush(stdout);
-									}
-									else
-									{
-										printf("[%d] Software interrupt "
-												"from process %d\n",
-												(int) getpid(),
-												(int) (*s_argument_thread).pid);
-										fflush(stdout);
-									}
+									printf("[%d] Données acquittées "
+											"en provenance du "
+											"processus %d\n", (int) getpid(),
+											(int) (*s_argument_thread).pid);
 								}
-
-								if (pthread_mutex_lock(
-										&((*(*((struct_processus_fils *)
-										(*(*l_element_courant).donnee).objet))
-										.thread).mutex)) != 0)
+								else
 								{
-									(*s_etat_processus).erreur_systeme =
-											d_es_processus;
+									printf("[%d] Interruption logicielle "
+											"acquittée en provenance "
+											"du processus %d\n", (int) getpid(),
+											(int) (*s_argument_thread).pid);
 								}
 
-								(*(*((struct_processus_fils *)
-										(*(*l_element_courant).donnee)
-										.objet)).thread)
-										.nombre_interruptions_dans_pipe++;
-
-								if (pthread_mutex_unlock(
-										&((*(*((struct_processus_fils *)
-										(*(*l_element_courant).donnee).objet))
-										.thread).mutex)) != 0)
-								{
-									(*s_etat_processus).erreur_systeme =
-											d_es_processus;
-								}
-
-								(*s_etat_processus)
-										.nombre_interruptions_non_affectees++;
-
-								while((longueur_ecriture =
-										write_atomic(s_etat_processus,
-										(*(*((struct_processus_fils *)
-										(*(*l_element_courant).donnee).objet))
-										.thread).pipe_acquittement[1], "-",
-										sizeof(unsigned char))) !=
-										sizeof(unsigned char))
+								fflush(stdout);
+							}
+							else
+							{
+								if (caractere == 1)
 								{
-									if (longueur_ecriture == -1)
-									{
-										(*s_etat_processus)
-												.erreur_systeme_processus_fils =
-												d_es_processus;
-									}
+									printf("[%d] Data acknowklegment "
+											"from process %d\n", (int) getpid(),
+											(int) (*s_argument_thread).pid);
 								}
-
-								if ((*s_etat_processus).debug == d_vrai)
-									if (((*s_etat_processus).type_debug &
-											d_traitement_interruption) != 0)
+								else
 								{
-									if ((*s_etat_processus).langue == 'F')
-									{
-										printf("[%d] Interruption logicielle "
-												"acquittée en provenance "
-												"du processus %d\n",
-												(int) getpid(),
-												(int) (*s_argument_thread).pid);
-										fflush(stdout);
-									}
-									else
-									{
-										printf("[%d] Software interrupt "
-												"acknowklegment from "
-												"process %d\n",
-												(int) getpid(),
-												(int) (*s_argument_thread).pid);
-										fflush(stdout);
-									}
+									printf("[%d] Software interrupt "
+											"acknowklegment from "
+											"process %d\n", (int) getpid(),
+											(int) (*s_argument_thread).pid);
 								}
 
-								break;
+								fflush(stdout);
 							}
-
-							l_element_courant = (*l_element_courant).suivant;
-						}
-
-						BUG(l_element_courant == NULL,
-								printf("Process or thread not found"));
-
-						if (pthread_mutex_unlock(&((*s_etat_processus).mutex))
-								!= 0)
-						{
-							(*s_etat_processus).erreur_systeme_processus_fils =
-									d_es_processus;
 						}
 
 						envoi_signal_thread((*s_argument_thread).thread_pere,
 								rpl_siginject);
+						break;
+					}
+
+					case 0:
+					{
+						break;
+					}
+
+					default:
+					{
+						(*s_etat_processus).erreur_systeme_processus_fils =
+								d_es_processus;
+						BUG(1, printf("Spurious interprocess data"));
 					}
 				}
-				else
+
+				if (pthread_mutex_unlock(&((*s_etat_processus).mutex))
+						!= 0)
 				{
 					(*s_etat_processus).erreur_systeme_processus_fils =
 							d_es_processus;
 				}
 			}
+			else
+			{
+				perror("read");
+				(*s_etat_processus).erreur_systeme = d_es_processus;
+			}
 
 			if ((pid = waitpid((*s_argument_thread).pid, &status, WNOHANG)) < 0)
 			{
@@ -556,379 +399,228 @@ surveillance_processus(void *argument)
 			 * Le processus n'est pas détaché.
 			 */
 
-			// Scrutation de l'envoi de données par le fils.
-
-			tid_candidat = (pthread_t) 0;
-
-			if (drapeau_objets_traites == d_vrai)
+			if (drapeau_elements_traites == d_vrai)
 			{
 				nanosleep(&attente, NULL);
 			}
 			else if ((iostat = read_atomic(s_etat_processus,
-					(*s_argument_thread).pipe_nombre_objets_attente[0],
-					&tid_candidat, sizeof(tid_candidat))) == 0)
+					(*s_argument_thread).pipe_nombre_elements_attente[0],
+					&caractere, sizeof(caractere))) == 0)
 			{
 				// Rien dans le pipe
-
 				nanosleep(&attente, NULL);
 			}
-			else if (iostat != sizeof(tid_candidat))
+			else if (iostat == sizeof(caractere))
 			{
-				(*s_etat_processus).erreur_systeme_processus_fils =
-						d_es_processus;
-			}
-			else
-			{
-				// Un pid est dans le pipe. On vérifie que les deux pids
-				// correspondent.
+				// Un objet supplémentaire est dans le pipe correspondant
+				// au processus surveillé par ce thread.
 
-				if (tid_candidat == (pthread_t) -2)
-				{
-					drapeau_objets_traites = d_vrai;
-				}
-				else if (tid_candidat == (pthread_t) -1)
+				if (pthread_mutex_lock(&((*s_etat_processus).mutex)) != 0)
 				{
+					(*s_etat_processus).erreur_systeme_processus_fils =
+							d_es_processus;
 				}
-				else if ((iostat = read_atomic(s_etat_processus,
-						(*s_argument_thread).pipe_nombre_objets_attente[0],
-						&tid_candidat, sizeof(tid_candidat))) ==
-						sizeof(tid_candidat))
+
+				l_element_courant = (struct_liste_chainee *)
+						(*s_etat_processus).l_base_pile_processus;
+
+				while(l_element_courant != NULL)
 				{
-					if (pthread_equal((*s_argument_thread).tid,
-								tid_candidat) == 0)
+					if ((*(*((struct_processus_fils *)
+							(*(*l_element_courant).donnee).objet))
+							.thread).processus_detache == d_vrai)
 					{
-						(*s_etat_processus).erreur_systeme_processus_fils =
-								d_es_processus;
-						BUG(1, printf("Spurious thread identifier"));
+						l_element_courant = (*l_element_courant)
+								.suivant;
+						continue;
 					}
 
-					// Un objet supplémentaire est dans le pipe correspondant
-					// au processus surveillé par ce thread.
-
-					if (pthread_mutex_lock(&((*s_etat_processus).mutex)) != 0)
+					if ((*(*((struct_processus_fils *)
+							(*(*l_element_courant).donnee).objet))
+							.thread).tid == (*s_argument_thread).tid)
 					{
-						(*s_etat_processus).erreur_systeme_processus_fils =
-								d_es_processus;
+						break;
 					}
-					else
-					{
-						l_element_courant = (struct_liste_chainee *)
-								(*s_etat_processus).l_base_pile_processus;
 
-						while(l_element_courant != NULL)
-						{
-							if ((*(*((struct_processus_fils *)
-									(*(*l_element_courant).donnee).objet))
-									.thread).processus_detache == d_vrai)
-							{
-								l_element_courant = (*l_element_courant)
-										.suivant;
-								continue;
-							}
+					l_element_courant = (*l_element_courant).suivant;
+				}
 
-							if (pthread_equal((*(*((struct_processus_fils *)
-									(*(*l_element_courant).donnee).objet))
-									.thread).tid, tid_candidat) != 0)
-							{
-								if ((*s_etat_processus).debug == d_vrai)
-									if (((*s_etat_processus).type_debug &
-											d_debug_processus) != 0)
-								{
-									if ((*s_etat_processus).langue == 'F')
-									{
-										printf("[%d] Données en provenance "
-												"du thread %llu\n",
-												(int) getpid(),
-												(unsigned long long)
-												(*s_argument_thread).tid);
-										fflush(stdout);
-									}
-									else
-									{
-										printf("[%d] Data from thread %llu\n",
-												(int) getpid(),
-												(unsigned long long)
-												(*s_argument_thread).tid);
-										fflush(stdout);
-									}
-								}
+				BUG(l_element_courant == NULL,
+						printf("Process or thread not found"));
 
-								if (pthread_mutex_lock(
-										&((*(*((struct_processus_fils *)
-										(*(*l_element_courant).donnee).objet))
-										.thread).mutex)) != 0)
+				switch(caractere)
+				{
+					case 1:
+					case 2:
+					{
+						if ((*s_etat_processus).debug == d_vrai)
+							if (((*s_etat_processus).type_debug &
+									d_debug_processus) != 0)
+						{
+							if ((*s_etat_processus).langue == 'F')
+							{
+								if (caractere == 1)
 								{
-									(*s_etat_processus).erreur_systeme =
-											d_es_processus;
+									printf("[%d] Données en provenance "
+											"du thread %llu\n", (int) getpid(),
+											(unsigned long long)
+											(*s_argument_thread).tid);
 								}
-
-								(*(*((struct_processus_fils *)
-										(*(*l_element_courant).donnee).objet))
-										.thread).nombre_objets_dans_pipe++;
-
-								if (pthread_mutex_unlock(
-										&((*(*((struct_processus_fils *)
-										(*(*l_element_courant).donnee).objet))
-										.thread).mutex)) != 0)
+								else
 								{
-									(*s_etat_processus).erreur_systeme =
-											d_es_processus;
+									printf("[%d] Interrution logicielle "
+											"en provenance du thread "
+											"%llu\n", (int) getpid(),
+											(unsigned long long)
+											(*s_argument_thread).tid);
 								}
 
-								while((longueur_ecriture =
-										write_atomic(s_etat_processus,
-										(*(*((struct_processus_fils *)
-										(*(*l_element_courant).donnee).objet))
-										.thread).pipe_acquittement[1], "-",
-										sizeof(unsigned char))) !=
-										sizeof(unsigned char))
+								fflush(stdout);
+							}
+							else
+							{
+								if (caractere == 1)
 								{
-									if (longueur_ecriture == -1)
-									{
-										(*s_etat_processus)
-												.erreur_systeme_processus_fils =
-												d_es_processus;
-									}
+									printf("[%d] Data from thread %llu\n",
+											(int) getpid(), (unsigned long long)
+											(*s_argument_thread).tid);
 								}
-
-								if ((*s_etat_processus).debug == d_vrai)
-									if (((*s_etat_processus).type_debug &
-											d_debug_processus) != 0)
+								else
 								{
-									if ((*s_etat_processus).langue == 'F')
-									{
-										printf("[%d] Données acquittées "
-												"en provenance du thread "
-												"%llu\n", (int) getpid(),
-												(unsigned long long)
-												(*s_argument_thread).tid);
-										fflush(stdout);
-									}
-									else
-									{
-										printf("[%d] Data acknowklegment "
-												"from thread %llu\n",
-												(int) getpid(),
-												(unsigned long long)
-												(*s_argument_thread).tid);
-										fflush(stdout);
-									}
+									printf("[%d] Software interrupt "
+											"from thread %llu\n",
+											(int) getpid(), (unsigned long long)
+											(*s_argument_thread).tid);
 								}
 
-								break;
+								fflush(stdout);
 							}
-
-							l_element_courant = (*l_element_courant).suivant;
 						}
 
-						BUG(l_element_courant == NULL,
-								printf("Process or thread not found\n"));
-
-						if (pthread_mutex_unlock(&((*s_etat_processus).mutex))
-								!= 0)
+						if (pthread_mutex_lock(&((*(*((struct_processus_fils *)
+								(*(*l_element_courant).donnee).objet))
+								.thread).mutex)) != 0)
 						{
-							(*s_etat_processus).erreur_systeme_processus_fils =
+							(*s_etat_processus).erreur_systeme =
 									d_es_processus;
 						}
-					}
-				}
-				else
-				{
-					(*s_etat_processus).erreur_systeme_processus_fils =
-							d_es_processus;
-				}
-			}
-
-			// Scrutation de l'envoi d'interruptions par le fils.
-
-			if (drapeau_interruptions_traitees == d_vrai)
-			{
-				nanosleep(&attente, NULL);
-			}
-			else if ((iostat = read_atomic(s_etat_processus,
-					(*s_argument_thread).pipe_nombre_interruptions_attente[0],
-					&tid_candidat, sizeof(tid_candidat))) == 0)
-			{
-				// Rien dans le pipe
-
-				nanosleep(&attente, NULL);
-			}
-			else if (iostat != sizeof(tid_candidat))
-			{
-				(*s_etat_processus).erreur_systeme_processus_fils =
-						d_es_processus;
-			}
-			else
-			{
-				// Un pid est dans le pipe. On vérifie que les deux pids
-				// correspondent.
-
-				if (tid_candidat == (pthread_t) -2)
-				{
-					drapeau_interruptions_traitees = d_vrai;
-				}
-				else if (tid_candidat == (pthread_t) -1)
-				{
-				}
-				else if ((iostat = read_atomic(s_etat_processus,
-						(*s_argument_thread).pipe_nombre_interruptions_attente
-						[0], &tid_candidat, sizeof(tid_candidat))) ==
-						sizeof(tid_candidat))
-				{
-					if (pthread_equal((*s_argument_thread).tid,
-							tid_candidat) == 0)
-					{
-						(*s_etat_processus).erreur_systeme_processus_fils =
-								d_es_processus;
-						BUG(1, printf("Spurious interrupt"));
-					}
 
-					// Une interruption supplémentaire est dans le pipe
-					// correspondant au processus surveillé par ce thread.
+						if (caractere == 1)
+						{
+							(*(*((struct_processus_fils *)
+									(*(*l_element_courant).donnee).objet))
+									.thread).nombre_objets_dans_pipe++;
+						}
+						else
+						{
+							(*(*((struct_processus_fils *)
+									(*(*l_element_courant).donnee).objet))
+							 		.thread).nombre_interruptions_dans_pipe++;
+							(*s_etat_processus)
+									.nombre_interruptions_non_affectees++;
+						}
 
-					if (pthread_mutex_lock(&((*s_etat_processus).mutex)) != 0)
-					{
-						(*s_etat_processus).erreur_systeme_processus_fils =
-								d_es_processus;
-					}
-					else
-					{
-						l_element_courant = (struct_liste_chainee *)
-								(*s_etat_processus).l_base_pile_processus;
+						if (pthread_mutex_unlock(
+								&((*(*((struct_processus_fils *)
+								(*(*l_element_courant).donnee).objet))
+								.thread).mutex)) != 0)
+						{
+							(*s_etat_processus).erreur_systeme =
+									d_es_processus;
+						}
 
-						while(l_element_courant != NULL)
+						while((longueur_ecriture =
+								write_atomic(s_etat_processus,
+								(*(*((struct_processus_fils *)
+								(*(*l_element_courant).donnee).objet))
+								.thread).pipe_acquittement[1], "-",
+								sizeof(unsigned char))) !=
+								sizeof(unsigned char))
 						{
-							if ((*(*((struct_processus_fils *)
-									(*(*l_element_courant).donnee).objet))
-									.thread).processus_detache == d_vrai)
+							if (longueur_ecriture == -1)
 							{
-								l_element_courant = (*l_element_courant)
-										.suivant;
-								continue;
+								(*s_etat_processus)
+										.erreur_systeme_processus_fils =
+										d_es_processus;
 							}
+						}
 
-							if (pthread_equal((*(*((struct_processus_fils *)
-									(*(*l_element_courant).donnee).objet))
-									.thread).tid, tid_candidat) != 0)
+						if ((*s_etat_processus).debug == d_vrai)
+							if (((*s_etat_processus).type_debug &
+									d_debug_processus) != 0)
+						{
+							if ((*s_etat_processus).langue == 'F')
 							{
-								if ((*s_etat_processus).debug == d_vrai)
-									if (((*s_etat_processus).type_debug &
-											d_debug_processus) != 0)
-								{
-									if ((*s_etat_processus).langue == 'F')
-									{
-										printf("[%d] Interrution logicielle "
-												"en provenance du thread "
-												"%llu\n", (int) getpid(),
-												(unsigned long long)
-												(*s_argument_thread).tid);
-										fflush(stdout);
-									}
-									else
-									{
-										printf("[%d] Software interrupt "
-												"from thread %llu\n",
-												(int) getpid(),
-												(unsigned long long)
-												(*s_argument_thread).tid);
-										fflush(stdout);
-									}
-								}
-
-								if (pthread_mutex_lock(
-										&((*(*((struct_processus_fils *)
-										(*(*l_element_courant).donnee).objet))
-										.thread).mutex)) != 0)
+								if (caractere == 1)
 								{
-									(*s_etat_processus).erreur_systeme =
-											d_es_processus;
+									printf("[%d] Données acquittées "
+											"en provenance du "
+											"thread %llu\n", (int) getpid(),
+											(unsigned long long)
+											(*s_argument_thread).tid);
 								}
-
-								(*(*((struct_processus_fils *)
-										(*(*l_element_courant).donnee)
-										.objet)).thread)
-										.nombre_interruptions_dans_pipe++;
-
-								if (pthread_mutex_unlock(
-										&((*(*((struct_processus_fils *)
-										(*(*l_element_courant).donnee).objet))
-										.thread).mutex)) != 0)
+								else
 								{
-									(*s_etat_processus).erreur_systeme =
-											d_es_processus;
+									printf("[%d] Interruption logicielle "
+											"acquittée en provenance "
+											"du thread %llu\n", (int) getpid(),
+											(unsigned long long)
+											(*s_argument_thread).tid);
 								}
 
-								(*s_etat_processus)
-										.nombre_interruptions_non_affectees++;
-
-								while((longueur_ecriture =
-										write_atomic(s_etat_processus,
-										(*(*((struct_processus_fils *)
-										(*(*l_element_courant).donnee).objet))
-										.thread).pipe_acquittement[1], "-",
-										sizeof(unsigned char))) !=
-										sizeof(unsigned char))
+								fflush(stdout);
+							}
+							else
+							{
+								if (caractere == 1)
 								{
-									if (longueur_ecriture == -1)
-									{
-										(*s_etat_processus)
-												.erreur_systeme_processus_fils =
-												d_es_processus;
-									}
+									printf("[%d] Data acknowklegment "
+											"from thread %d\n", (int) getpid(),
+											(unsigned long long)
+											(*s_argument_thread).tid);
 								}
-
-								if ((*s_etat_processus).debug == d_vrai)
-									if (((*s_etat_processus).type_debug &
-											d_traitement_interruption) != 0)
+								else
 								{
-									if ((*s_etat_processus).langue == 'F')
-									{
-										printf("[%d] Interruption logicielle "
-												"acquittée en provenance "
-												"du thread %llu\n",
-												(int) getpid(),
-												(unsigned long long)
-												(*s_argument_thread).tid);
-										fflush(stdout);
-									}
-									else
-									{
-										printf("[%d] Software interrupt "
-												"acknowklegment from "
-												"thread %llu\n",
-												(int) getpid(),
-												(unsigned long long)
-												(*s_argument_thread).tid);
-										fflush(stdout);
-									}
+									printf("[%d] Software interrupt "
+											"acknowklegment from "
+											"thread %d\n", (int) getpid(),
+											(unsigned long long)
+											(*s_argument_thread).tid);
 								}
 
-								break;
+								fflush(stdout);
 							}
-
-							l_element_courant = (*l_element_courant).suivant;
-						}
-
-						BUG(l_element_courant == NULL,
-								printf("Process or thread not found"));
-
-						if (pthread_mutex_unlock(&((*s_etat_processus).mutex))
-								!= 0)
-						{
-							(*s_etat_processus).erreur_systeme_processus_fils =
-									d_es_processus;
 						}
 
 						envoi_signal_thread((*s_argument_thread).thread_pere,
 								rpl_siginject);
+						break;
+					}
+
+					case 0:
+					{
+						break;
+					}
+
+					default:
+					{
+						(*s_etat_processus).erreur_systeme_processus_fils =
+								d_es_processus;
+						BUG(1, printf("Spurious interprocess data"));
 					}
 				}
-				else
+
+				if (pthread_mutex_unlock(&((*s_etat_processus).mutex))
+						!= 0)
 				{
 					(*s_etat_processus).erreur_systeme_processus_fils =
 							d_es_processus;
 				}
 			}
+			else
+			{
+				(*s_etat_processus).erreur_systeme = d_es_processus;
+			}
 
 			if (pthread_mutex_lock(&((*s_argument_thread).mutex)) != 0)
 			{
@@ -1010,380 +702,216 @@ surveillance_processus(void *argument)
 		l_element_courant = (struct_liste_chainee *)
 				(*s_etat_processus).l_base_pile_processus;
 
-		if (drapeau_objets_traites == d_faux)
+		if (drapeau_elements_traites == d_faux)
 		{
-			if ((*s_argument_thread).processus_detache == d_vrai)
+			while(l_element_courant != NULL)
 			{
-				while(l_element_courant != NULL)
+				if ((*(*((struct_processus_fils *) (*(*l_element_courant)
+						.donnee).objet)).thread).processus_detache
+						== d_vrai)
 				{
 					if ((*(*((struct_processus_fils *) (*(*l_element_courant)
-							.donnee).objet)).thread).processus_detache
-							== d_faux)
-					{
-						l_element_courant = (*l_element_courant).suivant;
-						continue;
-					}
-
-					if ((*(*((struct_processus_fils *) (*(*l_element_courant)
 							.donnee).objet)).thread).pid ==
 							(*s_argument_thread).pid)
 					{
 						while(read_atomic(s_etat_processus, (*s_argument_thread)
-								.pipe_nombre_objets_attente[0],
-								&pid_candidat, sizeof(pid_candidat)) ==
-								sizeof(pid_candidat))
+								.pipe_nombre_elements_attente[0],
+								&caractere, sizeof(caractere)) ==
+								sizeof(caractere))
 						{
-							/*
-							 * -1 est renvoyé par l'instruction SWI
-							 */
-
-							if (pid_candidat == -2)
-							{
-								break;
-							}
-							else if (pid_candidat == -1)
+							if (caractere == 0)
 							{
+								continue;
 							}
-							else if (read_atomic(s_etat_processus,
-									(*s_argument_thread)
-									.pipe_nombre_objets_attente[0],
-									&pid_candidat, sizeof(pid_candidat)) ==
-									sizeof(pid_candidat))
+
+							if ((*s_etat_processus).debug == d_vrai)
+								if (((*s_etat_processus).type_debug &
+										d_debug_processus) != 0)
 							{
-								if ((*s_etat_processus).debug == d_vrai)
-									if (((*s_etat_processus).type_debug &
-											d_debug_processus) != 0)
+								if ((*s_etat_processus).langue == 'F')
 								{
-									if ((*s_etat_processus).langue == 'F')
+									if (caractere == 1)
 									{
 										printf("[%d] Données en provenance du "
 												"processus %d (processus "
 												"arrêté)\n", (int) getpid(),
 												(int) (*s_argument_thread).pid);
-										fflush(stdout);
 									}
 									else
 									{
+										printf("[%d] Interruption en "
+												"provenance du "
+												"processus %d (processus "
+												"arrêté)\n", (int) getpid(),
+												(int) (*s_argument_thread).pid);
+									}
+
+									fflush(stdout);
+								}
+								else
+								{
+									if (caractere == 1)
+									{
 										printf("[%d] Data from process %d "
 												"(processus stopped)\n",
 												(int) getpid(),
 												(int) (*s_argument_thread).pid);
-										fflush(stdout);
 									}
-								}
+									else
+									{
+										printf("[%d] Interrupt from process %d "
+												"(processus stopped)\n",
+												(int) getpid(),
+												(int) (*s_argument_thread).pid);
+									}
 
-								if (pthread_mutex_lock(
-										&((*(*((struct_processus_fils *)
-										(*(*l_element_courant).donnee).objet))
-										.thread).mutex)) != 0)
-								{
-									(*s_etat_processus).erreur_systeme =
-											d_es_processus;
+									fflush(stdout);
 								}
+							}
 
+							if (pthread_mutex_lock(
+									&((*(*((struct_processus_fils *)
+									(*(*l_element_courant).donnee).objet))
+									.thread).mutex)) != 0)
+							{
+								(*s_etat_processus).erreur_systeme =
+										d_es_processus;
+							}
+
+							if (caractere == 1)
+							{
 								(*(*((struct_processus_fils *)
 										(*(*l_element_courant).donnee).objet))
 										.thread).nombre_objets_dans_pipe++;
-
-								if (pthread_mutex_unlock(
-										&((*(*((struct_processus_fils *)
+							}
+							else
+							{
+								(*(*((struct_processus_fils *)
 										(*(*l_element_courant).donnee).objet))
-										.thread).mutex)) != 0)
-								{
-									(*s_etat_processus).erreur_systeme =
-											d_es_processus;
-								}
+										.thread)
+										.nombre_interruptions_dans_pipe++;
+								(*s_etat_processus)
+										.nombre_interruptions_non_affectees++;
+							}
+
+							if (pthread_mutex_unlock(
+									&((*(*((struct_processus_fils *)
+									(*(*l_element_courant).donnee).objet))
+									.thread).mutex)) != 0)
+							{
+								(*s_etat_processus).erreur_systeme =
+										d_es_processus;
 							}
 						}
 
 						break;
 					}
-
-					l_element_courant = (*l_element_courant).suivant;
 				}
-			}
-			else
-			{
-				while(l_element_courant != NULL)
+				else
 				{
 					if ((*(*((struct_processus_fils *) (*(*l_element_courant)
-							.donnee).objet)).thread).processus_detache
-							== d_vrai)
-					{
-						l_element_courant = (*l_element_courant).suivant;
-						continue;
-					}
-
-					if (pthread_equal((*(*((struct_processus_fils *)
-							(*(*l_element_courant).donnee).objet)).thread).tid,
-							(*s_argument_thread).tid) != 0)
+							.donnee).objet)).thread).tid ==
+							(*s_argument_thread).tid)
 					{
 						while(read_atomic(s_etat_processus, (*s_argument_thread)
-								.pipe_nombre_objets_attente[0],
-								&tid_candidat, sizeof(tid_candidat)) ==
-								sizeof(tid_candidat))
+								.pipe_nombre_elements_attente[0],
+								&caractere, sizeof(caractere)) ==
+								sizeof(caractere))
 						{
-							/*
-							 * -1 est renvoyé par l'instruction SWI
-							 */
-
-							if (tid_candidat == (pthread_t) -2)
-							{
-								break;
-							}
-							else if (tid_candidat == (pthread_t) -1)
+							if (caractere == 0)
 							{
+								continue;
 							}
-							else if (read_atomic(s_etat_processus,
-									(*s_argument_thread)
-									.pipe_nombre_objets_attente[0],
-									&tid_candidat, sizeof(tid_candidat)) ==
-									sizeof(tid_candidat))
+
+							if ((*s_etat_processus).debug == d_vrai)
+								if (((*s_etat_processus).type_debug &
+										d_debug_processus) != 0)
 							{
-								if ((*s_etat_processus).debug == d_vrai)
-									if (((*s_etat_processus).type_debug &
-											d_debug_processus) != 0)
+								if ((*s_etat_processus).langue == 'F')
 								{
-									if ((*s_etat_processus).langue == 'F')
+									if (caractere == 1)
 									{
 										printf("[%d] Données en provenance du "
-												"thread %llu (thread "
+												"thread %llu (processus "
 												"arrêté)\n", (int) getpid(),
 												(unsigned long long)
 												(*s_argument_thread).tid);
-										fflush(stdout);
 									}
 									else
 									{
-										printf("[%d] Data from thread %llu "
-												"(thread stopped)\n",
-												(int) getpid(),
+										printf("[%d] Interruption en "
+												"provenance du "
+												"thread %llu (processus "
+												"arrêté)\n", (int) getpid(),
 												(unsigned long long)
 												(*s_argument_thread).tid);
-										fflush(stdout);
 									}
-								}
 
-								if (pthread_mutex_lock(
-										&((*(*((struct_processus_fils *)
-										(*(*l_element_courant).donnee).objet))
-										.thread).mutex)) != 0)
-								{
-									(*s_etat_processus).erreur_systeme =
-											d_es_processus;
+									fflush(stdout);
 								}
-
-								(*(*((struct_processus_fils *)
-										(*(*l_element_courant).donnee).objet))
-										.thread).nombre_objets_dans_pipe++;
-
-								if (pthread_mutex_unlock(
-										&((*(*((struct_processus_fils *)
-										(*(*l_element_courant).donnee).objet))
-										.thread).mutex)) != 0)
+								else
 								{
-									(*s_etat_processus).erreur_systeme =
-											d_es_processus;
-								}
-							}
-						}
-
-						break;
-					}
-
-					l_element_courant = (*l_element_courant).suivant;
-				}
-			}
-		}
-
-		l_element_courant = (struct_liste_chainee *)
-				(*s_etat_processus).l_base_pile_processus;
-
-		if (drapeau_interruptions_traitees == d_faux)
-		{
-			if ((*s_argument_thread).processus_detache == d_vrai)
-			{
-				while(l_element_courant != NULL)
-				{
-					if ((*(*((struct_processus_fils *) (*(*l_element_courant)
-							.donnee).objet)).thread).processus_detache
-							== d_faux)
-					{
-						l_element_courant = (*l_element_courant).suivant;
-						continue;
-					}
-
-					if ((*(*((struct_processus_fils *) (*(*l_element_courant)
-							.donnee).objet)).thread).pid ==
-							(*s_argument_thread).pid)
-					{
-						while(read_atomic(s_etat_processus, (*s_argument_thread)
-								.pipe_nombre_interruptions_attente[0],
-								&pid_candidat, sizeof(pid_candidat)) ==
-								sizeof(pid_candidat))
-						{
-							if (pid_candidat == -2)
-							{
-								break;
-							}
-							else if (pid_candidat == -1)
-							{
-							}
-							else if (read_atomic(s_etat_processus,
-									(*s_argument_thread)
-									.pipe_nombre_interruptions_attente[0],
-									&pid_candidat, sizeof(pid_candidat)) ==
-									sizeof(pid_candidat))
-							{
-								if ((*s_etat_processus).debug == d_vrai)
-									if (((*s_etat_processus).type_debug &
-											d_traitement_interruption) != 0)
-								{
-									if ((*s_etat_processus).langue == 'F')
+									if (caractere == 1)
 									{
-										printf("[%d] Interruption logicielle "
-												"en provenance du processus %d"
-												" (processus arrêté)\n",
+										printf("[%d] Data from thread %llu "
+												"(processus stopped)\n",
 												(int) getpid(),
-												(int) (*s_argument_thread).pid);
-										fflush(stdout);
+												(unsigned long long)
+												(*s_argument_thread).pid);
 									}
 									else
 									{
-										printf("[%d] Software interrupt "
-												"from process %d (processus "
-												"stopped)\n", (int) getpid(),
-												(int) (*s_argument_thread).pid);
-										fflush(stdout);
+										printf("[%d] Interrupt from thread "
+												"%llu (processus stopped)\n",
+												(int) getpid(),
+												(unsigned long long)
+												(*s_argument_thread).pid);
 									}
-								}
-
-								if (pthread_mutex_lock(
-										&((*(*((struct_processus_fils *)
-										(*(*l_element_courant).donnee).objet))
-										.thread).mutex)) != 0)
-								{
-									(*s_etat_processus).erreur_systeme =
-											d_es_processus;
-								}
 
-								(*(*((struct_processus_fils *)
-										(*(*l_element_courant).donnee)
-										.objet)).thread)
-										.nombre_interruptions_dans_pipe++;
-
-								if (pthread_mutex_unlock(
-										&((*(*((struct_processus_fils *)
-										(*(*l_element_courant).donnee).objet))
-										.thread).mutex)) != 0)
-								{
-									(*s_etat_processus).erreur_systeme =
-											d_es_processus;
+									fflush(stdout);
 								}
-
-								(*s_etat_processus)
-										.nombre_interruptions_non_affectees++;
 							}
-						}
-
-						break;
-					}
-
-					l_element_courant = (*l_element_courant).suivant;
-				}
-			}
-			else
-			{
-				while(l_element_courant != NULL)
-				{
-					if ((*(*((struct_processus_fils *) (*(*l_element_courant)
-							.donnee).objet)).thread).processus_detache
-							== d_vrai)
-					{
-						l_element_courant = (*l_element_courant).suivant;
-						continue;
-					}
 
-					if (pthread_equal((*(*((struct_processus_fils *)
-							(*(*l_element_courant).donnee).objet)).thread).tid,
-							(*s_argument_thread).tid) != 0)
-					{
-						while(read_atomic(s_etat_processus, (*s_argument_thread)
-								.pipe_nombre_interruptions_attente[0],
-								&tid_candidat, sizeof(tid_candidat)) ==
-								sizeof(tid_candidat))
-						{
-							if (tid_candidat == (pthread_t) -2)
+							if (pthread_mutex_lock(
+									&((*(*((struct_processus_fils *)
+									(*(*l_element_courant).donnee).objet))
+									.thread).mutex)) != 0)
 							{
-								break;
+								(*s_etat_processus).erreur_systeme =
+										d_es_processus;
 							}
-							else if (tid_candidat == (pthread_t) -1)
+
+							if (caractere == 1)
 							{
+								(*(*((struct_processus_fils *)
+										(*(*l_element_courant).donnee).objet))
+										.thread).nombre_objets_dans_pipe++;
 							}
-							else if (read_atomic(s_etat_processus,
-									(*s_argument_thread)
-									.pipe_nombre_interruptions_attente[0],
-									&tid_candidat, sizeof(tid_candidat)) ==
-									sizeof(tid_candidat))
+							else
 							{
-								if ((*s_etat_processus).debug == d_vrai)
-									if (((*s_etat_processus).type_debug &
-											d_traitement_interruption) != 0)
-								{
-									if ((*s_etat_processus).langue == 'F')
-									{
-										printf("[%d] Interruption logicielle "
-												"en provenance du thread %llu"
-												" (thread arrêté)\n",
-												(int) getpid(),
-												(unsigned long long)
-												(*s_argument_thread).tid);
-										fflush(stdout);
-									}
-									else
-									{
-										printf("[%d] Software interrupt "
-												"from thread %llu (thread "
-												"stopped)\n", (int) getpid(),
-												(unsigned long long)
-												(*s_argument_thread).tid);
-										fflush(stdout);
-									}
-								}
-
-								if (pthread_mutex_lock(
-										&((*(*((struct_processus_fils *)
-										(*(*l_element_courant).donnee).objet))
-										.thread).mutex)) != 0)
-								{
-									(*s_etat_processus).erreur_systeme =
-											d_es_processus;
-								}
-
 								(*(*((struct_processus_fils *)
-										(*(*l_element_courant).donnee)
-										.objet)).thread)
-										.nombre_interruptions_dans_pipe++;
-
-								if (pthread_mutex_unlock(
-										&((*(*((struct_processus_fils *)
 										(*(*l_element_courant).donnee).objet))
-										.thread).mutex)) != 0)
-								{
-									(*s_etat_processus).erreur_systeme =
-											d_es_processus;
-								}
-
+										.thread)
+										.nombre_interruptions_dans_pipe++;
 								(*s_etat_processus)
 										.nombre_interruptions_non_affectees++;
 							}
+
+							if (pthread_mutex_unlock(
+									&((*(*((struct_processus_fils *)
+									(*(*l_element_courant).donnee).objet))
+									.thread).mutex)) != 0)
+							{
+								(*s_etat_processus).erreur_systeme =
+										d_es_processus;
+							}
 						}
 
 						break;
 					}
-
-					l_element_courant = (*l_element_courant).suivant;
 				}
+
+				l_element_courant = (*l_element_courant).suivant;
 			}
 		}
 
@@ -1675,7 +1203,7 @@ surveillance_processus(void *argument)
 				}
 
 				if (close((*s_argument_thread)
-						.pipe_nombre_objets_attente[0]) != 0)
+						.pipe_nombre_elements_attente[0]) != 0)
 				{
 					(*s_etat_processus).erreur_systeme_processus_fils =
 							d_es_processus;
@@ -1686,13 +1214,6 @@ surveillance_processus(void *argument)
 				{
 					(*s_etat_processus).erreur_systeme_processus_fils =
 							d_es_processus;
-				}
-
-				if (close((*s_argument_thread)
-						.pipe_nombre_interruptions_attente[0]) != 0)
-				{
-					(*s_etat_processus).erreur_systeme_processus_fils =
-							d_es_processus;
 				}
 
 				drapeau_fin = d_vrai;