--- rpl/src/instructions_w1.c	2011/04/11 13:02:26	1.34.2.1
+++ rpl/src/instructions_w1.c	2011/09/14 17:55:59	1.47
@@ -1,6 +1,6 @@
 /*
 ================================================================================
-  RPL/2 (R) version 4.0.22
+  RPL/2 (R) version 4.1.3
   Copyright (C) 1989-2011 Dr. BERTRAND Joël
 
   This file is part of RPL/2.
@@ -261,34 +261,19 @@ instruction_wait(struct_processus *s_eta
 
 		do
 		{
-#			ifndef SEMAPHORES_NOMMES
-			if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
+			if (pthread_mutex_unlock(&((*s_etat_processus).mutex_fork)) != 0)
 			{
 				(*s_etat_processus).erreur_systeme = d_es_processus;
 				return;
 			}
-#			else
-			if (sem_post((*s_etat_processus).semaphore_fork) != 0)
-			{
-				(*s_etat_processus).erreur_systeme = d_es_processus;
-				return;
-			}
-#			endif
 
 			code_retour = nanosleep(&temporisation, &temporisation);
 			erreur = errno;
 
-#			ifndef SEMAPHORES_NOMMES
-			while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1)
-#			else
-			while(sem_wait((*s_etat_processus).semaphore_fork) == -1)
-#			endif
+			if (pthread_mutex_lock(&((*s_etat_processus).mutex_fork)) != 0)
 			{
-				if (errno != EINTR)
-				{
-					(*s_etat_processus).erreur_systeme = d_es_processus;
-					return;
-				}
+				(*s_etat_processus).erreur_systeme = d_es_processus;
+				return;
 			}
 
 			scrutation_injection(s_etat_processus);
@@ -1413,6 +1398,8 @@ instruction_write(struct_processus *s_et
 			/*
 			 * Sockets non formatées
 			 */
