--- rpl/src/instructions_r4.c	2013/03/11 15:41:05	1.73
+++ rpl/src/instructions_r4.c	2013/03/15 11:37:26	1.74
@@ -2335,11 +2335,10 @@ instruction_read(struct_processus *s_eta
 					return;
 				}
 
-				if (ios < 0)
+				if (ios <= 0)
 				{
 					nanosleep(&attente, NULL);
 					INCR_GRANULARITE(attente.tv_nsec);
-					scrutation_injection(s_etat_processus);
 				}
 				else
 				{
@@ -2347,11 +2346,13 @@ instruction_read(struct_processus *s_eta
 					attente.tv_nsec = GRANULARITE_us * 1000;
 				}
 
+				scrutation_injection(s_etat_processus);
+
 				if ((*s_etat_processus).var_volatile_requete_arret == -1)
 				{
 					if (ios >= 0)
 					{
-						longueur_effective += ios;
+						longueur_effective = ios;
 					}
 
 					break;
@@ -2361,7 +2362,7 @@ instruction_read(struct_processus *s_eta
 
 				if (ios >= 0)
 				{
-					longueur_effective += ios;
+					longueur_effective = ios;
 					position_initiale = 0;
 					presence_indicateur = d_faux;
 
@@ -2968,11 +2969,10 @@ instruction_read(struct_processus *s_eta
 					return;
 				}
 
-				if (ios < 0)
+				if (ios <= 0)
 				{
 					nanosleep(&attente, NULL);
 					INCR_GRANULARITE(attente.tv_nsec);
-					scrutation_injection(s_etat_processus);
 				}
 				else
 				{
@@ -2980,6 +2980,8 @@ instruction_read(struct_processus *s_eta
 					attente.tv_nsec = GRANULARITE_us * 1000;
 				}
 
+				scrutation_injection(s_etat_processus);
+
 				if ((*s_etat_processus).var_volatile_requete_arret == -1)
 				{
 					if (ios >= 0)
@@ -2992,181 +2994,71 @@ instruction_read(struct_processus *s_eta
 
 				// Une donnée a été reçue.
 
-				if (ios >= 0)
+				if (ios == (longueur_effective + longueur_questure))
 				{
-					longueur_effective += ios;
+					longueur_effective = ios;
 					position_initiale = 0;
 					presence_indicateur = d_faux;
+				}
+				else if (ios > 0)
+				{
+					// On retire une trame du buffer.
 
-					do
+					if ((*((struct_socket *) (*s_objet_argument_1).objet))
+							.domaine == PF_UNIX)
 					{
-						if (tampon_lecture[position_initiale] == '{')
+						do
 						{
-							presence_indicateur = d_vrai;
-							break;
-						}
-
-						position_initiale++;
-					} while(position_initiale < longueur_effective);
-
-					if (presence_indicateur == d_vrai)
+							longueur_adresse = sizeof(adresse_unix);
+							recvfrom((*((struct_socket *)
+									(*s_objet_argument_1).objet)).socket,
+									tampon_lecture, longueur_effective,
+									0, (struct sockaddr *)
+									&adresse_unix, &longueur_adresse);
+						} while((ios == -1) && (errno == EINTR));
+					}
+					else if ((*((struct_socket *) (*s_objet_argument_1)
+							.objet)).domaine == PF_INET)
 					{
-						position_finale = position_initiale + 1;
-						presence_chaine = d_faux;
-						presence_indicateur = d_faux;
-						niveau = 1;
-
-						while(position_finale < longueur_effective)
+						do
 						{
-							caractere = tampon_lecture[position_finale];
-
-							if (caractere == '"')
-							{
-								if (position_finale > 0)
-								{
-									if (tampon_lecture[position_finale - 1]
-											!= '\\')
-									{
-										presence_chaine = (presence_chaine ==
-												d_vrai) ? d_faux : d_vrai;
-									}
-								}
-								else
-								{
-									presence_chaine =
-											(presence_chaine == d_vrai)
-											? d_faux : d_vrai;
-								}
-							}
-							else
-							{
-								if (presence_chaine == d_faux)
-								{
-									if (caractere == '{')
-									{
-										niveau++;
-									}
-									else if (caractere == '}')
-									{
-										niveau--;
-									}
-								}
-							}
-
-							if (niveau == 0)
-							{
-								presence_indicateur = d_vrai;
-								trame_complete = d_vrai;
-								break;
-							}
-
-							position_finale++;
-						}
+							longueur_adresse = sizeof(adresse_ipv4);
+							recvfrom((*((struct_socket *)
+									(*s_objet_argument_1).objet)).socket,
+									tampon_lecture, longueur_effective,
+									0, (struct sockaddr *)
+									&adresse_ipv4, &longueur_adresse);
+						} while((ios == -1) && (errno == EINTR));
 					}
-
-					// On retire une trame du buffer.
-
-					if (trame_complete == d_vrai)
+					else if ((*((struct_socket *) (*s_objet_argument_1)
+							.objet)) .domaine == PF_INET6)
 					{
-						if ((*((struct_socket *) (*s_objet_argument_1).objet))
-								.domaine == PF_UNIX)
+#						ifdef IPV6
+						do
 						{
-							do
-							{
-								longueur_adresse = sizeof(adresse_unix);
-								recvfrom((*((struct_socket *)
-										(*s_objet_argument_1).objet)).socket,
-										tampon_lecture, longueur_effective,
-										0, (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_ipv6);
+							recvfrom((*((struct_socket *)
+									(*s_objet_argument_1).objet)).socket,
+									tampon_lecture, longueur_effective,
+									0, (struct sockaddr *)
+									&adresse_ipv6, &longueur_adresse);
+						} while((ios == -1) && (errno == EINTR));
+#						else
+						if ((*s_etat_processus).langue == 'F')
 						{
-							do
-							{
-								longueur_adresse = sizeof(adresse_ipv4);
-								recvfrom((*((struct_socket *)
-										(*s_objet_argument_1).objet)).socket,
-										tampon_lecture, longueur_effective,
-										0, (struct sockaddr *)
-										&adresse_ipv4, &longueur_adresse);
-							} while((ios == -1) && (errno == EINTR));
+							printf("+++Attention : Support du protocole"
+									" IPv6 indisponible\n");
 						}
-						else if ((*((struct_socket *) (*s_objet_argument_1)
-								.objet)) .domaine == PF_INET6)
+						else
 						{
-#							ifdef IPV6
-							do
-							{
-								longueur_adresse = sizeof(adresse_ipv6);
-								recvfrom((*((struct_socket *)
-										(*s_objet_argument_1).objet)).socket,
-										tampon_lecture, longueur_effective,
-										0, (struct sockaddr *)
-										&adresse_ipv6, &longueur_adresse);
-							} while((ios == -1) && (errno == EINTR));
-#							else
-							if ((*s_etat_processus).langue == 'F')
-							{
-								printf("+++Attention : Support du protocole"
-										" IPv6 indisponible\n");
-							}
-							else
-							{
-								printf("+++Warning : IPv6 support "
-										"unavailable\n");
-							}
-
-#							endif
+							printf("+++Warning : IPv6 support "
+									"unavailable\n");
 						}
-
-						longueur_effective = ios;
+#						endif
 					}
-					else
-					{
-						// Installation d'un timeout pour sortir de
-						// l'instruction dans le cas où la transmission serait
-						// invalide et que la trame reçue serait erronée.
-
-						poll_fd.fd = (*((struct_socket *)
-								(*s_objet_argument_1).objet)).socket;
-						poll_fd.events = POLLIN;
-
-						while((ios = poll(&poll_fd, 1, 10000)) <= 0)
-						{
-							// La fin de la trame n'est pas atteinte.
 
-							switch(ios)
-							{
-								case EINTR:
-								{
-									if ((*s_etat_processus)
-											.var_volatile_requete_arret == -1)
-									{
-										liberation(s_etat_processus,
-												s_objet_argument_1);
-										free(tampon_lecture);
-										return;
-									}
-
-									break;
-								}
-
-								case 0:
-								{
-									liberation(s_etat_processus,
-											s_objet_argument_1);
-									free(tampon_lecture);
-
-									(*s_etat_processus).erreur_execution =
-											d_ex_fin_de_fichier_atteinte;
-									return;
-								}
-							}
-						}
-					}
+					longueur_effective = ios;
+					trame_complete = d_vrai;
 				}
 
 #				ifndef SEMAPHORES_NOMMES
@@ -3208,57 +3100,18 @@ instruction_read(struct_processus *s_eta
 				}
 			} while(trame_complete == d_faux);
 
-			tampon_lecture[++position_finale] = d_code_fin_chaine;
-			tampon = (*s_etat_processus).instruction_courante;
-			(*s_etat_processus).instruction_courante = tampon_lecture;
-
-			indicateur_48 = test_cfsf(s_etat_processus, 48);
-			cf(s_etat_processus, 48);
-
-			recherche_type(s_etat_processus);
-
-			if ((*s_etat_processus).erreur_execution != d_ex)
-			{
-				(*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;
-			}
-
-			if (indicateur_48 == d_vrai)
-			{
-				sf(s_etat_processus, 48);
-			}
-			else
-			{
-				cf(s_etat_processus, 48);
-			}
-
-			(*s_etat_processus).instruction_courante = tampon;
-
 			/*
 			 * Création de la liste de sortie
 			 */
 
-			if (depilement(s_etat_processus, &((*s_etat_processus).l_base_pile),
-					&s_objet_type) == d_erreur)
+			ptr = tampon_lecture;
+
+			if ((s_objet_type = lecture_fichier_non_formate(s_etat_processus,
+					&ptr, longueur_effective, d_faux)) == NULL)
 			{
-				(*s_etat_processus).erreur_execution = d_ex_manque_argument;
+				free(tampon_lecture);
+
+				(*s_etat_processus).erreur_execution = d_ex_syntaxe;
 				return;
 			}