--- rpl/src/instructions_r4.c	2013/03/20 22:24:37	1.76
+++ rpl/src/instructions_r4.c	2013/09/26 15:38:38	1.83
@@ -1,6 +1,6 @@
 /*
 ================================================================================
-  RPL/2 (R) version 4.1.13
+  RPL/2 (R) version 4.1.16
   Copyright (C) 1989-2013 Dr. BERTRAND Joël
 
   This file is part of RPL/2.
@@ -855,6 +855,8 @@ instruction_read(struct_processus *s_eta
 	integer8						i;
 	integer8						id;
 	integer8						position_clef;
+	integer8						longueur;
+
 	integer8						longueur_effective;
 	integer8						longueur_enregistrement;
 	integer8						longueur_questure;
@@ -863,14 +865,13 @@ instruction_read(struct_processus *s_eta
 	integer8						position_finale;
 	integer8						position_initiale;
 
+	logical1						device;
 	logical1						format_degenere;
 	logical1						indicateur_48;
 	logical1						presence_chaine;
 	logical1						presence_indicateur;
 	logical1						trame_complete;
 
-	long							longueur;
-
 	socklen_t						longueur_adresse;
 
 	sqlite3_stmt					*ppStmt;
@@ -883,8 +884,6 @@ instruction_read(struct_processus *s_eta
 	struct sockaddr_in6				adresse_ipv6;
 #	endif
 
-	struct pollfd					poll_fd;
-
 	struct timespec					attente;
 
 	struct_descripteur_fichier		*descripteur;
@@ -1111,7 +1110,7 @@ instruction_read(struct_processus *s_eta
 				presence_chaine = d_faux;
 				niveau = 1;
 
-				if (fseek((*descripteur).descripteur_c, position_finale,
+				if (fseek((*descripteur).descripteur_c, (long) position_finale,
 						SEEK_SET) != 0)
 				{
 					liberation(s_etat_processus, s_objet_argument_1);
@@ -1201,8 +1200,8 @@ instruction_read(struct_processus *s_eta
 					return;
 				}
 
-				if (fseek((*descripteur).descripteur_c, position_initiale,
-						SEEK_SET) != 0)
+				if (fseek((*descripteur).descripteur_c,
+						(long) position_initiale, SEEK_SET) != 0)
 				{
 					liberation(s_etat_processus, s_objet_argument_1);
 					free(tampon_lecture);
@@ -1975,12 +1974,21 @@ instruction_read(struct_processus *s_eta
 
 				BUG(((*descripteur).type != 'C'), uprintf("Bad filtype !\n"));
 				longueur_enregistrement = 0;
+				device = d_faux;
 
 				if ((position_initiale = ftell((*descripteur).descripteur_c))
 						== -1)
 				{
-					(*s_etat_processus).erreur_systeme = d_es_erreur_fichier;
-					return;
+					if (errno == ESPIPE)
+					{
+						device = d_vrai;
+					}
+					else
+					{
+						(*s_etat_processus).erreur_systeme =
+								d_es_erreur_fichier;
+						return;
+					}
 				}
 
 				l_element_courant_format = (struct_liste_chainee *)
@@ -2052,7 +2060,7 @@ instruction_read(struct_processus *s_eta
 						// Détermination de la longueur
 						format_degenere = d_faux;
 
-						if (sscanf(&(format_chaine[8]), "%ld", &longueur) != 1)
+						if (sscanf(&(format_chaine[8]), "%lld", &longueur) != 1)
 						{
 							liberation(s_etat_processus, s_objet_argument_1);
 							liberation(s_etat_processus, s_objet_resultat);
@@ -2074,15 +2082,19 @@ instruction_read(struct_processus *s_eta
 							longueur_enregistrement++;
 						} while((c != '\n') && (c != EOF));
 
-						if (fseek((*descripteur).descripteur_c,
-								position_initiale, SEEK_SET) != 0)
+						if (device == d_faux)
 						{
-							liberation(s_etat_processus, s_objet_argument_1);
-							liberation(s_etat_processus, s_objet_resultat);
+							if (fseek((*descripteur).descripteur_c,
+									(long) position_initiale, SEEK_SET) != 0)
+							{
+								liberation(s_etat_processus,
+										s_objet_argument_1);
+								liberation(s_etat_processus, s_objet_resultat);
 
-							(*s_etat_processus).erreur_systeme =
-									d_es_erreur_fichier;
-							return;
+								(*s_etat_processus).erreur_systeme =
+										d_es_erreur_fichier;
+								return;
+							}
 						}
 					}
 					else
@@ -2498,45 +2510,74 @@ instruction_read(struct_processus *s_eta
 					}
 					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;
+						// Si on a lu toute une trame et qu'on n'a pas
+						// réussi à en trouver la structure, on remonte
+						// une erreur de syntaxe.
 
-						while((ios = poll(&poll_fd, 1, 10000)) <= 0)
+						if (longueur_effective == ios)
 						{
-							// La fin de la trame n'est pas atteinte.
-
-							switch(ios)
+							if ((*((struct_socket *) (*s_objet_argument_1)
+									.objet)).domaine == PF_UNIX)
 							{
-								case EINTR:
+								do
 								{
-									if ((*s_etat_processus)
-											.var_volatile_requete_arret == -1)
-									{
-										liberation(s_etat_processus,
-												s_objet_argument_1);
-										free(tampon_lecture);
-										return;
-									}
-
-									break;
+									longueur_adresse = sizeof(adresse_unix);
+									recvfrom((*((struct_socket *)
+											(*s_objet_argument_1).objet))
+											.socket, tampon_lecture,
+											(size_t) 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)
+							{
+								do
+								{
+									longueur_adresse = sizeof(adresse_ipv4);
+									recvfrom((*((struct_socket *)
+											(*s_objet_argument_1).objet))
+											.socket, tampon_lecture,
+											(size_t) longueur_effective,
+											0, (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
+								do
+								{
+									longueur_adresse = sizeof(adresse_ipv6);
+									recvfrom((*((struct_socket *)
+											(*s_objet_argument_1).objet))
+											.socket, tampon_lecture,
+											(size_t) 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");
 								}
-
-								case 0:
+								else
 								{
-									liberation(s_etat_processus,
-											s_objet_argument_1);
-									free(tampon_lecture);
-
-									(*s_etat_processus).erreur_execution =
-											d_ex_fin_de_fichier_atteinte;
-									return;
+									printf("+++Warning : IPv6 support "
+											"unavailable\n");
 								}
+
+#								endif
 							}
+
+							liberation(s_etat_processus, s_objet_argument_1);
+							free(tampon_lecture);
+
+							(*s_etat_processus).erreur_execution = d_ex_syntaxe;
+							return;
 						}
 					}
 				}