--- rpl/src/instructions_r4.c	2011/04/17 14:01:23	1.28.2.3
+++ rpl/src/instructions_r4.c	2011/09/20 08:56:23	1.42
@@ -1,6 +1,6 @@
 /*
 ================================================================================
-  RPL/2 (R) version 4.0.23
+  RPL/2 (R) version 4.1.3
   Copyright (C) 1989-2011 Dr. BERTRAND Joël
 
   This file is part of RPL/2.
@@ -2034,11 +2034,9 @@ instruction_read(struct_processus *s_eta
 			}
 		}
 
-printf("<1>\n");
 		if ((*((struct_socket *) (*s_objet_argument_1).objet)).binaire == 'N')
 		{ // Socket formatée
 			longueur_questure = 256;
-printf("<2>\n");
 
 			do
 			{
@@ -2050,19 +2048,11 @@ printf("<2>\n");
 					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)
-				{
-					(*s_etat_processus).erreur_systeme = d_es_processus;
-					return;
-				}
-#				endif
 
 				attente.tv_sec = 0;
 				attente.tv_nsec = GRANULARITE_us * 1000;
@@ -2099,6 +2089,7 @@ printf("<2>\n");
 								tampon_lecture, longueur_questure,
 								MSG_PEEK | MSG_DONTWAIT, (struct sockaddr *)
 								&adresse_ipv6, &longueur_adresse);
+
 #						else
 						if ((*s_etat_processus).langue == 'F')
 						{
@@ -2117,20 +2108,11 @@ printf("<2>\n");
 						free(tampon_lecture);
 						liberation(s_etat_processus, s_objet_argument_1);
 
-#						ifndef SEMAPHORES_NOMMES
 						while(sem_wait(&((*s_etat_processus)
-								.semaphore_fork)) == -1)
-#						else
-						while(sem_wait((*s_etat_processus)
-								.semaphore_fork) == -1)
-#						endif
+								.semaphore_fork)) != 0)
 						{
-							if (errno != EINTR)
-							{
-								(*s_etat_processus).erreur_systeme =
-										d_es_processus;
-								return;
-							}
+							(*s_etat_processus).erreur_systeme =
+									d_es_processus;
 						}
 
 						(*s_etat_processus).erreur_execution =
@@ -2138,31 +2120,26 @@ printf("<2>\n");
 						return;
 					}
 
-					if (longueur_effective <= 0)
+					if (longueur_effective < 0)
 					{
 						nanosleep(&attente, NULL);
 						INCR_GRANULARITE(attente.tv_nsec);
 						scrutation_injection(s_etat_processus);
 					}
 
+					// Une donnée a été reçue.
+
 					if (((*s_etat_processus).var_volatile_requete_arret == -1)
-							|| (longueur_effective > 0))
+							|| (longueur_effective >= 0))
 					{
 						break;
 					}
 				}
 
-#				ifndef SEMAPHORES_NOMMES
-				while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1)
-#				else
-				while(sem_wait((*s_etat_processus).semaphore_fork) == -1)
-#				endif
+				if (sem_wait(&((*s_etat_processus).semaphore_fork)) != 0)
 				{
-					if (errno != EINTR)
-					{
-						(*s_etat_processus).erreur_systeme = d_es_processus;
-						return;
-					}
+					(*s_etat_processus).erreur_systeme = d_es_processus;
+					return;
 				}
 
 				if ((*s_etat_processus).var_volatile_requete_arret == -1)
@@ -2358,7 +2335,6 @@ printf("<2>\n");
 						(*s_objet_argument_1).objet)).socket, tampon_lecture,
 						longueur_effective, MSG_DONTWAIT,
 						NULL, &longueur_adresse);
-printf("<%s>\n", tampon_lecture);
 
 				(*s_objet_adresse).objet = NULL;
 			}
@@ -2559,19 +2535,11 @@ printf("<%s>\n", tampon_lecture);
 					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)
-				{
-					(*s_etat_processus).erreur_systeme = d_es_processus;
-					return;
-				}
-#				endif
 
 				attente.tv_sec = 0;
 				attente.tv_nsec = GRANULARITE_us * 1000;
@@ -2626,20 +2594,12 @@ printf("<%s>\n", tampon_lecture);
 						free(tampon_lecture);
 						liberation(s_etat_processus, s_objet_argument_1);
 
-#						ifndef SEMAPHORES_NOMMES
-						while(sem_wait(&((*s_etat_processus)
-								.semaphore_fork)) == -1)
-#						else
-						while(sem_wait((*s_etat_processus)
-								.semaphore_fork) == -1)
-#						endif
+						if (sem_wait(&((*s_etat_processus)
+								.semaphore_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_execution =
@@ -2661,17 +2621,10 @@ printf("<%s>\n", tampon_lecture);
 					}
 				}
 
-#				ifndef SEMAPHORES_NOMMES
-				while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1)
-#				else
-				while(sem_wait((*s_etat_processus).semaphore_fork) == -1)
-#				endif
+				if (sem_wait(&((*s_etat_processus).semaphore_fork)) != 0)
 				{
-					if (errno != EINTR)
-					{
-						(*s_etat_processus).erreur_systeme = d_es_processus;
-						return;
-					}
+					(*s_etat_processus).erreur_systeme = d_es_processus;
+					return;
 				}
 
 				if ((*s_etat_processus).var_volatile_requete_arret == -1)