--- rpl/src/instructions_p7.c	2011/09/14 17:55:59	1.35
+++ rpl/src/instructions_p7.c	2019/02/11 09:45:51	1.80
@@ -1,7 +1,7 @@
 /*
 ================================================================================
-  RPL/2 (R) version 4.1.3
-  Copyright (C) 1989-2011 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,19 @@ instruction_poke(struct_processus *s_eta
 					// figure !
 
 					action.sa_handler = SIG_IGN;
-					action.sa_flags = SA_ONSTACK;
+					action.sa_flags = 0;
+
+					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 +774,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,17 +792,26 @@ 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;
 						}
 					}
 
-					if (pthread_mutex_unlock(&((*s_etat_processus).mutex_fork))
-							!= 0)
+					/*
+#					ifndef SEMAPHORES_NOMMES
+						if (sem_post(&((*s_etat_processus).semaphore_fork))
+								!= 0)
+#					else
+						if (sem_post((*s_etat_processus).semaphore_fork) != 0)
+#					endif
 					{
+						pthread_mutex_unlock(&mutex_sigaction);
 						(*s_etat_processus).erreur_systeme = d_es_processus;
 						return;
 					}
+					*/
 
 					while((longueur_ecriture = write_atomic(s_etat_processus,
 							(*(*((struct_processus_fils *)
@@ -801,16 +819,29 @@ instruction_poke(struct_processus *s_eta
 							.pipe_nombre_injections[1], "-",
 							sizeof(unsigned char))) != sizeof(unsigned char))
 					{
-						if (pthread_mutex_lock(
-								&((*s_etat_processus).mutex_fork)) != 0)
+						/*
+#						ifndef SEMAPHORES_NOMMES
+							while(sem_wait(
+									&((*s_etat_processus).semaphore_fork)) != 0)
+#						else
+							while(sem_wait(
+									(*s_etat_processus).semaphore_fork) != 0)
+#						endif
 						{
-							(*s_etat_processus).erreur_systeme = d_es_processus;
-							return;
+							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);
@@ -837,6 +868,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;
@@ -845,12 +877,19 @@ instruction_poke(struct_processus *s_eta
 							return;
 						}
 
-						if (pthread_mutex_unlock(
-								&((*s_etat_processus).mutex_fork)) != 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 (ecriture_pipe(s_etat_processus,
@@ -867,12 +906,21 @@ instruction_poke(struct_processus *s_eta
 						}
 					}
 
-					if (pthread_mutex_lock(&((*s_etat_processus).mutex_fork))
-							!= 0)
+					/*
+#					ifndef SEMAPHORES_NOMMES
+						while(sem_wait(&((*s_etat_processus).semaphore_fork))
+								!= 0)
+#					else
+						while(sem_wait((*s_etat_processus).semaphore_fork) != 0)
+#					endif
 					{
-						(*s_etat_processus).erreur_systeme = d_es_processus;
-						return;
+						if (errno != EINTR)
+						{
+							(*s_etat_processus).erreur_systeme = d_es_processus;
+							return;
+						}
 					}
+					*/
 
 					if (registre_stop == 0)
 					{
@@ -894,12 +942,20 @@ 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;
+					}
+
 					break;
 				}
 			}
@@ -926,12 +982,20 @@ instruction_poke(struct_processus *s_eta
 					// de lecteur et on peut se prendre un SIGPIPE dans la
 					// figure !
 
+					if (pthread_mutex_lock(&mutex_sigaction) != 0)
+					{
+						(*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));
+						pthread_mutex_unlock(&mutex_sigaction);
+						pthread_mutex_unlock(&((*s_etat_processus)
+								.mutex_pile_processus));
 
 						(*s_etat_processus).erreur_systeme = d_es_signal;
 						return;
@@ -945,6 +1009,7 @@ instruction_poke(struct_processus *s_eta
 							(*(*l_element_courant).donnee).objet)).thread)
 							.mutex)) != 0)
 					{
+						pthread_mutex_unlock(&mutex_sigaction);
 						(*s_etat_processus).erreur_systeme = d_es_processus;
 						return;
 					}