+
+			chaine = NULL;
 		}
 		else
 		{
@@ -1457,11 +1444,7 @@ instruction_write(struct_processus *s_et
 				return;
 			}
 
-#			ifndef SEMAPHORES_NOMMES
-			if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
-#			else
-			if (sem_post((*s_etat_processus).semaphore_fork) != 0)
-#			endif
+			if (pthread_mutex_unlock(&((*s_etat_processus).mutex_fork)) != 0)
 			{
 				if (sigaction(SIGPIPE, &registre, NULL) != 0)
 				{
@@ -1484,17 +1467,10 @@ instruction_write(struct_processus *s_et
 					return;
 				}
 
-#				ifndef SEMAPHORES_NOMMES
-				while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1)
-#				else
-				while(sem_wait((*s_etat_processus).semaphore_fork) == -1)
-#				endif
+				if (pthread_mutex_lock(&((*s_etat_processus).mutex_fork)) != 0)
 				{
-					if (errno != EINTR)
-					{
-						(*s_etat_processus).erreur_systeme = d_es_processus;
-						return;
-					}
+					(*s_etat_processus).erreur_systeme = d_es_processus;
+					return;
 				}
 
 				if ((ios == EPIPE) || (ios == ECONNRESET))
@@ -1508,11 +1484,7 @@ instruction_write(struct_processus *s_et
 				return;
 			}
 
-#			ifndef SEMAPHORES_NOMMES
-			while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1)
-#			else
-			while(sem_wait((*s_etat_processus).semaphore_fork) == -1)
-#			endif
+			if (pthread_mutex_lock(&((*s_etat_processus).mutex_fork)) != 0)
 			{
 				if (errno != EINTR)
 				{
@@ -1565,39 +1537,25 @@ instruction_write(struct_processus *s_et
 				adresse_unix.sun_path[UNIX_PATH_MAX - 1] =
 						d_code_fin_chaine;
 
-#				ifndef SEMAPHORES_NOMMES
-				if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
-				{
-					(*s_etat_processus).erreur_systeme = d_es_processus;
-					return;
-				}
-#				else
-				if (sem_post((*s_etat_processus).semaphore_fork) != 0)
+				if (pthread_mutex_unlock(&((*s_etat_processus).mutex_fork))
+						!= 0)
 				{
 					(*s_etat_processus).erreur_systeme = d_es_processus;
 					return;
 				}
-#				endif
 
 				if (sendto((*((struct_socket *)
 						(*s_objet_argument_1).objet)).socket, chaine,
 						longueur_effective, 0, (struct sockaddr *)
 						&adresse_unix, sizeof(adresse_unix)) < 0)
 				{
-#					ifndef SEMAPHORES_NOMMES
-					while(sem_wait(&((*s_etat_processus)
-							.semaphore_fork)) == -1)
-#					else
-					while(sem_wait((*s_etat_processus)
-							.semaphore_fork) == -1)
-#					endif
+					ios = errno;
+
+					if (pthread_mutex_lock(&((*s_etat_processus)
+							.mutex_fork)) != 0)
 					{
-						if (errno != EINTR)
-						{
-							(*s_etat_processus).erreur_systeme =
-									d_es_processus;
-							return;
-						}
+						(*s_etat_processus).erreur_systeme = d_es_processus;
+						return;
 					}
 
 					if ((ios == EPIPE) || (ios == ECONNRESET))
@@ -1612,17 +1570,10 @@ instruction_write(struct_processus *s_et
 					return;
 				}
 
-#				ifndef SEMAPHORES_NOMMES
-				while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1)
-#				else
-				while(sem_wait((*s_etat_processus).semaphore_fork) == -1)
-#				endif
+				if (pthread_mutex_lock(&((*s_etat_processus).mutex_fork)) != 0)
 				{
-					if (errno != EINTR)
-					{
-						(*s_etat_processus).erreur_systeme = d_es_processus;
-						return;
-					}
+					(*s_etat_processus).erreur_systeme = d_es_processus;
+					return;
 				}
 			}
 			else if ((*((struct_socket *) (*s_objet_argument_1).objet))
@@ -1643,40 +1594,23 @@ instruction_write(struct_processus *s_et
 					adresse_ipv4.sin_port = htons(port);
 					adresse_ipv4.sin_addr.s_addr = htonl(calcul_adresse);
 
-#					ifndef SEMAPHORES_NOMMES
-					if (sem_post(&((*s_etat_processus)
-							.semaphore_fork)) != 0)
+					if (pthread_mutex_unlock(&((*s_etat_processus)
+							.mutex_fork)) != 0)
 					{
 						(*s_etat_processus).erreur_systeme = d_es_processus;
 						return;
 					}
-#					else
-					if (sem_post((*s_etat_processus) .semaphore_fork) != 0)
-					{
-						(*s_etat_processus).erreur_systeme = d_es_processus;
-						return;
-					}
-#					endif
 
 					if (sendto((*((struct_socket *)
 							(*s_objet_argument_1).objet)).socket, chaine,
 							longueur_effective, 0, (struct sockaddr *)
 							&adresse_ipv4, sizeof(adresse_ipv4)) < 0)
 					{
-#						ifndef SEMAPHORES_NOMMES
-						while(sem_wait(&((*s_etat_processus)
-								.semaphore_fork)) == -1)
-#						else
-						while(sem_wait((*s_etat_processus)
-								.semaphore_fork) == -1)
-#						endif
+						if (pthread_mutex_lock(&((*s_etat_processus)
+								.mutex_fork)) != 0)
 						{
-							if (errno != EINTR)
-							{
-								(*s_etat_processus).erreur_systeme =
-										d_es_processus;
-								return;
-							}
+							(*s_etat_processus).erreur_systeme = d_es_processus;
+							return;
 						}
 
 						(*s_etat_processus).erreur_systeme =
@@ -1684,20 +1618,11 @@ instruction_write(struct_processus *s_et
 						return;
 					}
 
-#					ifndef SEMAPHORES_NOMMES
-					while(sem_wait(&((*s_etat_processus)
-							.semaphore_fork)) == -1)
-#					else
-					while(sem_wait((*s_etat_processus)
-							.semaphore_fork) == -1)
-#					endif
+					if (pthread_mutex_lock(&((*s_etat_processus)
+							.mutex_fork)) != 0)
 					{
-						if (errno != EINTR)
-						{
-							(*s_etat_processus).erreur_systeme =
-									d_es_processus;
-							return;
-						}
+						(*s_etat_processus).erreur_systeme = d_es_processus;
+						return;
 					}
 				}
 				else
@@ -1732,40 +1657,24 @@ instruction_write(struct_processus *s_et
 							adresse_ipv6.sin6_addr.s6_addr[i] =
 							adresse[i], i++);
 
-#					ifndef SEMAPHORES_NOMMES
-					if (sem_post(&((*s_etat_processus)
-							.semaphore_fork)) != 0)
+					if (pthread_mutex_unlock(&((*s_etat_processus)
+							.mutex_fork)) != 0)
 					{
 						(*s_etat_processus).erreur_systeme = d_es_processus;
 						return;
 					}
-#					else
-					if (sem_post((*s_etat_processus) .semaphore_fork) != 0)
-					{
-						(*s_etat_processus).erreur_systeme = d_es_processus;
-						return;
-					}
-#					endif
 
 					if (sendto((*((struct_socket *)
 							(*s_objet_argument_1).objet)).socket, chaine,
 							longueur_effective, 0, (struct sockaddr *)
 							&adresse_ipv6, sizeof(adresse_ipv6)) < 0)
 					{
-#						ifndef SEMAPHORES_NOMMES
-						while(sem_wait(&((*s_etat_processus)
-								.semaphore_fork)) == -1)
-#						else
-						while(sem_wait((*s_etat_processus)
-								.semaphore_fork) == -1)
-#						endif
+						if (pthread_mutex_lock(&((*s_etat_processus)
+								.mutex_fork)) != 0)
 						{
-							if (errno != EINTR)
-							{
-								(*s_etat_processus).erreur_systeme =
-										d_es_processus;
-								return;
-							}
+							(*s_etat_processus).erreur_systeme =
+									d_es_processus;
+							return;
 						}
 
 						(*s_etat_processus).erreur_systeme =
@@ -1773,20 +1682,12 @@ instruction_write(struct_processus *s_et
 						return;
 					}
 
-#					ifndef SEMAPHORES_NOMMES
-					while(sem_wait(&((*s_etat_processus)
-							.semaphore_fork)) == -1)
-#					else
-					while(sem_wait((*s_etat_processus)
-							.semaphore_fork) == -1)
-#					endif
+					if (pthread_mutex_lock(&((*s_etat_processus)
+							.mutex_fork)) != 0)
 					{
-						if (errno != EINTR)
-						{
-							(*s_etat_processus).erreur_systeme =
-									d_es_processus;
-							return;
-						}
+						(*s_etat_processus).erreur_systeme =
+								d_es_processus;
+						return;
 					}
 #					else
 					if ((*s_etat_processus).langue == 'F')
@@ -1983,32 +1884,17 @@ instruction_wflock(struct_processus *s_e
 				return;
 			}
 
-#			ifndef SEMAPHORES_NOMMES
-			if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
+			if (pthread_mutex_unlock(&((*s_etat_processus).mutex_fork)) != 0)
 			{
 				(*s_etat_processus).erreur_systeme = d_es_processus;
 				return;
 			}
-#			else
-			if (sem_post((*s_etat_processus).semaphore_fork) != 0)
+
+			if (pthread_mutex_lock(&((*s_etat_processus).mutex_fork)) != 0)
 			{
 				(*s_etat_processus).erreur_systeme = d_es_processus;
 				return;
 			}
-#			endif
-
-#			ifndef SEMAPHORES_NOMMES
-			while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1)
-#			else
-			while(sem_wait((*s_etat_processus).semaphore_fork) == -1)
-#			endif
-			{
-				if (errno != EINTR)
-				{
-					(*s_etat_processus).erreur_systeme = d_es_processus;
-					return;
-				}
-			}
 
 			if (lock.l_type == F_UNLCK)
 			{
@@ -2310,33 +2196,20 @@ instruction_wfproc(struct_processus *s_e
 								registre_instruction_valide;
 					}
 
-#					ifndef SEMAPHORES_NOMMES
-					if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
+					if (pthread_mutex_unlock(&((*s_etat_processus)
+							.mutex_fork)) != 0)
 					{
 						(*s_etat_processus).erreur_systeme = d_es_processus;
 						return;
 					}
-#					else
-					if (sem_post((*s_etat_processus).semaphore_fork) != 0)
-					{
-						(*s_etat_processus).erreur_systeme = d_es_processus;
-						return;
-					}
-#					endif
 
 					nanosleep(&attente, NULL);
 
-#					ifndef SEMAPHORES_NOMMES
-					while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1)
-#					else
-					while(sem_wait((*s_etat_processus).semaphore_fork) == -1)
-#					endif
+					if (pthread_mutex_lock(&((*s_etat_processus).mutex_fork))
+							!= 0)
 					{
-						if (errno != EINTR)
-						{
-							(*s_etat_processus).erreur_systeme = d_es_processus;
-							return;
-						}
+						(*s_etat_processus).erreur_systeme = d_es_processus;
+						return;
 					}
 
 					scrutation_injection(s_etat_processus);
@@ -2581,33 +2454,20 @@ instruction_wfdata(struct_processus *s_e
 						return;
 					}
 
-#					ifndef SEMAPHORES_NOMMES
-					if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
-					{
-						(*s_etat_processus).erreur_systeme = d_es_processus;
-						return;
-					}
-#					else
-					if (sem_post((*s_etat_processus).semaphore_fork) != 0)
+					if (pthread_mutex_unlock(&((*s_etat_processus)
+							.mutex_fork)) != 0)
 					{
 						(*s_etat_processus).erreur_systeme = d_es_processus;
 						return;
 					}
-#					endif
 
 					nanosleep(&attente, NULL);
 
-#					ifndef SEMAPHORES_NOMMES
-					while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1)
-#					else
-					while(sem_wait((*s_etat_processus).semaphore_fork) == -1)
-#					endif
+					if (pthread_mutex_lock(&((*s_etat_processus).mutex_fork))
+							!= 0)
 					{
-						if (errno != EINTR)
-						{
-							(*s_etat_processus).erreur_systeme = d_es_processus;
-							return;
-						}
+						(*s_etat_processus).erreur_systeme = d_es_processus;
+						return;
 					}
 
 					scrutation_injection(s_etat_processus);
@@ -2787,19 +2647,12 @@ instruction_wfsock(struct_processus *s_e
 			{
 				drapeau = d_vrai;
 
-#				ifndef SEMAPHORES_NOMMES
-				if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
-				{
-					(*s_etat_processus).erreur_systeme = d_es_processus;
-					return;
-				}
-#				else
-				if (sem_post((*s_etat_processus).semaphore_fork) != 0)
+				if (pthread_mutex_unlock(&((*s_etat_processus).mutex_fork))
+						!= 0)
 				{
 					(*s_etat_processus).erreur_systeme = d_es_processus;
 					return;
 				}
-#				endif
 
 				if (((*((struct_socket *) (*s_objet_resultat).objet)).socket =
 						accept((*((struct_socket *) (*s_objet_argument).objet))
@@ -2808,17 +2661,11 @@ instruction_wfsock(struct_processus *s_e
 				{
 					erreur = errno;
 
-#					ifndef SEMAPHORES_NOMMES
-					while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1)
-#					else
-					while(sem_wait((*s_etat_processus).semaphore_fork) == -1)
-#					endif
+					if (pthread_mutex_lock(&((*s_etat_processus).mutex_fork))
+							!= 0)
 					{
-						if (errno != EINTR)
-						{
-							(*s_etat_processus).erreur_systeme = d_es_processus;
-							return;
-						}
+						(*s_etat_processus).erreur_systeme = d_es_processus;
+						return;
 					}
 
 					if (erreur != EINTR)
@@ -2844,17 +2691,11 @@ instruction_wfsock(struct_processus *s_e
 				}
 				else
 				{
-#					ifndef SEMAPHORES_NOMMES
-					while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1)
-#					else
-					while(sem_wait((*s_etat_processus).semaphore_fork) == -1)
-#					endif
+					if (pthread_mutex_lock(&((*s_etat_processus).mutex_fork))
+							!= 0)
 					{
-						if (errno != EINTR)
-						{
-							(*s_etat_processus).erreur_systeme = d_es_processus;
-							return;
-						}
+						(*s_etat_processus).erreur_systeme = d_es_processus;
+						return;
 					}
 				}
 			} while(drapeau == d_faux);
@@ -2886,19 +2727,12 @@ instruction_wfsock(struct_processus *s_e
 			{
 				drapeau = d_vrai;
 
-#				ifndef SEMAPHORES_NOMMES
-				if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
-				{
-					(*s_etat_processus).erreur_systeme = d_es_processus;
-					return;
-				}
-#				else
-				if (sem_post((*s_etat_processus).semaphore_fork) != 0)
+				if (pthread_mutex_unlock(&((*s_etat_processus).mutex_fork))
+						!= 0)
 				{
 					(*s_etat_processus).erreur_systeme = d_es_processus;
 					return;
 				}
-#				endif
 
 				if (((*((struct_socket *) (*s_objet_resultat).objet)).socket =
 						accept((*((struct_socket *) (*s_objet_argument).objet))
@@ -2907,17 +2741,11 @@ instruction_wfsock(struct_processus *s_e
 				{
 					erreur = errno;
 
-#					ifndef SEMAPHORES_NOMMES
-					while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1)
-#					else
-					while(sem_wait((*s_etat_processus).semaphore_fork) == -1)
-#					endif
+					if (pthread_mutex_lock(&((*s_etat_processus).mutex_fork))
+							!= 0)
 					{
-						if (errno != EINTR)
-						{
-							(*s_etat_processus).erreur_systeme = d_es_processus;
-							return;
-						}
+						(*s_etat_processus).erreur_systeme = d_es_processus;
+						return;
 					}
 
 					if (erreur != EINTR)
@@ -2943,17 +2771,11 @@ instruction_wfsock(struct_processus *s_e
 				}
 				else
 				{
-#					ifndef SEMAPHORES_NOMMES
-					while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1)
-#					else
-					while(sem_wait((*s_etat_processus).semaphore_fork) == -1)
-#					endif
+					if (pthread_mutex_lock(&((*s_etat_processus).mutex_fork))
+							!= 0)
 					{
-						if (errno != EINTR)
-						{
-							(*s_etat_processus).erreur_systeme = d_es_processus;
-							return;
-						}
+						(*s_etat_processus).erreur_systeme = d_es_processus;
+						return;
 					}
 				}
 			} while(drapeau == d_faux);
@@ -3004,19 +2826,12 @@ instruction_wfsock(struct_processus *s_e
 			{
 				drapeau = d_vrai;
 
-#				ifndef SEMAPHORES_NOMMES
-				if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
-				{
-					(*s_etat_processus).erreur_systeme = d_es_processus;
-					return;
-				}
-#				else
-				if (sem_post((*s_etat_processus).semaphore_fork) != 0)
+				if (pthread_mutex_unlock(&((*s_etat_processus).mutex_fork))
+						!= 0)
 				{
 					(*s_etat_processus).erreur_systeme = d_es_processus;
 					return;
 				}
-#				endif
 
 				if (((*((struct_socket *) (*s_objet_resultat).objet)).socket =
 						accept((*((struct_socket *) (*s_objet_argument).objet))
@@ -3024,17 +2839,11 @@ instruction_wfsock(struct_processus *s_e
 				{
 					erreur = errno;
 
-#					ifndef SEMAPHORES_NOMMES
-					while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1)
-#					else
-					while(sem_wait((*s_etat_processus).semaphore_fork) == -1)
-#					endif
+					if (pthread_mutex_lock(&((*s_etat_processus).mutex_fork))
+							!= 0)
 					{
-						if (errno != EINTR)
-						{
-							(*s_etat_processus).erreur_systeme = d_es_processus;
-							return;
-						}
+						(*s_etat_processus).erreur_systeme = d_es_processus;
+						return;
 					}
 
 					if (erreur != EINTR)
@@ -3060,17 +2869,11 @@ instruction_wfsock(struct_processus *s_e
 				}
 				else
 				{
-#					ifndef SEMAPHORES_NOMMES
-					while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1)
-#					else
-					while(sem_wait((*s_etat_processus).semaphore_fork) == -1)
-#					endif
+					if (pthread_mutex_lock(&((*s_etat_processus).mutex_fork))
+							!= 0)
 					{
-						if (errno != EINTR)
-						{
-							(*s_etat_processus).erreur_systeme = d_es_processus;
-							return;
-						}
+						(*s_etat_processus).erreur_systeme = d_es_processus;
+						return;
 					}
 				}
 			} while(drapeau == d_faux);
@@ -3350,33 +3153,18 @@ instruction_wfpoke(struct_processus *s_e
 
 	do
 	{
-#		ifndef SEMAPHORES_NOMMES
-		if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
+		if (pthread_mutex_unlock(&((*s_etat_processus).mutex_fork)) != 0)
 		{
 			(*s_etat_processus).erreur_systeme = d_es_processus;
 			return;
 		}
-#		else
-		if (sem_post((*s_etat_processus).semaphore_fork) != 0)
-		{
-			(*s_etat_processus).erreur_systeme = d_es_processus;
-			return;
-		}
-#		endif
 
 		nanosleep(&attente, NULL);
 
-#		ifndef SEMAPHORES_NOMMES
-		while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1)
-#		else
-		while(sem_wait((*s_etat_processus).semaphore_fork) == -1)
-#		endif
+		if (pthread_mutex_lock(&((*s_etat_processus).mutex_fork)) != 0)
 		{
-			if (errno != EINTR)
-			{
-				(*s_etat_processus).erreur_systeme = d_es_processus;
-				return;
-			}
+			(*s_etat_processus).erreur_systeme = d_es_processus;
+			return;
 		}
 
 		scrutation_injection(s_etat_processus);
@@ -3512,34 +3300,19 @@ instruction_wfack(struct_processus *s_et
 			return;
 		}
 
-#		ifndef SEMAPHORES_NOMMES
-		if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
-		{
-			(*s_etat_processus).erreur_systeme = d_es_processus;
-			return;
-		}
-#		else
-		if (sem_post((*s_etat_processus).semaphore_fork) != 0)
+		if (pthread_mutex_unlock(&((*s_etat_processus).mutex_fork)) != 0)
 		{
 			(*s_etat_processus).erreur_systeme = d_es_processus;
 			return;
 		}
-#		endif
 
 		nanosleep(&attente, NULL);
 		INCR_GRANULARITE(attente.tv_nsec);
 
-#		ifndef SEMAPHORES_NOMMES
-		while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1)
-#		else
-		while(sem_wait((*s_etat_processus).semaphore_fork) == -1)
-#		endif
+		if (pthread_mutex_lock(&((*s_etat_processus).mutex_fork)) != 0)
 		{
-			if (errno != EINTR)
-			{
-				(*s_etat_processus).erreur_systeme = d_es_processus;
-				return;
-			}
+			(*s_etat_processus).erreur_systeme = d_es_processus;
+			return;
 		}
 	}