--- rpl/src/instructions_w1.c	2012/04/13 14:13:01	1.60
+++ rpl/src/instructions_w1.c	2013/02/27 17:11:44	1.72
@@ -1,7 +1,7 @@
 /*
 ================================================================================
-  RPL/2 (R) version 4.1.8
-  Copyright (C) 1989-2012 Dr. BERTRAND Joël
+  RPL/2 (R) version 4.1.13
+  Copyright (C) 1989-2013 Dr. BERTRAND Joël
 
   This file is part of RPL/2.
 
@@ -385,14 +385,17 @@ instruction_write(struct_processus *s_et
 
 	int									adresse[16];
 	int									port;
+	int									sqlite_status;
 
 	integer8							clef;
 	integer8							compteur;
 	integer8							id;
 	integer8							ordre;
 
+	logical1							format_degenere;
 	logical1							mise_a_jour;
 
+	long								longueur;
 	long								longueur_effective;
 	long								recursivite;
 
@@ -422,12 +425,15 @@ instruction_write(struct_processus *s_et
 
 	struct flock						lock;
 
+	struct timespec						attente;
+
 	uint32_t							calcul_adresse;
 
 	unsigned char						*chaine;
 	unsigned char						*chaine_utf8;
 	unsigned char						*clef_utf8;
 	unsigned char						*commande;
+	unsigned char						*format_chaine;
 
 	unsigned long						i;
 
@@ -757,11 +763,30 @@ instruction_write(struct_processus *s_et
 					return;
 				}
 
-				if (sqlite3_step(ppStmt) != SQLITE_ROW)
+				attente.tv_sec = 0;
+				attente.tv_nsec = GRANULARITE_us * 1000;
+
+				do
 				{
-					(*s_etat_processus).erreur_systeme = d_es_erreur_fichier;
-					return;
-				}
+					sqlite_status = sqlite3_step(ppStmt);
+
+					if (sqlite_status == SQLITE_ROW)
+					{
+						break;
+					}
+					else if ((sqlite_status == SQLITE_BUSY) ||
+							(sqlite_status == SQLITE_LOCKED))
+					{
+						nanosleep(&attente, NULL);
+						INCR_GRANULARITE(attente.tv_nsec);
+					}
+					else
+					{
+						(*s_etat_processus).erreur_systeme =
+								d_es_erreur_fichier;
+						return;
+					}
+				} while(sqlite_status != SQLITE_ROW);
 
 				if (sqlite3_column_type(ppStmt, 0) != SQLITE_INTEGER)
 				{
@@ -914,100 +939,107 @@ instruction_write(struct_processus *s_et
 					return;
 				}
 
-				switch(sqlite3_step(ppStmt))
-				{
-					case SQLITE_ROW:
-					{
-						// Une clef existe.
-
-						mise_a_jour = d_vrai;
-						break;
-					}
+				attente.tv_sec = 0;
+				attente.tv_nsec = GRANULARITE_us * 1000;
 
-					case SQLITE_DONE:
+				do
+				{
+					switch(sqlite_status = sqlite3_step(ppStmt))
 					{
-						// Aucune clef n'existe.
-
-						mise_a_jour = d_faux;
-
-						if (sqlite3_finalize(ppStmt) != SQLITE_OK)
-						{
-							(*s_etat_processus).erreur_systeme =
-									d_es_erreur_fichier;
-							return;
-						}
-
-						free(commande);
-
-						if (alsprintf(&commande, "insert into key "
-								"(key) values ('%s')", clef_utf8) < 0)
+						case SQLITE_ROW:
 						{
-							(*s_etat_processus).erreur_systeme =
-									d_es_allocation_memoire;
-							return;
-						}
+							// Une clef existe.
 
-						if (sqlite3_prepare_v2((*descripteur)
-								.descripteur_sqlite,
-								commande, strlen(commande), &ppStmt, &queue)
-								!= SQLITE_OK)
-						{
-							(*s_etat_processus).erreur_systeme =
-									d_es_erreur_fichier;
-							return;
+							mise_a_jour = d_vrai;
+							break;
 						}
 
-						if (sqlite3_step(ppStmt) != SQLITE_DONE)
+						case SQLITE_DONE:
 						{
-							(*s_etat_processus).erreur_systeme =
-									d_es_erreur_fichier;
-							return;
-						}
+							// Aucune clef n'existe.
 
-						if (sqlite3_finalize(ppStmt) != SQLITE_OK)
-						{
-							(*s_etat_processus).erreur_systeme =
-									d_es_erreur_fichier;
-							return;
-						}
+							mise_a_jour = d_faux;
 
-						free(commande);
+							if (sqlite3_finalize(ppStmt) != SQLITE_OK)
+							{
+								(*s_etat_processus).erreur_systeme =
+										d_es_erreur_fichier;
+								return;
+							}
+
+							free(commande);
+
+							if (alsprintf(&commande, "insert into key "
+									"(key) values ('%s')", clef_utf8) < 0)
+							{
+								(*s_etat_processus).erreur_systeme =
+										d_es_allocation_memoire;
+								return;
+							}
+
+							if (sqlite3_prepare_v2((*descripteur)
+									.descripteur_sqlite,
+									commande, strlen(commande), &ppStmt, &queue)
+									!= SQLITE_OK)
+							{
+								(*s_etat_processus).erreur_systeme =
+										d_es_erreur_fichier;
+								return;
+							}
+
+							if (sqlite3_step(ppStmt) != SQLITE_DONE)
+							{
+								(*s_etat_processus).erreur_systeme =
+										d_es_erreur_fichier;
+								return;
+							}
+
+							if (sqlite3_finalize(ppStmt) != SQLITE_OK)
+							{
+								(*s_etat_processus).erreur_systeme =
+										d_es_erreur_fichier;
+								return;
+							}
+
+							free(commande);
+
+							if (alsprintf(&commande, "select id from key "
+									"where key = '%s'", clef_utf8) < 0)
+							{
+								(*s_etat_processus).erreur_systeme =
+										d_es_allocation_memoire;
+								return;
+							}
+
+							if (sqlite3_prepare_v2((*descripteur)
+									.descripteur_sqlite,
+									commande, strlen(commande), &ppStmt, &queue)
+									!= SQLITE_OK)
+							{
+								(*s_etat_processus).erreur_systeme =
+										d_es_erreur_fichier;
+								return;
+							}
 
-						if (alsprintf(&commande, "select id from key "
-								"where key = '%s'", clef_utf8) < 0)
-						{
-							(*s_etat_processus).erreur_systeme =
-									d_es_allocation_memoire;
-							return;
+							break;
 						}
 
-						if (sqlite3_prepare_v2((*descripteur)
-								.descripteur_sqlite,
-								commande, strlen(commande), &ppStmt, &queue)
-								!= SQLITE_OK)
+						case SQLITE_BUSY:
+						case SQLITE_LOCKED:
 						{
-							(*s_etat_processus).erreur_systeme =
-									d_es_erreur_fichier;
-							return;
+							nanosleep(&attente, NULL);
+							INCR_GRANULARITE(attente.tv_nsec);
+							break;
 						}
 
-						if (sqlite3_step(ppStmt) != SQLITE_ROW)
+						default:
 						{
 							(*s_etat_processus).erreur_systeme =
 									d_es_erreur_fichier;
 							return;
 						}
-
-						break;
-					}
-
-					default:
-					{
-						(*s_etat_processus).erreur_systeme =
-								d_es_erreur_fichier;
-						return;
 					}
-				}
+				} while(sqlite_status != SQLITE_ROW);
 
 				if (sqlite3_column_type(ppStmt, 0) != SQLITE_INTEGER)
 				{
@@ -1349,35 +1381,147 @@ instruction_write(struct_processus *s_et
 					return;
 				}
 
-				if ((*((*((struct_liste_chainee *) (*s_objet_argument_2).objet))
-						.donnee)).type != CHN)
+				l_element_courant = (*s_objet_argument_2).objet;
+				l_element_courant_format = (struct_liste_chainee *)
+						(*(*((struct_fichier *) (*s_objet_argument_1).objet))
+						.format).objet;
+
+				while((l_element_courant != NULL) &&
+						(l_element_courant_format != NULL))
 				{
-					liberation(s_etat_processus, s_objet_argument_2);
-					liberation(s_etat_processus, s_objet_argument_1);
+					if ((*(*l_element_courant).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;
-				}
+						(*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 ((*(*l_element_courant_format).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 ((format_chaine = conversion_majuscule((unsigned char *)
+							(*(*l_element_courant_format).donnee).objet))
+							== NULL)
+					{
+						(*s_etat_processus).erreur_systeme =
+								d_es_allocation_memoire;
+						return;
+					}
+
+					if (strncmp("LENGTH*(", format_chaine, 8) != 0)
+					{
+						free(format_chaine);
+
+						liberation(s_etat_processus, s_objet_argument_2);
+						liberation(s_etat_processus, s_objet_argument_1);
+
+						(*s_etat_processus).erreur_execution =
+								d_ex_erreur_format_fichier;
+						return;
+					}
+
+					longueur = strlen(format_chaine);
+
+					if (format_chaine[longueur - 1] != ')')
+					{
+						free(format_chaine);
+
+						liberation(s_etat_processus, s_objet_argument_2);
+						liberation(s_etat_processus, s_objet_argument_1);
+
+						(*s_etat_processus).erreur_execution =
+								d_ex_erreur_format_fichier;
+						return;
+					}
+
+					format_chaine[longueur] = d_code_fin_chaine;
+
+					if (format_chaine[8] == '*')
+					{
+						format_degenere = d_vrai;
+					}
+					else
+					{
+						// Détermination de la longueur
+						format_degenere = d_faux;
+
+						if (sscanf(&(format_chaine[8]), "%ld", &longueur) != 1)
+						{
+							free(format_chaine);
+
+							liberation(s_etat_processus, s_objet_argument_2);
+							liberation(s_etat_processus, s_objet_argument_1);
+
+							(*s_etat_processus).erreur_execution =
+									d_ex_erreur_format_fichier;
+							return;
+						}
+					}
+
+					free(format_chaine);
+
+					if ((chaine = formateur_flux(s_etat_processus,
+							(unsigned char *) (*(*l_element_courant).donnee)
+							.objet, &longueur_effective)) == NULL)
+					{
+						(*s_etat_processus).erreur_systeme =
+								d_es_allocation_memoire;
+						return;
+					}
+
+					if ((format_degenere == d_vrai) ||
+							(longueur_effective < longueur))
+					{
+						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;
+						}
+					}
+					else
+					{
+						if (fwrite(chaine, sizeof(unsigned char),
+								longueur_effective,
+								(*descripteur).descripteur_c) !=
+								(size_t) longueur)
+						{
+							(*s_etat_processus).erreur_systeme =
+									d_es_erreur_fichier;
+							return;
+						}
+					}
+
+					free(chaine);
+
+					l_element_courant = (*l_element_courant).suivant;
+					l_element_courant_format = (*l_element_courant_format)
+							.suivant;
 				}
 
-				if (fwrite(chaine, sizeof(unsigned char), longueur_effective,
-						(*descripteur).descripteur_c) !=
-						(size_t) longueur_effective)
+				if ((l_element_courant_format != NULL) ||
+						(l_element_courant != NULL))
 				{
-					(*s_etat_processus).erreur_systeme = d_es_erreur_fichier;
+					liberation(s_etat_processus, s_objet_argument_2);
+					liberation(s_etat_processus, s_objet_argument_1);
+
+					(*s_etat_processus).erreur_execution =
+							d_ex_erreur_format_fichier;
 					return;
 				}
-
-				free(chaine);
 			}
 			else
 			{