--- rpl/src/instructions_p7.c	2013/02/27 17:11:43	1.53
+++ rpl/src/instructions_p7.c	2019/02/28 12:40:36	1.82
@@ -1,7 +1,7 @@
 /*
 ================================================================================
-  RPL/2 (R) version 4.1.13
-  Copyright (C) 1989-2013 Dr. BERTRAND Joël
+  RPL/2 (R) version 4.1.31
+  Copyright (C) 1989-2019 Dr. BERTRAND Joël
 
   This file is part of RPL/2.
 
@@ -718,7 +718,8 @@ instruction_poke(struct_processus *s_eta
 			return;
 		}
 
-		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;
 			return;
@@ -749,11 +750,30 @@ instruction_poke(struct_processus *s_eta
 					// figure !
 
 					action.sa_handler = SIG_IGN;
-					action.sa_flags = SA_ONSTACK;
+					action.sa_flags = 0;
+
+#					ifndef SEMAPHORES_NOMMES
+						if (sem_post(&((*s_etat_processus).semaphore_fork))
+								!= 0)
+#					else
+						if (sem_post((*s_etat_processus).semaphore_fork) != 0)
+#					endif
+					{
+						(*s_etat_processus).erreur_systeme = d_es_processus;
+						return;
+					}
+
+					if (pthread_mutex_lock(&mutex_sigaction) != 0)
+					{
+						(*s_etat_processus).erreur_systeme = d_es_processus;
+						return;
+					}
 
 					if (sigaction(SIGPIPE, &action, &registre) != 0)
 					{
-						pthread_mutex_unlock(&((*s_etat_processus).mutex));
+						pthread_mutex_unlock(&mutex_sigaction);
+						pthread_mutex_unlock(&((*s_etat_processus)
+								.mutex_pile_processus));
 
 						(*s_etat_processus).erreur_systeme = d_es_signal;
 						return;
@@ -765,7 +785,7 @@ instruction_poke(struct_processus *s_eta
 
 					if (envoi_signal_processus((*(*((struct_processus_fils *)
 							(*(*l_element_courant).donnee).objet))
-							.thread).pid, rpl_siginject) != 0)
+							.thread).pid, rpl_siginject, d_faux) != 0)
 					{
 						// Le processus fils peut s'être terminé.
 						break;
@@ -783,47 +803,24 @@ instruction_poke(struct_processus *s_eta
 
 						if ((*s_etat_processus).erreur_systeme != d_es)
 						{
-							pthread_mutex_unlock(&((*s_etat_processus).mutex));
+							pthread_mutex_unlock(&mutex_sigaction);
+							pthread_mutex_unlock(&((*s_etat_processus)
+									.mutex_pile_processus));
 							return;
 						}
 					}
 
-#					ifndef SEMAPHORES_NOMMES
-						if (sem_post(&((*s_etat_processus).semaphore_fork))
-								!= 0)
-#					else
-						if (sem_post((*s_etat_processus).semaphore_fork) != 0)
-#					endif
-					{
-						(*s_etat_processus).erreur_systeme = d_es_processus;
-						return;
-					}
-
 					while((longueur_ecriture = write_atomic(s_etat_processus,
 							(*(*((struct_processus_fils *)
 							(*(*l_element_courant).donnee).objet)).thread)
 							.pipe_nombre_injections[1], "-",
 							sizeof(unsigned char))) != sizeof(unsigned char))
 					{
-#						ifndef SEMAPHORES_NOMMES
-							while(sem_wait(
-									&((*s_etat_processus).semaphore_fork)) != 0)
-#						else
-							while(sem_wait(
-									(*s_etat_processus).semaphore_fork) != 0)
-#						endif
-						{
-							if (errno != EINTR)
-							{
-								(*s_etat_processus).erreur_systeme =
-										d_es_processus;
-								return;
-							}
-						}
-
 						if (longueur_ecriture == -1)
 						{
-							pthread_mutex_unlock(&((*s_etat_processus).mutex));
+							pthread_mutex_unlock(&mutex_sigaction);
+							pthread_mutex_unlock(&((*s_etat_processus)
+									.mutex_pile_processus));
 
 							liberation(s_etat_processus, s_objet_argument_1);
 							liberation(s_etat_processus, s_objet_argument_2);
@@ -850,6 +847,7 @@ instruction_poke(struct_processus *s_eta
 
 							if (sigaction(SIGPIPE, &registre, NULL) != 0)
 							{
+								pthread_mutex_unlock(&mutex_sigaction);
 								(*s_etat_processus).erreur_systeme =
 										d_es_signal;
 								return;
@@ -857,18 +855,6 @@ instruction_poke(struct_processus *s_eta
 
 							return;
 						}
-
-#						ifndef SEMAPHORES_NOMMES
-							if (sem_post(
-									&((*s_etat_processus).semaphore_fork)) != 0)
-#						else
-							if (sem_post(
-									(*s_etat_processus).semaphore_fork) != 0)
-#						endif
-						{
-							(*s_etat_processus).erreur_systeme = d_es_processus;
-							return;
-						}
 					}
 
 					if (ecriture_pipe(s_etat_processus,
@@ -885,20 +871,6 @@ instruction_poke(struct_processus *s_eta
 						}
 					}
 
-#					ifndef SEMAPHORES_NOMMES
-						while(sem_wait(&((*s_etat_processus).semaphore_fork))
-								!= 0)
-#					else
-						while(sem_wait((*s_etat_processus).semaphore_fork) != 0)
-#					endif
-					{
-						if (errno != EINTR)
-						{
-							(*s_etat_processus).erreur_systeme = d_es_processus;
-							return;
-						}
-					}
-
 					if (registre_stop == 0)
 					{
 						if ((*s_etat_processus)
@@ -919,12 +891,34 @@ instruction_poke(struct_processus *s_eta
 
 					if (sigaction(SIGPIPE, &registre, NULL) != 0)
 					{
-						pthread_mutex_unlock(&((*s_etat_processus).mutex));
+						pthread_mutex_unlock(&mutex_sigaction);
+						pthread_mutex_unlock(&((*s_etat_processus)
+								.mutex_pile_processus));
 
 						(*s_etat_processus).erreur_systeme = d_es_signal;
 						return;
 					}
 
+					if (pthread_mutex_unlock(&mutex_sigaction) != 0)
+					{
+						(*s_etat_processus).erreur_systeme = d_es_processus;
+						return;
+					}
+
+#					ifndef SEMAPHORES_NOMMES
+						while(sem_wait(&((*s_etat_processus).semaphore_fork))
+								!= 0)
+#					else
+						while(sem_wait((*s_etat_processus).semaphore_fork) != 0)
+#					endif
+					{
+						if (errno != EINTR)
+						{
+							(*s_etat_processus).erreur_systeme = d_es_processus;
+							return;
+						}
+					}
+
 					break;
 				}
 			}
@@ -951,12 +945,63 @@ instruction_poke(struct_processus *s_eta
 					// de lecteur et on peut se prendre un SIGPIPE dans la
 					// figure !
 
+#					ifndef SEMAPHORES_NOMMES
+						if (sem_post(&((*s_etat_processus).semaphore_fork))
+								!= 0)
+#					else
+						if (sem_post((*s_etat_processus).semaphore_fork) != 0)
+#					endif
+					{
+						(*s_etat_processus).erreur_systeme = d_es_processus;
+						return;
+					}
+
+					if (pthread_mutex_lock(&mutex_sigaction) != 0)
+					{
+#						ifndef SEMAPHORES_NOMMES
+							while(sem_wait(&((*s_etat_processus)
+									.semaphore_fork)) != 0)
+#						else
+							while(sem_wait((*s_etat_processus)
+									.semaphore_fork) != 0)
+#						endif
+						{
+							if (errno != EINTR)
+							{
+								(*s_etat_processus).erreur_systeme =
+										d_es_processus;
+								return;
+							}
+						}
+
+						(*s_etat_processus).erreur_systeme = d_es_processus;
+						return;
+					}
+
 					action.sa_handler = SIG_IGN;
-					action.sa_flags = SA_ONSTACK;
+					action.sa_flags = 0;
 
 					if (sigaction(SIGPIPE, &action, &registre) != 0)
 					{
-						pthread_mutex_unlock(&((*s_etat_processus).mutex));
+#						ifndef SEMAPHORES_NOMMES
+							while(sem_wait(&((*s_etat_processus)
+									.semaphore_fork)) != 0)
+#						else
+							while(sem_wait((*s_etat_processus)
+									.semaphore_fork) != 0)
+#						endif
+						{
+							if (errno != EINTR)
+							{
+								(*s_etat_processus).erreur_systeme =
+										d_es_processus;
+								return;
+							}
+						}
+
+						pthread_mutex_unlock(&mutex_sigaction);
+						pthread_mutex_unlock(&((*s_etat_processus)
+								.mutex_pile_processus));
 
 						(*s_etat_processus).erreur_systeme = d_es_signal;
 						return;
@@ -970,6 +1015,23 @@ instruction_poke(struct_processus *s_eta
 							(*(*l_element_courant).donnee).objet)).thread)
 							.mutex)) != 0)
 					{
+#						ifndef SEMAPHORES_NOMMES
+							while(sem_wait(&((*s_etat_processus)
+									.semaphore_fork)) != 0)
+#						else
+							while(sem_wait((*s_etat_processus)
+									.semaphore_fork) != 0)
+#						endif
+						{
+							if (errno != EINTR)
+							{
+								(*s_etat_processus).erreur_systeme =
+										d_es_processus;
+								return;
+							}
+						}
+
+						pthread_mutex_unlock(&mutex_sigaction);
 						(*s_etat_processus).erreur_systeme = d_es_processus;
 						return;
 					}
@@ -978,7 +1040,8 @@ instruction_poke(struct_processus *s_eta
 							(*(*l_element_courant).donnee).objet)).thread)
 							.thread_actif == d_vrai)
 					{
-						if (envoi_signal_thread((*(*((struct_processus_fils *)
+						if (envoi_signal_thread(NULL,
+								(*(*((struct_processus_fils *)
 								(*(*l_element_courant).donnee).objet)).thread)
 								.tid, rpl_siginject) != 0)
 						{
@@ -989,6 +1052,23 @@ instruction_poke(struct_processus *s_eta
 									(*(*l_element_courant).donnee).objet))
 									.thread).mutex)) != 0)
 							{
+#								ifndef SEMAPHORES_NOMMES
+									while(sem_wait(&((*s_etat_processus)
+											.semaphore_fork)) != 0)
+#								else
+									while(sem_wait((*s_etat_processus)
+											.semaphore_fork) != 0)
+#								endif
+								{
+									if (errno != EINTR)
+									{
+										(*s_etat_processus).erreur_systeme =
+												d_es_processus;
+										return;
+									}
+								}
+
+								pthread_mutex_unlock(&mutex_sigaction);
 								(*s_etat_processus).erreur_systeme =
 										d_es_processus;
 								return;
@@ -1004,6 +1084,23 @@ instruction_poke(struct_processus *s_eta
 								(*(*l_element_courant).donnee).objet))
 								.thread).mutex)) != 0)
 						{
+#							ifndef SEMAPHORES_NOMMES
+								while(sem_wait(&((*s_etat_processus)
+										.semaphore_fork)) != 0)
+#							else
+								while(sem_wait((*s_etat_processus)
+										.semaphore_fork) != 0)
+#							endif
+							{
+								if (errno != EINTR)
+								{
+									(*s_etat_processus).erreur_systeme =
+											d_es_processus;
+									return;
+								}
+							}
+
+							pthread_mutex_unlock(&mutex_sigaction);
 							(*s_etat_processus).erreur_systeme = d_es_processus;
 							return;
 						}
@@ -1015,6 +1112,23 @@ instruction_poke(struct_processus *s_eta
 							(*(*l_element_courant).donnee).objet)).thread)
 							.mutex)) != 0)
 					{
+#						ifndef SEMAPHORES_NOMMES
+							while(sem_wait(&((*s_etat_processus)
+									.semaphore_fork)) != 0)
+#						else
+							while(sem_wait((*s_etat_processus)
+									.semaphore_fork) != 0)
+#						endif
+						{
+							if (errno != EINTR)
+							{
+								(*s_etat_processus).erreur_systeme =
+										d_es_processus;
+								return;
+							}
+						}
+
+						pthread_mutex_unlock(&mutex_sigaction);
 						(*s_etat_processus).erreur_systeme = d_es_processus;
 						return;
 					}
@@ -1031,48 +1145,39 @@ instruction_poke(struct_processus *s_eta
 
 						if ((*s_etat_processus).erreur_systeme != d_es)
 						{
-							pthread_mutex_unlock(&((*s_etat_processus).mutex));
+#							ifndef SEMAPHORES_NOMMES
+								while(sem_wait(&((*s_etat_processus)
+										.semaphore_fork)) != 0)
+#							else
+								while(sem_wait((*s_etat_processus)
+										.semaphore_fork) != 0)
+#							endif
+							{
+								if (errno != EINTR)
+								{
+									(*s_etat_processus).erreur_systeme =
+											d_es_processus;
+									return;
+								}
+							}
+
+							pthread_mutex_unlock(&mutex_sigaction);
+							pthread_mutex_unlock(&((*s_etat_processus)
+									.mutex_pile_processus));
 							return;
 						}
 					}
 
-#					ifndef SEMAPHORES_NOMMES
-						if (sem_post(
-								&((*s_etat_processus).semaphore_fork)) != 0)
-#					else
-						if (sem_post(
-								(*s_etat_processus).semaphore_fork) != 0)
-#					endif
-					{
-						(*s_etat_processus).erreur_systeme = d_es_processus;
-						return;
-					}
-
 					while((longueur_ecriture = write_atomic(s_etat_processus,
 							(*(*((struct_processus_fils *)
 							(*(*l_element_courant).donnee).objet)).thread)
 							.pipe_nombre_injections[1], "-",
 							sizeof(unsigned char))) != sizeof(unsigned char))
 					{
-#						ifndef SEMAPHORES_NOMMES
-							while(sem_wait(
-									&((*s_etat_processus).semaphore_fork)) != 0)
-#						else
-							while(sem_wait(
-									(*s_etat_processus).semaphore_fork) != 0)
-#						endif
-						{
-							if (errno != EINTR)
-							{
-								(*s_etat_processus).erreur_systeme =
-										d_es_processus;
-								return;
-							}
-						}
-
 						if (longueur_ecriture == -1)
 						{
-							pthread_mutex_unlock(&((*s_etat_processus).mutex));
+							pthread_mutex_unlock(&((*s_etat_processus)
+									.mutex_pile_processus));
 
 							liberation(s_etat_processus, s_objet_argument_1);
 							liberation(s_etat_processus, s_objet_argument_2);
@@ -1099,23 +1204,45 @@ instruction_poke(struct_processus *s_eta
 
 							if (sigaction(SIGPIPE, &registre, NULL) != 0)
 							{
+#								ifndef SEMAPHORES_NOMMES
+									while(sem_wait(&((*s_etat_processus)
+											.semaphore_fork)) != 0)
+#								else
+									while(sem_wait((*s_etat_processus)
+											.semaphore_fork) != 0)
+#								endif
+								{
+									if (errno != EINTR)
+									{
+										(*s_etat_processus).erreur_systeme =
+												d_es_processus;
+										return;
+									}
+								}
+
+								pthread_mutex_unlock(&mutex_sigaction);
 								(*s_etat_processus).erreur_systeme =
 										d_es_signal;
 								return;
 							}
 
-							return;
-						}
+#							ifndef SEMAPHORES_NOMMES
+								while(sem_wait(&((*s_etat_processus)
+										.semaphore_fork)) != 0)
+#							else
+								while(sem_wait((*s_etat_processus)
+										.semaphore_fork) != 0)
+#							endif
+							{
+								if (errno != EINTR)
+								{
+									(*s_etat_processus).erreur_systeme =
+											d_es_processus;
+									return;
+								}
+							}
 
-#						ifndef SEMAPHORES_NOMMES
-							if (sem_post(
-									&((*s_etat_processus).semaphore_fork)) != 0)
-#						else
-							if (sem_post(
-									(*s_etat_processus).semaphore_fork) != 0)
-#						endif
-						{
-							(*s_etat_processus).erreur_systeme = d_es_processus;
+							pthread_mutex_unlock(&mutex_sigaction);
 							return;
 						}
 					}
@@ -1134,21 +1261,6 @@ instruction_poke(struct_processus *s_eta
 						}
 					}
 
-#					ifndef SEMAPHORES_NOMMES
-						while(sem_wait(
-								&((*s_etat_processus).semaphore_fork)) != 0)
-#					else
-						while(sem_wait(
-								(*s_etat_processus).semaphore_fork) != 0)
-#					endif
-					{
-						if (errno != EINTR)
-						{
-							(*s_etat_processus).erreur_systeme = d_es_processus;
-							return;
-						}
-					}
-
 					if (registre_stop == 0)
 					{
 						if ((*s_etat_processus)
@@ -1169,12 +1281,66 @@ instruction_poke(struct_processus *s_eta
 
 					if (sigaction(SIGPIPE, &registre, NULL) != 0)
 					{
-						pthread_mutex_unlock(&((*s_etat_processus).mutex));
+#						ifndef SEMAPHORES_NOMMES
+							while(sem_wait(&((*s_etat_processus)
+									.semaphore_fork)) != 0)
+#						else
+							while(sem_wait((*s_etat_processus)
+									.semaphore_fork) != 0)
+#						endif
+						{
+							if (errno != EINTR)
+							{
+								(*s_etat_processus).erreur_systeme =
+										d_es_processus;
+								return;
+							}
+						}
+
+						pthread_mutex_unlock(&mutex_sigaction);
+						pthread_mutex_unlock(&((*s_etat_processus)
+								.mutex_pile_processus));
 
 						(*s_etat_processus).erreur_systeme = d_es_signal;
 						return;
 					}
 
+					if (pthread_mutex_unlock(&mutex_sigaction) != 0)
+					{
+#						ifndef SEMAPHORES_NOMMES
+							while(sem_wait(&((*s_etat_processus)
+									.semaphore_fork)) != 0)
+#						else
+							while(sem_wait((*s_etat_processus)
+									.semaphore_fork) != 0)
+#						endif
+						{
+							if (errno != EINTR)
+							{
+								(*s_etat_processus).erreur_systeme =
+										d_es_processus;
+								return;
+							}
+						}
+
+						(*s_etat_processus).erreur_systeme = d_es_processus;
+						return;
+					}
+
+#					ifndef SEMAPHORES_NOMMES
+						while(sem_wait(&((*s_etat_processus).semaphore_fork))
+								!= 0)
+#					else
+						while(sem_wait((*s_etat_processus).semaphore_fork) != 0)
+#					endif
+					{
+						if (errno != EINTR)
+						{
+							(*s_etat_processus).erreur_systeme = d_es_processus;
+							return;
+						}
+					}
+
 					break;
 				}
 			}
@@ -1182,7 +1348,8 @@ instruction_poke(struct_processus *s_eta
 			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 = d_es_processus;
 			return;