@@ -953,7 +1018,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(s_etat_processus,
+								(*(*((struct_processus_fils *)
 								(*(*l_element_courant).donnee).objet)).thread)
 								.tid, rpl_siginject) != 0)
 						{
@@ -964,6 +1030,7 @@ instruction_poke(struct_processus *s_eta
 									(*(*l_element_courant).donnee).objet))
 									.thread).mutex)) != 0)
 							{
+								pthread_mutex_unlock(&mutex_sigaction);
 								(*s_etat_processus).erreur_systeme =
 										d_es_processus;
 								return;
@@ -979,6 +1046,7 @@ instruction_poke(struct_processus *s_eta
 								(*(*l_element_courant).donnee).objet))
 								.thread).mutex)) != 0)
 						{
+							pthread_mutex_unlock(&mutex_sigaction);
 							(*s_etat_processus).erreur_systeme = d_es_processus;
 							return;
 						}
@@ -990,6 +1058,7 @@ instruction_poke(struct_processus *s_eta
 							(*(*l_element_courant).donnee).objet)).thread)
 							.mutex)) != 0)
 					{
+						pthread_mutex_unlock(&mutex_sigaction);
 						(*s_etat_processus).erreur_systeme = d_es_processus;
 						return;
 					}
@@ -1006,17 +1075,26 @@ 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;
 						}
 					}
 
-					if (pthread_mutex_unlock(
-							&((*s_etat_processus).mutex_fork)) != 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;
 					}
