--- rpl/src/instructions_r4.c	2012/06/19 09:59:34	1.56
+++ rpl/src/instructions_r4.c	2012/06/19 10:14:56	1.57
@@ -867,6 +867,7 @@ instruction_read(struct_processus *s_eta
 	logical1						indicateur_48;
 	logical1						presence_chaine;
 	logical1						presence_indicateur;
+	logical1						trame_complete;
 
 	socklen_t						longueur_adresse;
 
@@ -2217,12 +2218,16 @@ printf("L=%d\n", longueur_enregistrement
 			attente.tv_sec = 0;
 			attente.tv_nsec = GRANULARITE_us * 1000;
 
+			trame_complete = d_faux;
+			position_initiale = 0;
+			position_finale = 0;
+
 			do
 			{
 				presence_indicateur = d_faux;
 
 				if ((tampon_lecture = realloc(tampon_lecture,
-						(longueur_effective + longueur_questure)
+						(longueur_effective + longueur_questure + 1)
 					   	* sizeof(unsigned char))) == NULL)
 				{
 					(*s_etat_processus).erreur_systeme =
@@ -2244,35 +2249,47 @@ printf("L=%d\n", longueur_enregistrement
 						.domaine == PF_UNIX)
 				{
 					longueur_adresse = sizeof(adresse_unix);
-					ios = recvfrom((*((struct_socket *)
-							(*s_objet_argument_1).objet)).socket,
-							tampon_lecture + longueur_effective,
-							longueur_questure,
-							MSG_PEEK | MSG_DONTWAIT, (struct sockaddr *)
-							&adresse_unix, &longueur_adresse);
+
+					do
+					{
+						ios = recvfrom((*((struct_socket *)
+								(*s_objet_argument_1).objet)).socket,
+								tampon_lecture + longueur_effective,
+								longueur_questure,
+								MSG_PEEK | MSG_DONTWAIT, (struct sockaddr *)
+								&adresse_unix, &longueur_adresse);
+					} while((ios == -1) && (errno == EINTR));
 				}
 				else if ((*((struct_socket *) (*s_objet_argument_1).objet))
 						.domaine == PF_INET)
 				{
 					longueur_adresse = sizeof(adresse_ipv4);
-					ios = recvfrom((*((struct_socket *)
-							(*s_objet_argument_1).objet)).socket,
-							tampon_lecture + longueur_effective,
-							longueur_questure,
-							MSG_PEEK | MSG_DONTWAIT, (struct sockaddr *)
-							&adresse_ipv4, &longueur_adresse);
+
+					do
+					{
+						ios = recvfrom((*((struct_socket *)
+								(*s_objet_argument_1).objet)).socket,
+								tampon_lecture + longueur_effective,
+								longueur_questure,
+								MSG_PEEK | MSG_DONTWAIT, (struct sockaddr *)
+								&adresse_ipv4, &longueur_adresse);
+					} while((ios == -1) && (errno == EINTR));
 				}
 				else if ((*((struct_socket *) (*s_objet_argument_1).objet))
 						.domaine == PF_INET6)
 				{
 #					ifdef IPV6
 					longueur_adresse = sizeof(adresse_ipv6);
-					ios = recvfrom((*((struct_socket *)
-							(*s_objet_argument_1).objet)).socket,
-							tampon_lecture + longueur_effective,
-							longueur_questure,
-							MSG_PEEK | MSG_DONTWAIT, (struct sockaddr *)
-							&adresse_ipv6, &longueur_adresse);
+					
+					do
+					{
+						ios = recvfrom((*((struct_socket *)
+								(*s_objet_argument_1).objet)).socket,
+								tampon_lecture + longueur_effective,
+								longueur_questure,
+								MSG_PEEK | MSG_DONTWAIT, (struct sockaddr *)
+								&adresse_ipv6, &longueur_adresse);
+					} while((ios == -1) && (errno == EINTR));
 #					else
 					if ((*s_etat_processus).langue == 'F')
 					{
@@ -2385,6 +2402,7 @@ printf("L=%d\n", longueur_enregistrement
 							if (niveau == 0)
 							{
 								presence_indicateur = d_vrai;
+								trame_complete = d_vrai;
 								break;
 							}
 
@@ -2399,35 +2417,50 @@ printf("L=%d\n", longueur_enregistrement
 							.domaine == PF_UNIX)
 					{
 						longueur_adresse = sizeof(adresse_unix);
-						ios = recvfrom((*((struct_socket *)
-								(*s_objet_argument_1).objet)).socket,
-								poubelle, position_finale
-								- ancienne_longueur_effective,
-								MSG_DONTWAIT, (struct sockaddr *)
-								&adresse_unix, &longueur_adresse);
+
+						do
+						{
+							ios = recvfrom((*((struct_socket *)
+									(*s_objet_argument_1).objet)).socket,
+									poubelle, position_finale
+									- ancienne_longueur_effective,
+									MSG_DONTWAIT, (struct sockaddr *)
+									&adresse_unix, &longueur_adresse);
+						}
+						while((ios == -1) && (errno == EINTR));
 					}
 					else if ((*((struct_socket *) (*s_objet_argument_1)
 							.objet)).domaine == PF_INET)
 					{
 						longueur_adresse = sizeof(adresse_ipv4);
-						ios = recvfrom((*((struct_socket *)
-								(*s_objet_argument_1).objet)).socket,
-								poubelle, position_finale
-								- ancienne_longueur_effective,
-								MSG_DONTWAIT, (struct sockaddr *)
-								&adresse_ipv4, &longueur_adresse);
+
+						do
+						{
+							ios = recvfrom((*((struct_socket *)
+									(*s_objet_argument_1).objet)).socket,
+									poubelle, position_finale
+									- ancienne_longueur_effective,
+									MSG_DONTWAIT, (struct sockaddr *)
+									&adresse_ipv4, &longueur_adresse);
+						}
+						while((ios == -1) && (errno == EINTR));
 					}
 					else if ((*((struct_socket *) (*s_objet_argument_1)
 							.objet)) .domaine == PF_INET6)
 					{
 #						ifdef IPV6
 						longueur_adresse = sizeof(adresse_ipv6);
-						ios = recvfrom((*((struct_socket *)
-								(*s_objet_argument_1).objet)).socket,
-								poubelle, position_finale
-								- ancienne_longueur_effective,
-								MSG_DONTWAIT, (struct sockaddr *)
-								&adresse_ipv6, &longueur_adresse);
+
+						do
+						{
+							ios = recvfrom((*((struct_socket *)
+									(*s_objet_argument_1).objet)).socket,
+									poubelle, position_finale
+									- ancienne_longueur_effective,
+									MSG_DONTWAIT, (struct sockaddr *)
+									&adresse_ipv6, &longueur_adresse);
+						}
+						while((ios == -1) && (errno == EINTR));
 #						else
 						if ((*s_etat_processus).langue == 'F')
 						{
@@ -2514,7 +2547,7 @@ printf("L=%d\n", longueur_enregistrement
 							d_ex_erreur_acces_fichier;
 					return;
 				}
-			} while(presence_indicateur == d_faux);
+			} while(trame_complete == d_faux);
 
 			tampon_lecture[++position_finale] = d_code_fin_chaine;
 			tampon = (*s_etat_processus).instruction_courante;
@@ -2531,6 +2564,20 @@ printf("L=%d\n", longueur_enregistrement
 				(*s_etat_processus).instruction_courante = tampon;
 				free(tampon_lecture);
 				
+				if (indicateur_48 == d_vrai)
+				{
+					sf(s_etat_processus, 48);
+				}
+				else
+				{
+					cf(s_etat_processus, 48);
+				}
+
+				if ((*s_etat_processus).var_volatile_requete_arret == -1)
+				{
+					(*s_etat_processus).erreur_execution = d_ex;
+				}
+
 				liberation(s_etat_processus, s_objet_argument_1);
 				return;
 			}