--- rpl/src/gestion_processus.c	2012/01/17 14:44:06	1.51
+++ rpl/src/gestion_processus.c	2015/01/05 15:32:15	1.77
@@ -1,7 +1,7 @@
 /*
 ================================================================================
-  RPL/2 (R) version 4.1.6
-  Copyright (C) 1989-2012 Dr. BERTRAND Joël
+  RPL/2 (R) version 4.1.20
+  Copyright (C) 1989-2015 Dr. BERTRAND Joël
 
   This file is part of RPL/2.
 
@@ -40,7 +40,6 @@
 void *
 surveillance_processus(void *argument)
 {
-	int								iostat;
 	int								status;
 
 	integer8						nombre_donnees;
@@ -48,15 +47,12 @@ 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;
 
 	struct_descripteur_thread		*s_argument_thread;
@@ -70,13 +66,18 @@ surveillance_processus(void *argument)
 
 	unsigned char					caractere;
 
-	unsigned int					tampon_erreur_execution;
-	unsigned int					tampon_erreur_systeme;
+	int								tampon_erreur_execution;
+	int								tampon_erreur_systeme;
+
+	sigset_t						set;
+
+	sigfillset(&set);
+	pthread_sigmask(SIG_BLOCK, &set, NULL);
 
 	s_argument_thread = argument;
 	s_etat_processus = (*s_argument_thread).s_etat_processus;
 
-	if (pthread_mutex_lock(&((*s_etat_processus).mutex)) != 0)
+	if (pthread_mutex_lock(&((*s_etat_processus).mutex_pile_processus)) != 0)
 	{
 		(*s_etat_processus).erreur_systeme = d_es_processus;
 		BUG(1, uprintf("General mutex error!\n"));
@@ -84,7 +85,7 @@ surveillance_processus(void *argument)
 
 	insertion_thread_surveillance(s_etat_processus, s_argument_thread);
 
-	if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
+	if (pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus)) != 0)
 	{
 		(*s_etat_processus).erreur_systeme = d_es_processus;
 		BUG(1, uprintf("General mutex error!\n"));
@@ -95,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 &
@@ -141,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);
@@ -161,373 +160,238 @@ 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_pile_processus)) != 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 (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++;
 
-			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
+							if (pthread_mutex_lock(&((*s_etat_processus)
+									.mutex_interruptions)) != 0)
+							{
+								(*s_etat_processus).erreur_systeme =
+								 		d_es_processus;
+							}
 
-				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.
+							(*s_etat_processus)
+									.nombre_interruptions_non_affectees++;
 
-				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 (pthread_mutex_unlock(&((*s_etat_processus)
+									.mutex_interruptions)) != 0)
+							{
+								(*s_etat_processus).erreur_systeme =
+										d_es_processus;
+							}
+						}
 
-					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 ((*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);
-									}
-								}
-
-								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 "
+											"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)
+								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);
 								}
 
-								(*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_pile_processus)) != 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)
 			{
@@ -551,364 +415,216 @@ 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_pile_processus)) != 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
+						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++;
 
-				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 (pthread_mutex_lock(&((*s_etat_processus)
+									.mutex_interruptions)) != 0)
+							{
+								(*s_etat_processus).erreur_systeme =
+										d_es_processus;
+							}
 
-				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"));
-					}
+							(*s_etat_processus)
+									.nombre_interruptions_non_affectees++;
 
-					// Une interruption supplémentaire est dans le pipe
-					// correspondant au processus surveillé par ce thread.
+							if (pthread_mutex_unlock(&((*s_etat_processus)
+									.mutex_interruptions)) != 0)
+							{
+								(*s_etat_processus).erreur_systeme =
+										d_es_processus;
+							}
+						}
 
-					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)
+						if (pthread_mutex_unlock(&((*s_etat_processus)
+								.mutex_pile_processus)) != 0)
 						{
 							(*s_etat_processus).erreur_systeme_processus_fils =
 									d_es_processus;
@@ -916,14 +632,41 @@ surveillance_processus(void *argument)
 
 						envoi_signal_thread((*s_argument_thread).thread_pere,
 								rpl_siginject);
+
+						if (pthread_mutex_lock(&((*s_etat_processus)
+								.mutex_pile_processus)) != 0)
+						{
+							(*s_etat_processus).erreur_systeme_processus_fils =
+									d_es_processus;
+						}
+
+						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_pile_processus)) != 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)
 			{
@@ -957,7 +700,7 @@ surveillance_processus(void *argument)
 	 * reste plus rien dans les tuyaux...
 	 */
 