+					*/
 
 					while((longueur_ecriture = write_atomic(s_etat_processus,
 							(*(*((struct_processus_fils *)
@@ -1024,16 +1102,28 @@ instruction_poke(struct_processus *s_eta
 							.pipe_nombre_injections[1], "-",
 							sizeof(unsigned char))) != sizeof(unsigned char))
 					{
-						if (pthread_mutex_lock(
-								&((*s_etat_processus).mutex_fork)) != 0)
+						/*
+#						ifndef SEMAPHORES_NOMMES
+							while(sem_wait(
+									&((*s_etat_processus).semaphore_fork)) != 0)
+#						else
+							while(sem_wait(
+									(*s_etat_processus).semaphore_fork) != 0)
+#						endif
 						{
-							(*s_etat_processus).erreur_systeme = d_es_processus;
-							return;
+							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);
@@ -1060,20 +1150,29 @@ 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;
 							}
 
+							pthread_mutex_unlock(&mutex_sigaction);
 							return;
 						}
 
-						if (pthread_mutex_unlock(
-								&((*s_etat_processus).mutex_fork)) != 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 (ecriture_pipe(s_etat_processus,
@@ -1090,12 +1189,22 @@ instruction_poke(struct_processus *s_eta
 						}
 					}
 
-					if (pthread_mutex_lock(
-							&((*s_etat_processus).mutex_fork)) != 0)
+					/*
+#					ifndef SEMAPHORES_NOMMES
+						while(sem_wait(
+								&((*s_etat_processus).semaphore_fork)) != 0)
+#					else
+						while(sem_wait(
+								(*s_etat_processus).semaphore_fork) != 0)
+#					endif
 					{
-						(*s_etat_processus).erreur_systeme = d_es_processus;
-						return;
+						if (errno != EINTR)
+						{
+							(*s_etat_processus).erreur_systeme = d_es_processus;
+							return;
+						}
 					}
+					*/
 
 					if (registre_stop == 0)
 					{
@@ -1117,12 +1226,20 @@ 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;
+					}
+
 					break;
 				}
 			}
@@ -1130,7 +1247,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;
@@ -1232,26 +1350,12 @@ instruction_private(struct_processus *s_
 			return;
 		}
 
-		if (pthread_mutex_lock(&((*(*s_etat_processus)
-				.s_liste_variables_partagees).mutex)) != 0)
-		{
-			(*s_etat_processus).erreur_systeme = d_es_processus;
-			return;
-		}
-
 		if (recherche_variable_partagee(s_etat_processus, ((*((struct_nom *)
 				(*s_objet).objet)).nom), (*(*s_etat_processus)
 				.pointeur_variable_courante).variable_partagee,
 				(*(*s_etat_processus).pointeur_variable_courante).origine)
-				== d_faux)
+				== NULL)
 		{
-			if (pthread_mutex_unlock(&((*(*s_etat_processus)
-					.s_liste_variables_partagees).mutex)) != 0)
-			{
-				(*s_etat_processus).erreur_systeme = d_es_processus;
-				return;
-			}
-
 			liberation(s_etat_processus, s_objet);
 
 			(*s_etat_processus).erreur_systeme = d_es;
@@ -1259,25 +1363,15 @@ instruction_private(struct_processus *s_
 		}
 
 		(*(*s_etat_processus).pointeur_variable_courante).objet =
-				(*(*s_etat_processus).s_liste_variables_partagees).table
-				[(*(*s_etat_processus).s_liste_variables_partagees)
-				.position_variable].objet;
-		(*(*s_etat_processus).s_liste_variables_partagees).table
-				[(*(*s_etat_processus).s_liste_variables_partagees)
-				.position_variable].objet = NULL;
+				(*(*s_etat_processus).pointeur_variable_partagee_courante)
+				.objet;
+		(*(*s_etat_processus).pointeur_variable_partagee_courante).objet = NULL;
 
 		if (retrait_variable_partagee(s_etat_processus,
 				(*((struct_nom *) (*s_objet).objet)).nom,
 				(*(*s_etat_processus).pointeur_variable_courante)
 				.variable_partagee) == d_erreur)
 		{
-			if (pthread_mutex_unlock(&((*(*s_etat_processus)
-					.s_liste_variables_partagees).mutex)) != 0)
-			{
-				(*s_etat_processus).erreur_systeme = d_es_processus;
-				return;
-			}
-
 			liberation(s_etat_processus, s_objet);
 			return;
 		}
@@ -1292,13 +1386,6 @@ instruction_private(struct_processus *s_
 			(*(*s_etat_processus).pointeur_variable_courante)
 					.variable_partagee.pointeur = NULL;
 		}
-
-		if (pthread_mutex_unlock(&((*(*s_etat_processus)
-				.s_liste_variables_partagees).mutex)) != 0)
-		{
-			(*s_etat_processus).erreur_systeme = d_es_processus;
-			return;
-		}
 	}
 	else if ((*s_objet).type == LST)
 	{
@@ -1325,26 +1412,12 @@ instruction_private(struct_processus *s_
 				return;
 			}
 
-			if (pthread_mutex_lock(&((*(*s_etat_processus)
-					.s_liste_variables_partagees).mutex)) != 0)
-			{
-				(*s_etat_processus).erreur_systeme = d_es_processus;
-				return;
-			}
-
 			if (recherche_variable_partagee(s_etat_processus, ((*((struct_nom *)
 					(*s_objet).objet)).nom), (*(*s_etat_processus)
 					.pointeur_variable_courante).variable_partagee,
 					(*(*s_etat_processus).pointeur_variable_courante).origine)
-					== d_faux)
+					== NULL)
 			{
-				if (pthread_mutex_unlock(&((*(*s_etat_processus)
-						.s_liste_variables_partagees).mutex)) != 0)
-				{
-					(*s_etat_processus).erreur_systeme = d_es_processus;
-					return;
-				}
-
 				liberation(s_etat_processus, s_objet);
 
 				(*s_etat_processus).erreur_systeme = d_es;
@@ -1354,12 +1427,10 @@ instruction_private(struct_processus *s_
 			}
 
 			(*(*s_etat_processus).pointeur_variable_courante).objet =
-					(*(*s_etat_processus).s_liste_variables_partagees).table
-					[(*(*s_etat_processus).s_liste_variables_partagees)
-					.position_variable].objet;
-			(*(*s_etat_processus).s_liste_variables_partagees).table
-					[(*(*s_etat_processus).s_liste_variables_partagees)
-					.position_variable].objet = NULL;
+					(*(*s_etat_processus).pointeur_variable_partagee_courante)
+					.objet;
+			(*(*s_etat_processus).pointeur_variable_partagee_courante).objet
+					= NULL;
 
 			if ((*(*s_etat_processus).pointeur_variable_courante).origine
 					== 'P')
@@ -1378,24 +1449,10 @@ instruction_private(struct_processus *s_
 					(*(*s_etat_processus).pointeur_variable_courante)
 					.variable_statique) == d_erreur)
 			{
-				if (pthread_mutex_unlock(&((*(*s_etat_processus)
-						.s_liste_variables_partagees).mutex)) != 0)
-				{
-					(*s_etat_processus).erreur_systeme = d_es_processus;
-					return;
-				}
-
 				liberation(s_etat_processus, s_objet);
 				return;
 			}
 
-			if (pthread_mutex_unlock(&((*(*s_etat_processus)
-					.s_liste_variables_partagees).mutex)) != 0)
-			{
-				(*s_etat_processus).erreur_systeme = d_es_processus;
-				return;
-			}
-
 			l_element_courant = (*l_element_courant).suivant;
 		}
 	}