--- rpl/src/instructions_w1.c	2010/08/15 14:46:25	1.24
+++ rpl/src/instructions_w1.c	2011/09/15 17:51:43	1.48
@@ -1,7 +1,7 @@
 /*
 ================================================================================
-  RPL/2 (R) version 4.0.18
-  Copyright (C) 1989-2010 Dr. BERTRAND Joël
+  RPL/2 (R) version 4.1.3
+  Copyright (C) 1989-2011 Dr. BERTRAND Joël
 
   This file is part of RPL/2.
 
@@ -226,8 +226,7 @@ instruction_wait(struct_processus *s_eta
 		return;
 	}
 	
-	if (((*s_objet).type == INT) ||
-			((*s_objet).type == REL))
+	if (((*s_objet).type == INT) || ((*s_objet).type == REL))
 	{
 		if ((*s_objet).type == INT)
 		{
@@ -262,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);
@@ -1327,6 +1311,51 @@ instruction_write(struct_processus *s_et
 			/*
 			 * Fichiers de type FLOW
 			 */
+
+			if ((*((struct_fichier *) (*s_objet_argument_1).objet)).acces
+					== 'S')
+			{
+				BUG(((*descripteur).type != 'C'), uprintf("Bad filetype !\n"));
+
+				if ((*((*((struct_liste_chainee *) (*s_objet_argument_2).objet))
+						.donnee)).type != CHN)
+				{
+					liberation(s_etat_processus, s_objet_argument_2);
+					liberation(s_etat_processus, s_objet_argument_1);
+
+					(*s_etat_processus).erreur_execution =
+							d_ex_erreur_type_argument;
+					return;
+				}
+
+				if ((chaine = formateur_flux(s_etat_processus, (unsigned char *)
+						(*((*((struct_liste_chainee *) (*s_objet_argument_2)
+						.objet)).donnee)).objet, &longueur_effective)) == NULL)
+				{
+					(*s_etat_processus).erreur_systeme =
+							d_es_allocation_memoire;
+					return;
+				}
+
+				if (fwrite(chaine, sizeof(unsigned char), longueur_effective,
+						(*descripteur).descripteur_c) !=
+						(size_t) longueur_effective)
+				{
+					(*s_etat_processus).erreur_systeme = d_es_erreur_fichier;
+					return;
+				}
+
+				free(chaine);
+			}
+			else
+			{
+				liberation(s_etat_processus, s_objet_argument_1);
+				liberation(s_etat_processus, s_objet_argument_2);
+
+				(*s_etat_processus).erreur_execution =
+						d_ex_erreur_type_fichier;
+				return;
+			}
 		}
 	}
 	else if (((*s_objet_argument_2).type == LST) &&
@@ -1362,27 +1391,102 @@ instruction_write(struct_processus *s_et
 
 				return;
 			}
+		}
+		else if ((*((struct_socket *) (*s_objet_argument_1).objet)).binaire
+				== 'Y')
+		{
+			/*
+			 * Sockets non formatées
+			 */
+
+			chaine = NULL;
+		}
+		else
+		{
+			/*
+			 * 	Sockets de type FLOW
+			 */
 
-			if ((strcmp((*((struct_socket *) (*s_objet_argument_1).objet)).type,
-					"STREAM") == 0) || (strcmp((*((struct_socket *)
-					(*s_objet_argument_1).objet)).type,
-					"SEQUENTIAL DATAGRAM") == 0))
-			{ // Sockets connectées
+			if ((*((*((struct_liste_chainee *) (*s_objet_argument_2).objet))
+					.donnee)).type != CHN)
+			{
+				liberation(s_etat_processus, s_objet_argument_2);
+				liberation(s_etat_processus, s_objet_argument_1);
+
+				(*s_etat_processus).erreur_execution =
+						d_ex_erreur_type_argument;
+				return;
+			}
+
+			if ((chaine = formateur_flux(s_etat_processus, (unsigned char *)
+					(*((*((struct_liste_chainee *) (*s_objet_argument_2)
+					.objet)).donnee)).objet, &longueur_effective)) == NULL)
+			{
+				liberation(s_etat_processus, s_objet_argument_2);
+				liberation(s_etat_processus, s_objet_argument_1);
+
+				return;
+			}
+		}
 
-				action.sa_handler = SIG_IGN;
-				action.sa_flags = SA_ONSTACK;
+		if ((strcmp((*((struct_socket *) (*s_objet_argument_1).objet)).type,
+				"STREAM") == 0) || (strcmp((*((struct_socket *)
+				(*s_objet_argument_1).objet)).type,
+				"SEQUENTIAL DATAGRAM") == 0))
+		{ // Sockets connectées
 
-				if (sigaction(SIGPIPE, &action, &registre) != 0)
+			action.sa_handler = SIG_IGN;
+			action.sa_flags = SA_ONSTACK;
+
+			if (sigaction(SIGPIPE, &action, &registre) != 0)
+			{
+				(*s_etat_processus).erreur_systeme = d_es_signal;
+				return;
+			}
+
+			if (pthread_mutex_unlock(&((*s_etat_processus).mutex_fork)) != 0)
+			{
+				if (sigaction(SIGPIPE, &registre, NULL) != 0)
+				{
+					(*s_etat_processus).erreur_systeme = d_es_signal;
+					return;
+				}
+
+				(*s_etat_processus).erreur_systeme = d_es_processus;
+				return;
+			}
+
+			if (send((*((struct_socket *) (*s_objet_argument_1).objet))
+					.socket, chaine, longueur_effective, 0) < 0)
+			{
+				ios = errno;
+
+				if (sigaction(SIGPIPE, &registre, NULL) != 0)
 				{
 					(*s_etat_processus).erreur_systeme = d_es_signal;
 					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_lock(&((*s_etat_processus).mutex_fork)) != 0)
+				{
+					(*s_etat_processus).erreur_systeme = d_es_processus;
+					return;
+				}
+
+				if ((ios == EPIPE) || (ios == ECONNRESET))
+				{
+					(*s_etat_processus).erreur_execution =
+							d_ex_erreur_acces_fichier;
+					return;
+				}
+
+				(*s_etat_processus).erreur_systeme = d_es_erreur_fichier;
+				return;
+			}
+
+			if (pthread_mutex_lock(&((*s_etat_processus).mutex_fork)) != 0)
+			{
+				if (errno != EINTR)
 				{
 					if (sigaction(SIGPIPE, &registre, NULL) != 0)
 					{
@@ -1393,132 +1497,184 @@ instruction_write(struct_processus *s_et
 					(*s_etat_processus).erreur_systeme = d_es_processus;
 					return;
 				}
+			}
+
+			if (sigaction(SIGPIPE, &registre, NULL) != 0)
+			{
+				(*s_etat_processus).erreur_systeme = d_es_signal;
+				return;
+			}
+		}
+		else
+		{ // Sockets non connectées
+
+			/*
+			 * Vérification de l'adresse distante
+			 */
+
+			if (strcmp((*((struct_socket *) (*s_objet_argument_1).objet))
+					.adresse_distante, "") == 0)
+			{
+				liberation(s_etat_processus, s_objet_argument_1);
+				liberation(s_etat_processus, s_objet_argument_2);
+
+				(*s_etat_processus).erreur_execution =
+						d_ex_erreur_acces_fichier;
+				return;
+			}
+
+			/*
+			 * Création de l'adresse logique
+			 */
+
+			if ((*((struct_socket *) (*s_objet_argument_1).objet))
+					.domaine == PF_UNIX)
+			{
+				adresse_unix.sun_family = AF_UNIX;
+				strncpy(adresse_unix.sun_path, (*((struct_socket *)
+						(*s_objet_argument_1).objet)).adresse_distante,
+						UNIX_PATH_MAX);
+				adresse_unix.sun_path[UNIX_PATH_MAX - 1] =
+						d_code_fin_chaine;
+
+				if (pthread_mutex_unlock(&((*s_etat_processus).mutex_fork))
+						!= 0)
+				{
+					(*s_etat_processus).erreur_systeme = d_es_processus;
+					return;
+				}
 
-				if (send((*((struct_socket *) (*s_objet_argument_1).objet))
-						.socket, chaine, strlen(chaine), 0) < 0)
+				if (sendto((*((struct_socket *)
+						(*s_objet_argument_1).objet)).socket, chaine,
+						longueur_effective, 0, (struct sockaddr *)
+						&adresse_unix, sizeof(adresse_unix)) < 0)
 				{
 					ios = errno;
 
-					if (sigaction(SIGPIPE, &registre, NULL) != 0)
+					if (pthread_mutex_lock(&((*s_etat_processus)
+							.mutex_fork)) != 0)
 					{
-						(*s_etat_processus).erreur_systeme = d_es_signal;
+						(*s_etat_processus).erreur_systeme = d_es_processus;
 						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 (errno != EINTR)
-						{
-							(*s_etat_processus).erreur_systeme = d_es_processus;
-							return;
-						}
-					}
-
-					if (ios == EPIPE)
+					if ((ios == EPIPE) || (ios == ECONNRESET))
 					{
 						(*s_etat_processus).erreur_execution =
 								d_ex_erreur_acces_fichier;
 						return;
 					}
 
+
 					(*s_etat_processus).erreur_systeme = d_es_erreur_fichier;
 					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;
+				}
+			}
+			else if ((*((struct_socket *) (*s_objet_argument_1).objet))
+					.domaine == PF_INET)
+			{
+				if (sscanf((*((struct_socket *)
+						(*s_objet_argument_1).objet))
+						.adresse_distante, "%d.%d.%d.%d(%d)",
+						&(adresse[0]), &(adresse[1]), &(adresse[2]),
+						&(adresse[3]), &port) == 5)
+				{ // Adresse IPv4
+					calcul_adresse = 0;
+					for(i = 0; i < 4; calcul_adresse =
+							(256 * calcul_adresse) + adresse[i++]);
+
+					memset(&adresse_ipv4, 0, sizeof(adresse_ipv4));
+					adresse_ipv4.sin_family = AF_INET;
+					adresse_ipv4.sin_port = htons(port);
+					adresse_ipv4.sin_addr.s_addr = htonl(calcul_adresse);
+
+					if (pthread_mutex_unlock(&((*s_etat_processus)
+							.mutex_fork)) != 0)
+					{
+						(*s_etat_processus).erreur_systeme = d_es_processus;
+						return;
+					}
+
+					if (sendto((*((struct_socket *)
+							(*s_objet_argument_1).objet)).socket, chaine,
+							longueur_effective, 0, (struct sockaddr *)
+							&adresse_ipv4, sizeof(adresse_ipv4)) < 0)
 					{
-						if (sigaction(SIGPIPE, &registre, NULL) != 0)
+						if (pthread_mutex_lock(&((*s_etat_processus)
+								.mutex_fork)) != 0)
 						{
-							(*s_etat_processus).erreur_systeme = d_es_signal;
+							(*s_etat_processus).erreur_systeme = d_es_processus;
 							return;
 						}
 
-						(*s_etat_processus).erreur_systeme = d_es_processus;
+						(*s_etat_processus).erreur_systeme =
+								d_es_erreur_fichier;
 						return;
 					}
-				}
 
-				if (sigaction(SIGPIPE, &registre, NULL) != 0)
-				{
-					(*s_etat_processus).erreur_systeme = d_es_signal;
-					return;
+					if (pthread_mutex_lock(&((*s_etat_processus)
+							.mutex_fork)) != 0)
+					{
+						(*s_etat_processus).erreur_systeme = d_es_processus;
+						return;
+					}
 				}
-			}
-			else
-			{ // Sockets non connectées
-
-				/*
-				 * Vérification de l'adresse distante
-				 */
-
-				if (strcmp((*((struct_socket *) (*s_objet_argument_1).objet))
-						.adresse_distante, "") == 0)
+				else
 				{
 					liberation(s_etat_processus, s_objet_argument_1);
 					liberation(s_etat_processus, s_objet_argument_2);
 
 					(*s_etat_processus).erreur_execution =
-							d_ex_erreur_acces_fichier;
+							d_ex_erreur_parametre_fichier;
 					return;
 				}
+			}
+			else if ((*((struct_socket *) (*s_objet_argument_1).objet))
+					.domaine == PF_INET6)
+			{
+				if (sscanf((*((struct_socket *) (*s_objet_argument_1)
+						.objet)).adresse_distante, "%X:%X:%X:%X:%X:"
+						"%X:%X:%X:%X:%X:%X:%X:%X:%X:%X:%X(%d)",
+						&(adresse[0]), &(adresse[1]), &(adresse[2]),
+						&(adresse[3]), &(adresse[4]), &(adresse[5]),
+						&(adresse[6]), &(adresse[7]), &(adresse[8]),
+						&(adresse[9]), &(adresse[10]), &(adresse[11]),
+						&(adresse[12]), &(adresse[13]), &(adresse[14]),
+						&(adresse[15]), &port)== 17)
+				{ // Adresse IPv6
+#					ifdef IPV6
+					memset(&adresse_ipv6, 0, sizeof(adresse_ipv6));
+					adresse_ipv6.sin6_family = AF_INET6;
+					adresse_ipv6.sin6_port = htons((uint16_t) port);
+
+					for(i = 0; i < 16;
+							adresse_ipv6.sin6_addr.s6_addr[i] =
+							adresse[i], i++);
 
-				/*
-				 * Création de l'adresse logique
-				 */
-
-				if ((*((struct_socket *) (*s_objet_argument_1).objet))
-						.domaine == PF_UNIX)
-				{
-					adresse_unix.sun_family = AF_UNIX;
-					strncpy(adresse_unix.sun_path, (*((struct_socket *)
-							(*s_objet_argument_1).objet)).adresse_distante,
-							UNIX_PATH_MAX);
-					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,
-							strlen(chaine), 0, (struct sockaddr *)
-							&adresse_unix, sizeof(adresse_unix)) < 0)
+							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 =
@@ -1526,206 +1682,27 @@ 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 (errno != EINTR)
-						{
-							(*s_etat_processus).erreur_systeme = d_es_processus;
-							return;
-						}
-					}
-				}
-				else if ((*((struct_socket *) (*s_objet_argument_1).objet))
-						.domaine == PF_INET)
-				{
-					if (sscanf((*((struct_socket *)
-							(*s_objet_argument_1).objet))
-							.adresse_distante, "%d.%d.%d.%d(%d)",
-							&(adresse[0]), &(adresse[1]), &(adresse[2]),
-							&(adresse[3]), &port) == 5)
-					{ // Adresse IPv4
-						calcul_adresse = 0;
-						for(i = 0; i < 4; calcul_adresse =
-								(256 * calcul_adresse) + adresse[i++]);
-
-						memset(&adresse_ipv4, 0, sizeof(adresse_ipv4));
-						adresse_ipv4.sin_family = AF_INET;
-						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)
-						{
-							(*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,
-								strlen(chaine), 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 (errno != EINTR)
-								{
-									(*s_etat_processus).erreur_systeme =
-											d_es_processus;
-									return;
-								}
-							}
-
-							(*s_etat_processus).erreur_systeme =
-									d_es_erreur_fichier;
-							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 (errno != EINTR)
-							{
-								(*s_etat_processus).erreur_systeme =
-										d_es_processus;
-								return;
-							}
-						}
-					}
-					else
+					if (pthread_mutex_lock(&((*s_etat_processus)
+							.mutex_fork)) != 0)
 					{
-						liberation(s_etat_processus, s_objet_argument_1);
-						liberation(s_etat_processus, s_objet_argument_2);
-
-						(*s_etat_processus).erreur_execution =
-								d_ex_erreur_parametre_fichier;
+						(*s_etat_processus).erreur_systeme =
+								d_es_processus;
 						return;
 					}
-				}
-				else if ((*((struct_socket *) (*s_objet_argument_1).objet))
-						.domaine == PF_INET6)
-				{
-					if (sscanf((*((struct_socket *) (*s_objet_argument_1)
-							.objet)).adresse_distante, "%X:%X:%X:%X:%X:"
-							"%X:%X:%X:%X:%X:%X:%X:%X:%X:%X:%X(%d)",
-							&(adresse[0]), &(adresse[1]), &(adresse[2]),
-							&(adresse[3]), &(adresse[4]), &(adresse[5]),
-							&(adresse[6]), &(adresse[7]), &(adresse[8]),
-							&(adresse[9]), &(adresse[10]), &(adresse[11]),
-							&(adresse[12]), &(adresse[13]), &(adresse[14]),
-							&(adresse[15]), &port)== 17)
-					{ // Adresse IPv6
-#						ifdef IPV6
-						memset(&adresse_ipv6, 0, sizeof(adresse_ipv6));
-						adresse_ipv6.sin6_family = AF_INET6;
-						adresse_ipv6.sin6_port = htons((uint16_t) port);
-
-						for(i = 0; i < 16;
-								adresse_ipv6.sin6_addr.s6_addr[i] =
-								adresse[i], i++);
-
-#						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)
-						{
-							(*s_etat_processus).erreur_systeme = d_es_processus;
-							return;
-						}
-#						endif
-
-						if (sendto((*((struct_socket *)
-								(*s_objet_argument_1).objet)).socket, chaine,
-								strlen(chaine), 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 (errno != EINTR)
-								{
-									(*s_etat_processus).erreur_systeme =
-											d_es_processus;
-									return;
-								}
-							}
-
-							(*s_etat_processus).erreur_systeme =
-									d_es_erreur_fichier;
-							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 (errno != EINTR)
-							{
-								(*s_etat_processus).erreur_systeme =
-										d_es_processus;
-								return;
-							}
-						}
-#						else
-						if ((*s_etat_processus).langue == 'F')
-						{
-							printf("+++Attention : Support du protocole"
-									" IPv6 indisponible\n");
-						}
-						else
-						{
-							printf("+++Attention : IPv6 support "
-									"unavailable\n");
-						}
-#						endif
+#					else
+					if ((*s_etat_processus).langue == 'F')
+					{
+						printf("+++Attention : Support du protocole"
+								" IPv6 indisponible\n");
 					}
 					else
 					{
-						liberation(s_etat_processus, s_objet_argument_1);
-						liberation(s_etat_processus, s_objet_argument_2);
-
-						(*s_etat_processus).erreur_execution =
-								d_ex_erreur_parametre_fichier;
-						return;
+						printf("+++Warning : IPv6 support "
+								"unavailable\n");
 					}
+#					endif
 				}
-				else 
+				else
 				{
 					liberation(s_etat_processus, s_objet_argument_1);
 					liberation(s_etat_processus, s_objet_argument_2);
@@ -1735,22 +1712,18 @@ instruction_write(struct_processus *s_et
 					return;
 				}
 			}
+			else 
+			{
+				liberation(s_etat_processus, s_objet_argument_1);
+				liberation(s_etat_processus, s_objet_argument_2);
 
-			free(chaine);
-		}
-		else if ((*((struct_socket *) (*s_objet_argument_1).objet)).binaire
-				== 'Y')
-		{
-			/*
-			 * Sockets non formatées
-			 */
-		}
-		else
-		{
-			/*
-			 * 	Sockets de type FLOW
-			 */
+				(*s_etat_processus).erreur_execution =
+						d_ex_erreur_parametre_fichier;
+				return;
+			}
 		}
+
+		free(chaine);
 	}
 	else
 	{
@@ -1911,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)
 			{
@@ -2152,9 +2110,9 @@ instruction_wfproc(struct_processus *s_e
 				if ((*(*((struct_processus_fils *) (*(*l_element_courant)
 						.donnee).objet)).thread).processus_detache == d_vrai)
 				{
-					if (kill((*(*((struct_processus_fils *)
+					if (envoi_signal_processus((*(*((struct_processus_fils *)
 							(*(*l_element_courant).donnee).objet)).thread).pid,
-							0) != 0)
+							rpl_signull) != 0)
 					{
 						drapeau_fin = d_vrai;
 					}
@@ -2238,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);
@@ -2509,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);
@@ -2715,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))
@@ -2736,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)
@@ -2772,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);
@@ -2814,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))
@@ -2835,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)
@@ -2871,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);
@@ -2919,7 +2813,7 @@ instruction_wfsock(struct_processus *s_e
 			}
 			else
 			{
-				printf("+++Attention : IPv6 support "
+				printf("+++Warning : IPv6 support "
 						"unavailable\n");
 			}
 #			endif
@@ -2932,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))
@@ -2952,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)
@@ -2988,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);
@@ -3278,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);
@@ -3440,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;
 		}
 	}