-	if (pthread_mutex_lock(&((*s_etat_processus).mutex)) != 0)
+	if (pthread_mutex_lock(&((*s_etat_processus).mutex_pile_processus)) != 0)
 	{
 		(*s_etat_processus).erreur_systeme_processus_fils =
 				d_es_processus;
@@ -1005,384 +748,251 @@ 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);
+									}
+
+									fflush(stdout);
 								}
+							}
 
-								if (pthread_mutex_lock(
-										&((*(*((struct_processus_fils *)
+							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).mutex)) != 0)
+										.thread).nombre_objets_dans_pipe++;
+							}
+							else
+							{
+								(*(*((struct_processus_fils *)
+										(*(*l_element_courant).donnee).objet))
+										.thread)
+										.nombre_interruptions_dans_pipe++;
+
+								if (pthread_mutex_lock(&((*s_etat_processus)
+										.mutex_interruptions)) != 0)
 								{
 									(*s_etat_processus).erreur_systeme =
 											d_es_processus;
 								}
 
-								(*(*((struct_processus_fils *)
-										(*(*l_element_courant).donnee).objet))
-										.thread).nombre_objets_dans_pipe++;
+								(*s_etat_processus)
+										.nombre_interruptions_non_affectees++;
 
-								if (pthread_mutex_unlock(
-										&((*(*((struct_processus_fils *)
-										(*(*l_element_courant).donnee).objet))
-										.thread).mutex)) != 0)
+								if (pthread_mutex_unlock(&((*s_etat_processus)
+										.mutex_interruptions)) != 0)
 								{
 									(*s_etat_processus).erreur_systeme =
 											d_es_processus;
 								}
 							}
+
+							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;
-								}
-
-								(*(*((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)
-								{
-									(*s_etat_processus).erreur_systeme =
-											d_es_processus;
+									fflush(stdout);
 								}
-							}
-						}
-
-						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)
+								else
 								{
-									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 *)
+								(*(*((struct_processus_fils *)
 										(*(*l_element_courant).donnee).objet))
-										.thread).mutex)) != 0)
+										.thread)
+										.nombre_interruptions_dans_pipe++;
+
+								if (pthread_mutex_lock(&((*s_etat_processus)
+										.mutex_interruptions)) != 0)
 								{
 									(*s_etat_processus).erreur_systeme =
 											d_es_processus;
 								}
 
-								(*(*((struct_processus_fils *)
-										(*(*l_element_courant).donnee)
-										.objet)).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)
+								if (pthread_mutex_unlock(&((*s_etat_processus)
+										.mutex_interruptions)) != 0)
 								{
 									(*s_etat_processus).erreur_systeme =
 											d_es_processus;
 								}
+							}
 
-								(*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;
 			}
 		}
 
-		if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
+		if (pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus))
+				!= 0)
 		{
 			(*s_etat_processus).erreur_systeme_processus_fils =
 					d_es_processus;
@@ -1476,7 +1086,7 @@ surveillance_processus(void *argument)
 		(*s_etat_processus).erreur_systeme_processus_fils = d_es_processus;
 	}
 
-	if (pthread_mutex_lock(&((*s_etat_processus).mutex)) != 0)
+	if (pthread_mutex_lock(&((*s_etat_processus).mutex_pile_processus)) != 0)
 	{
 		(*s_etat_processus).erreur_systeme_processus_fils = d_es_processus;
 	}
