--- rpl/src/instructions_w1.c	2019/02/12 14:38:43	1.117
+++ rpl/src/instructions_w1.c	2025/04/15 10:17:56	1.132
@@ -1,7 +1,7 @@
 /*
 ================================================================================
-  RPL/2 (R) version 4.1.31
-  Copyright (C) 1989-2019 Dr. BERTRAND Joël
+  RPL/2 (R) version 4.1.36
+  Copyright (C) 1989-2025 Dr. BERTRAND Joël
 
   This file is part of RPL/2.
 
@@ -20,6 +20,7 @@
 */
 
 
+#define DEBUG_ERREURS
 #include "rpl-conv.h"
 
 
@@ -1361,10 +1362,9 @@ instruction_write(struct_processus *s_et
 					return;
 				}
 
-				if (fwrite(chaine, sizeof(unsigned char),
-						(size_t) longueur_effective,
-						(*descripteur).descripteur_c) !=
-						(size_t) longueur_effective)
+				if (write(fileno((*descripteur).descripteur_c),
+						chaine, (size_t) longueur_effective) !=
+						(ssize_t) longueur_effective)
 				{
 					(*s_etat_processus).erreur_systeme = d_es_erreur_fichier;
 					return;
@@ -1411,6 +1411,54 @@ instruction_write(struct_processus *s_et
 
 					return;
 				}
+
+				if ((chaine_utf8 = transliteration(s_etat_processus,
+						chaine, d_locale, "UTF-8")) == NULL)
+				{
+					free(chaine);
+
+					liberation(s_etat_processus, s_objet_argument_2);
+					liberation(s_etat_processus, s_objet_argument_1);
+
+					return;
+				}
+
+				free(chaine);
+
+				if (alsprintf(s_etat_processus, &commande,
+						"insert or replace into data "
+						"(id, data) values (%lld, '%s')", (*((integer8 *)
+						(*s_objet_argument_2).objet)), chaine_utf8) < 0)
+				{
+					(*s_etat_processus).erreur_systeme =
+							d_es_allocation_memoire;
+					return;
+				}
+
+				free(chaine_utf8);
+
+				if (sqlite3_prepare_v2((*descripteur).descripteur_sqlite,
+						commande, (int) 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;
+				}
+
+				liberation(s_etat_processus, s_objet_argument_3);
+				free(commande);
 			}
 			else // Fichiers indexés
 			{
@@ -1584,10 +1632,9 @@ instruction_write(struct_processus *s_et
 					if ((format_degenere == d_vrai) ||
 							(longueur_effective < longueur))
 					{
-						if (fwrite(chaine, sizeof(unsigned char),
-								(size_t) longueur_effective,
-								(*descripteur).descripteur_c) !=
-								(size_t) longueur_effective)
+						if (write(fileno((*descripteur).descripteur_c),
+								chaine, (size_t) longueur_effective)
+								!= (ssize_t) longueur_effective)
 						{
 							(*s_etat_processus).erreur_systeme =
 									d_es_erreur_fichier;
@@ -1596,10 +1643,9 @@ instruction_write(struct_processus *s_et
 					}
 					else
 					{
-						if (fwrite(chaine, sizeof(unsigned char),
-								(size_t) longueur_effective,
-								(*descripteur).descripteur_c) !=
-								(size_t) longueur)
+						if (write(fileno((*descripteur).descripteur_c),
+								chaine, (size_t) longueur_effective)
+								!= (ssize_t) longueur)
 						{
 							(*s_etat_processus).erreur_systeme =
 									d_es_erreur_fichier;
@@ -1611,8 +1657,8 @@ instruction_write(struct_processus *s_et
 
 					if (format_oriente_ligne == d_vrai)
 					{
-						if (fwrite("\n", 1, 1, (*descripteur).descripteur_c)
-								!= 1)
+						if (write(fileno((*descripteur).descripteur_c),
+								"\n", 1) != 1)
 						{
 							(*s_etat_processus).erreur_systeme =
 									d_es_erreur_fichier;
@@ -2328,29 +2374,6 @@ instruction_wflock(struct_processus *s_e
 				return;
 			}
 
-#			ifndef SEMAPHORES_NOMMES
-				if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
-#			else
-				if (sem_post((*s_etat_processus).semaphore_fork) != 0)
-#			endif
-			{
-				(*s_etat_processus).erreur_systeme = d_es_processus;
-				return;
-			}
-
-#			ifndef SEMAPHORES_NOMMES
-				while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0)
-#			else
-				while(sem_wait((*s_etat_processus).semaphore_fork) != 0)
-#			endif
-			{
-				if (errno != EINTR)
-				{
-					(*s_etat_processus).erreur_systeme = d_es_processus;
-					return;
-				}
-			}
-
 			if (lock.l_type == F_UNLCK)
 			{
 				drapeau = d_vrai;
@@ -2386,10 +2409,34 @@ instruction_wflock(struct_processus *s_e
 							registre_instruction_valide;
 				}
 
-				nanosleep(&attente, NULL);
 				scrutation_injection(s_etat_processus);
 
+#				ifndef SEMAPHORES_NOMMES
+					if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
+#				else
+					if (sem_post((*s_etat_processus).semaphore_fork) != 0)
+#				endif
+				{
+					(*s_etat_processus).erreur_systeme = d_es_processus;
+					return;
+				}
+
+				nanosleep(&attente, NULL);
+
 				INCR_GRANULARITE(attente.tv_nsec);
+
+#				ifndef SEMAPHORES_NOMMES
+					while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0)
+#				else
+					while(sem_wait((*s_etat_processus).semaphore_fork) != 0)
+#				endif
+				{
+					if (errno != EINTR)
+					{
+						(*s_etat_processus).erreur_systeme = d_es_processus;
+						return;
+					}
+				}
 			}
 		} while((drapeau == d_faux) && ((*s_etat_processus)
 				.var_volatile_requete_arret != -1));
@@ -3104,12 +3151,10 @@ instruction_wfdata(struct_processus *s_e
 static inline logical1
 options_sockets(struct_processus *s_etat_processus, struct_socket *s_socket)
 {
-	int							drapeau;
-
 	if (((*s_socket).options & (1 << d_BROADCAST)) != 0)
 	{
-		if (setsockopt((*s_socket).socket, SOL_SOCKET, SO_BROADCAST, &drapeau,
-				sizeof(drapeau)) != 0)
+		if (setsockopt((*s_socket).socket, SOL_SOCKET, SO_BROADCAST, NULL, 0)
+				!= 0)
 		{
 			return(d_erreur);
 		}
@@ -3117,8 +3162,8 @@ options_sockets(struct_processus *s_etat
 
 	if (((*s_socket).options & (1 << d_DONT_ROUTE)) != 0)
 	{
-		if (setsockopt((*s_socket).socket, SOL_SOCKET, SO_DONTROUTE, &drapeau,
-				sizeof(drapeau)) != 0)
+		if (setsockopt((*s_socket).socket, SOL_SOCKET, SO_DONTROUTE, NULL, 0)
+				!= 0)
 		{
 			return(d_erreur);
 		}
@@ -3126,8 +3171,8 @@ options_sockets(struct_processus *s_etat
 
 	if (((*s_socket).options & (1 << d_KEEP_ALIVE)) != 0)
 	{
-		if (setsockopt((*s_socket).socket, SOL_SOCKET, SO_KEEPALIVE, &drapeau,
-				sizeof(drapeau)) != 0)
+		if (setsockopt((*s_socket).socket, SOL_SOCKET, SO_KEEPALIVE, NULL, 0)
+				!= 0)
 		{
 			return(d_erreur);
 		}
@@ -3284,7 +3329,7 @@ instruction_wfsock(struct_processus *s_e
 				(*s_objet_argument).objet)).type, "SEQUENTIAL DATAGRAM") != 0))
 		{
 			// Mode non connecté : l'attente se fait sur un poll()
-
+#define DEBUG_RETURN
 			if ((s_objet_resultat = copie_objet(s_etat_processus,
 					s_objet_argument, 'P')) == NULL)
 			{
@@ -3928,7 +3973,30 @@ instruction_wfswi(struct_processus *s_et
 			}
 			else
 			{
+#				ifndef SEMAPHORES_NOMMES
+					if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
+#				else
+					if (sem_post((*s_etat_processus).semaphore_fork) != 0)
+#				endif
+				{
+					(*s_etat_processus).erreur_systeme = d_es_processus;
+					return;
+				}
 				nanosleep(&attente, NULL);
+
+#				ifndef SEMAPHORES_NOMMES
+					while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0)
+#				else
+					while(sem_wait((*s_etat_processus).semaphore_fork) != 0)
+#				endif
+				{
+					if (errno != EINTR)
+					{
+						(*s_etat_processus).erreur_systeme = d_es_processus;
+						return;
+					}
+				}
+
 				scrutation_injection(s_etat_processus);
 				INCR_GRANULARITE(attente.tv_nsec);
 			}