@@ -1670,7 +1280,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;
@@ -1683,18 +1293,12 @@ surveillance_processus(void *argument)
 							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;
 			}
 			else
 			{
-				if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
+				if (pthread_mutex_unlock(&((*s_etat_processus)
+						.mutex_pile_processus)) != 0)
 				{
 					(*s_etat_processus).erreur_systeme_processus_fils =
 							d_es_processus;
@@ -1704,7 +1308,8 @@ surveillance_processus(void *argument)
 				nanosleep(&attente, NULL);
 				INCR_GRANULARITE(attente.tv_nsec);
 
-				if (pthread_mutex_lock(&((*s_etat_processus).mutex)) != 0)
+				if (pthread_mutex_lock(&((*s_etat_processus)
+						.mutex_pile_processus)) != 0)
 				{
 					(*s_etat_processus).erreur_systeme_processus_fils =
 							d_es_processus;
@@ -1823,7 +1428,8 @@ surveillance_processus(void *argument)
 
 		retrait_thread_surveillance(s_etat_processus, s_argument_thread);
 
-		if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
+		if (pthread_mutex_unlock(&((*s_etat_processus)
+				.mutex_pile_processus)) != 0)
 		{
 			(*s_etat_processus).erreur_systeme_processus_fils = d_es_processus;
 		}
@@ -1855,8 +1461,8 @@ ecriture_pipe(struct_processus *s_etat_p
 
 	struct timespec					attente;
 
-	unsigned long					i;
-	unsigned long					j;
+	integer8						i;
+	integer8						j;
 
 	size_t							longueur;
 	ssize_t							longueur_ecriture;
@@ -1986,7 +1592,7 @@ ecriture_pipe(struct_processus *s_etat_p
 
 		while((longueur_ecriture = write_atomic(s_etat_processus, pipe,
 				&((*((struct_vecteur *) (*s_objet).objet))
-				.taille), sizeof(unsigned long))) != sizeof(unsigned long))
+				.taille), sizeof(integer8))) != sizeof(integer8))
 		{
 			if (longueur_ecriture == -1)
 			{
@@ -2039,7 +1645,7 @@ ecriture_pipe(struct_processus *s_etat_p
 
 		while((longueur_ecriture = write_atomic(s_etat_processus, pipe,
 				&((*((struct_vecteur *) (*s_objet).objet))
-				.taille), sizeof(unsigned long))) != sizeof(unsigned long))
+				.taille), sizeof(integer8))) != sizeof(integer8))
 		{
 			if (longueur_ecriture == -1)
 			{
@@ -2092,7 +1698,7 @@ ecriture_pipe(struct_processus *s_etat_p
 
 		while((longueur_ecriture = write_atomic(s_etat_processus, pipe,
 				&((*((struct_vecteur *) (*s_objet).objet))
-				.taille), sizeof(unsigned long))) != sizeof(unsigned long))
+				.taille), sizeof(integer8))) != sizeof(integer8))
 		{
 			if (longueur_ecriture == -1)
 			{
@@ -2145,7 +1751,7 @@ ecriture_pipe(struct_processus *s_etat_p
 
 		while((longueur_ecriture = write_atomic(s_etat_processus, pipe,
 				&((*((struct_matrice *) (*s_objet).objet)).nombre_lignes),
-				sizeof(unsigned long))) != sizeof(unsigned long))
+				sizeof(integer8))) != sizeof(integer8))
 		{
 			if (longueur_ecriture == -1)
 			{
@@ -2161,7 +1767,7 @@ ecriture_pipe(struct_processus *s_etat_p
 
 		while((longueur_ecriture = write_atomic(s_etat_processus, pipe,
 				&((*((struct_matrice *) (*s_objet).objet)).nombre_colonnes),
-				sizeof(unsigned long))) != sizeof(unsigned long))
+				sizeof(integer8))) != sizeof(integer8))
 		{
 			if (longueur_ecriture == -1)
 			{
@@ -2220,7 +1826,7 @@ ecriture_pipe(struct_processus *s_etat_p
 
 		while((longueur_ecriture = write_atomic(s_etat_processus, pipe,
 				&((*((struct_matrice *) (*s_objet).objet)).nombre_lignes),
-				sizeof(unsigned long))) != sizeof(unsigned long))
+				sizeof(integer8))) != sizeof(integer8))
 		{
 			if (longueur_ecriture == -1)
 			{
@@ -2236,7 +1842,7 @@ ecriture_pipe(struct_processus *s_etat_p
 
 		while((longueur_ecriture = write_atomic(s_etat_processus, pipe,
 				&((*((struct_matrice *) (*s_objet).objet)).nombre_colonnes),
-				sizeof(unsigned long))) != sizeof(unsigned long))
+				sizeof(integer8))) != sizeof(integer8))
 		{
 			if (longueur_ecriture == -1)
 			{
@@ -2295,7 +1901,7 @@ ecriture_pipe(struct_processus *s_etat_p
 
 		while((longueur_ecriture = write_atomic(s_etat_processus, pipe,
 				&((*((struct_matrice *) (*s_objet).objet)).nombre_lignes),
-				sizeof(unsigned long))) != sizeof(unsigned long))
+				sizeof(integer8))) != sizeof(integer8))
 		{
 			if (longueur_ecriture == -1)
 			{
@@ -2311,7 +1917,7 @@ ecriture_pipe(struct_processus *s_etat_p
 
 		while((longueur_ecriture = write_atomic(s_etat_processus, pipe,
 				&((*((struct_matrice *) (*s_objet).objet)).nombre_colonnes),
-				sizeof(unsigned long))) != sizeof(unsigned long))
+				sizeof(integer8))) != sizeof(integer8))
 		{
 			if (longueur_ecriture == -1)
 			{
@@ -2505,7 +2111,7 @@ ecriture_pipe(struct_processus *s_etat_p
 
 		while((longueur_ecriture = write_atomic(s_etat_processus, pipe,
 				&((*((struct_fonction *) (*s_objet).objet)).nombre_arguments),
-				sizeof(unsigned long))) != sizeof(unsigned long))
+				sizeof(integer8))) != sizeof(integer8))
 		{
 			if (longueur_ecriture == -1)
 			{
@@ -2647,7 +2253,7 @@ ecriture_pipe(struct_processus *s_etat_p
 
 		while((longueur_ecriture = write_atomic(s_etat_processus, pipe,
 				&((*((struct_tableau *) (*s_objet).objet)).nombre_elements),
-				sizeof(unsigned long))) != sizeof(unsigned long))
+				sizeof(integer8))) != sizeof(integer8))
 		{
 			if (longueur_ecriture == -1)
 			{
@@ -2703,8 +2309,8 @@ lecture_pipe(struct_processus *s_etat_pr
 
 	struct timespec			attente;
 
-	unsigned long			i;
-	unsigned long			j;
+	integer8				i;
+	integer8				j;
 
 	if ((s_objet = allocation(s_etat_processus, NON)) == NULL)
 	{
@@ -2791,15 +2397,15 @@ lecture_pipe(struct_processus *s_etat_pr
 
 		while(read_atomic(s_etat_processus, pipe, &((*((struct_vecteur *)
 				(*s_objet).objet)).taille),
-				sizeof(unsigned long)) != sizeof(unsigned long))
+				sizeof(integer8)) != sizeof(integer8))
 		{
 			nanosleep(&attente, NULL);
 			INCR_GRANULARITE(attente.tv_nsec);
 		}
 
 		if (((*((struct_vecteur *) (*s_objet).objet)).tableau =
-				malloc((*((struct_vecteur *) (*s_objet).objet)).taille *
-				sizeof(integer8))) == NULL)
+				malloc(((size_t) (*((struct_vecteur *) (*s_objet).objet))
+				.taille) * sizeof(integer8))) == NULL)
 		{
 			(*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
 			return(NULL);
@@ -2835,15 +2441,15 @@ lecture_pipe(struct_processus *s_etat_pr
 
 		while(read_atomic(s_etat_processus, pipe, &((*((struct_vecteur *)
 				(*s_objet).objet)).taille),
-				sizeof(unsigned long)) != sizeof(unsigned long))
+				sizeof(integer8)) != sizeof(integer8))
 		{
 			nanosleep(&attente, NULL);
 			INCR_GRANULARITE(attente.tv_nsec);
 		}
 
 		if (((*((struct_vecteur *) (*s_objet).objet)).tableau =
-				malloc((*((struct_vecteur *) (*s_objet).objet)).taille *
-				sizeof(real8))) == NULL)
+				malloc(((size_t) (*((struct_vecteur *) (*s_objet).objet))
+				.taille) * sizeof(real8))) == NULL)
 		{
 			(*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
 			return(NULL);
@@ -2879,15 +2485,15 @@ lecture_pipe(struct_processus *s_etat_pr
 
 		while(read_atomic(s_etat_processus, pipe, &((*((struct_vecteur *)
 				(*s_objet).objet)).taille),
-				sizeof(unsigned long)) != sizeof(unsigned long))
+				sizeof(integer8)) != sizeof(integer8))
 		{
 			nanosleep(&attente, NULL);
 			INCR_GRANULARITE(attente.tv_nsec);
 		}
 
 		if (((*((struct_vecteur *) (*s_objet).objet)).tableau =
-				malloc((*((struct_vecteur *) (*s_objet).objet)).taille *
-				sizeof(complex16))) == NULL)
+				malloc(((size_t) (*((struct_vecteur *) (*s_objet).objet))
+				.taille) * sizeof(complex16))) == NULL)
 		{
 			(*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
 			return(NULL);
@@ -2923,7 +2529,7 @@ lecture_pipe(struct_processus *s_etat_pr
 
 		while(read_atomic(s_etat_processus, pipe, &((*((struct_matrice *)
 				(*s_objet).objet)).nombre_lignes),
-				sizeof(unsigned long)) != sizeof(unsigned long))
+				sizeof(integer8)) != sizeof(integer8))
 		{
 			nanosleep(&attente, NULL);
 			INCR_GRANULARITE(attente.tv_nsec);
@@ -2934,15 +2540,15 @@ lecture_pipe(struct_processus *s_etat_pr
 
 		while(read_atomic(s_etat_processus, pipe, &((*((struct_matrice *)
 				(*s_objet).objet)).nombre_colonnes),
-				sizeof(unsigned long)) != sizeof(unsigned long))
+				sizeof(integer8)) != sizeof(integer8))
 		{
 			nanosleep(&attente, NULL);
 			INCR_GRANULARITE(attente.tv_nsec);
 		}
 
 		if (((*((struct_matrice *) (*s_objet).objet)).tableau =
-				malloc((*((struct_matrice *) (*s_objet).objet)).nombre_lignes *
-				sizeof(integer8 *))) == NULL)
+				malloc(((size_t) (*((struct_matrice *) (*s_objet).objet))
+				.nombre_lignes) * sizeof(integer8 *))) == NULL)
 		{
 			(*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
 			return(NULL);
@@ -2952,8 +2558,8 @@ lecture_pipe(struct_processus *s_etat_pr
 				(*s_objet).objet)).nombre_lignes; i++)
 		{
 			if ((((*((struct_matrice *) (*s_objet).objet)).tableau)[i] =
-					malloc((*((struct_matrice *) (*s_objet).objet))
-					.nombre_colonnes * sizeof(integer8))) == NULL)
+					malloc(((size_t) (*((struct_matrice *) (*s_objet).objet))
+					.nombre_colonnes) * sizeof(integer8))) == NULL)
 			{
 				(*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
 				return(NULL);
@@ -2991,7 +2597,7 @@ lecture_pipe(struct_processus *s_etat_pr
 
 		while(read_atomic(s_etat_processus, pipe, &((*((struct_matrice *)
 				(*s_objet).objet)).nombre_lignes),
-				sizeof(unsigned long)) != sizeof(unsigned long))
+				sizeof(integer8)) != sizeof(integer8))
 		{
 			nanosleep(&attente, NULL);
 			INCR_GRANULARITE(attente.tv_nsec);
@@ -3002,15 +2608,15 @@ lecture_pipe(struct_processus *s_etat_pr
 
 		while(read_atomic(s_etat_processus, pipe, &((*((struct_matrice *)
 				(*s_objet).objet)).nombre_colonnes),
-				sizeof(unsigned long)) != sizeof(unsigned long))
+				sizeof(integer8)) != sizeof(integer8))
 		{
 			nanosleep(&attente, NULL);
 			INCR_GRANULARITE(attente.tv_nsec);
 		}
 
 		if (((*((struct_matrice *) (*s_objet).objet)).tableau =
-				malloc((*((struct_matrice *) (*s_objet).objet)).nombre_lignes *
-				sizeof(real8 *))) == NULL)
+				malloc(((size_t) (*((struct_matrice *) (*s_objet).objet))
+				.nombre_lignes) * sizeof(real8 *))) == NULL)
 		{
 			(*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
 			return(NULL);
@@ -3020,8 +2626,8 @@ lecture_pipe(struct_processus *s_etat_pr
 				(*s_objet).objet)).nombre_lignes; i++)
 		{
 			if ((((*((struct_matrice *) (*s_objet).objet)).tableau)[i] =
-					malloc((*((struct_matrice *) (*s_objet).objet))
-					.nombre_colonnes * sizeof(real8))) == NULL)
+					malloc(((size_t) (*((struct_matrice *) (*s_objet).objet))
+					.nombre_colonnes) * sizeof(real8))) == NULL)
 			{
 				(*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
 				return(NULL);
@@ -3059,7 +2665,7 @@ lecture_pipe(struct_processus *s_etat_pr
 
 		while(read_atomic(s_etat_processus, pipe, &((*((struct_matrice *)
 				(*s_objet).objet)).nombre_lignes),
-				sizeof(unsigned long)) != sizeof(unsigned long))
+				sizeof(integer8)) != sizeof(integer8))
 		{
 			nanosleep(&attente, NULL);
 			INCR_GRANULARITE(attente.tv_nsec);
@@ -3070,15 +2676,15 @@ lecture_pipe(struct_processus *s_etat_pr
 
 		while(read_atomic(s_etat_processus, pipe, &((*((struct_matrice *)
 				(*s_objet).objet)).nombre_colonnes),
-				sizeof(unsigned long)) != sizeof(unsigned long))
+				sizeof(integer8)) != sizeof(integer8))
 		{
 			nanosleep(&attente, NULL);
 			INCR_GRANULARITE(attente.tv_nsec);
 		}
 
 		if (((*((struct_matrice *) (*s_objet).objet)).tableau =
-				malloc((*((struct_matrice *) (*s_objet).objet)).nombre_lignes *
-				sizeof(complex16 *))) == NULL)
+				malloc(((size_t) (*((struct_matrice *) (*s_objet).objet))
+				.nombre_lignes) * sizeof(complex16 *))) == NULL)
 		{
 			(*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
 			return(NULL);
@@ -3088,8 +2694,8 @@ lecture_pipe(struct_processus *s_etat_pr
 				(*s_objet).objet)).nombre_lignes; i++)
 		{
 			if ((((*((struct_matrice *) (*s_objet).objet)).tableau)[i] =
-					malloc((*((struct_matrice *) (*s_objet).objet))
-					.nombre_colonnes * sizeof(complex16))) == NULL)
+					malloc(((size_t) (*((struct_matrice *) (*s_objet).objet))
+					.nombre_colonnes) * sizeof(complex16))) == NULL)
 			{
 				(*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
 				return(NULL);
@@ -3217,8 +2823,8 @@ lecture_pipe(struct_processus *s_etat_pr
 
 		while(read_atomic(s_etat_processus, pipe,
 				&((*((struct_fonction *) (*s_objet).objet))
-				.nombre_arguments), sizeof(unsigned long)) !=
-				sizeof(unsigned long))
+				.nombre_arguments), sizeof(integer8)) !=
+				sizeof(integer8))
 		{
 			nanosleep(&attente, NULL);
 			INCR_GRANULARITE(attente.tv_nsec);
@@ -3338,15 +2944,15 @@ lecture_pipe(struct_processus *s_etat_pr
 
 		while(read_atomic(s_etat_processus, pipe, &((*((struct_tableau *)
 				(*s_objet).objet)).nombre_elements),
-				sizeof(unsigned long)) != sizeof(unsigned long))
+				sizeof(integer8)) != sizeof(integer8))
 		{
 			nanosleep(&attente, NULL);
 			INCR_GRANULARITE(attente.tv_nsec);
 		}
 
 		if (((*((struct_tableau *) (*s_objet).objet)).elements = malloc(
-				(*((struct_tableau *) (*s_objet).objet)).nombre_elements *
-				sizeof(struct_objet *))) == NULL)
+				((size_t) (*((struct_tableau *) (*s_objet).objet))
+				.nombre_elements) * sizeof(struct_objet *))) == NULL)
 		{
 			(*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
 			return(NULL);