--- rpl/src/instructions_w1.c	2016/03/16 12:19:34	1.104
+++ rpl/src/instructions_w1.c	2021/12/09 22:44:59	1.123
@@ -1,7 +1,7 @@
 /*
 ================================================================================
-  RPL/2 (R) version 4.1.25
-  Copyright (C) 1989-2016 Dr. BERTRAND Joël
+  RPL/2 (R) version 4.1.33
+  Copyright (C) 1989-2021 Dr. BERTRAND Joël
 
   This file is part of RPL/2.
 
@@ -410,9 +410,9 @@ instruction_write(struct_processus *s_et
 	integer8							recursivite;
 
 	logical1							format_degenere;
+	logical1							format_oriente_ligne;
 	logical1							mise_a_jour;
 
-
 	sqlite3_stmt						*ppStmt;
 
 	ssize_t								ios;
@@ -1361,10 +1361,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;
@@ -1507,44 +1506,30 @@ instruction_write(struct_processus *s_et
 						return;
 					}
 
-					if (strncmp("LENGTH*(", format_chaine, 8) != 0)
+					if (strcmp("LINE*(*)", format_chaine) == 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;
+						format_oriente_ligne = d_vrai;
+						format_degenere = d_vrai;
 					}
-
-					longueur = (integer8) strlen(format_chaine);
-
-					if (format_chaine[longueur - 1] != ')')
+					else
 					{
-						free(format_chaine);
-
-						liberation(s_etat_processus, s_objet_argument_2);
-						liberation(s_etat_processus, s_objet_argument_1);
+						format_oriente_ligne = d_faux;
+						
+						if (strncmp("LENGTH*(", format_chaine, 8) != 0)
+						{
+							free(format_chaine);
 
-						(*s_etat_processus).erreur_execution =
-								d_ex_erreur_format_fichier;
-						return;
-					}
+							liberation(s_etat_processus, s_objet_argument_2);
+							liberation(s_etat_processus, s_objet_argument_1);
 
-					format_chaine[longueur] = d_code_fin_chaine;
+							(*s_etat_processus).erreur_execution =
+									d_ex_erreur_format_fichier;
+							return;
+						}
 
-					if (format_chaine[8] == '*')
-					{
-						format_degenere = d_vrai;
-					}
-					else
-					{
-						// Détermination de la longueur
-						format_degenere = d_faux;
+						longueur = (integer8) strlen(format_chaine);
 
-						if (sscanf(&(format_chaine[8]), "%lld", &longueur) != 1)
+						if (format_chaine[longueur - 1] != ')')
 						{
 							free(format_chaine);
 
@@ -1555,6 +1540,33 @@ instruction_write(struct_processus *s_et
 									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]), "%lld", &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);
@@ -1571,10 +1583,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;
@@ -1583,10 +1594,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;
@@ -1596,6 +1606,17 @@ instruction_write(struct_processus *s_et
 
 					free(chaine);
 
+					if (format_oriente_ligne == d_vrai)
+					{
+						if (write(fileno((*descripteur).descripteur_c),
+								"\n", 1) != 1)
+						{
+							(*s_etat_processus).erreur_systeme =
+									d_es_erreur_fichier;
+							return;
+						}
+					}
+
 					l_element_courant = (*l_element_courant).suivant;
 					l_element_courant_format = (*l_element_courant_format)
 							.suivant;
@@ -1708,32 +1729,32 @@ instruction_write(struct_processus *s_et
 				(*s_objet_argument_1).objet)).type,
 				"SEQUENTIAL DATAGRAM") == 0))
 		{ // Sockets connectées
-
-			action.sa_handler = SIG_IGN;
-			action.sa_flags = SA_ONSTACK;
-
-			if (sigaction(SIGPIPE, &action, &registre) != 0)
-			{
-				(*s_etat_processus).erreur_systeme = d_es_signal;
-				return;
-			}
-
 #			ifndef SEMAPHORES_NOMMES
 				if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
 #			else
 				if (sem_post((*s_etat_processus).semaphore_fork) != 0)
 #			endif
 			{
-				if (sigaction(SIGPIPE, &registre, NULL) != 0)
-				{
-					(*s_etat_processus).erreur_systeme = d_es_signal;
-					return;
-				}
+				(*s_etat_processus).erreur_systeme = d_es_processus;
+				return;
+			}
 
+			if (pthread_mutex_lock(&mutex_sigaction) != 0)
+			{
 				(*s_etat_processus).erreur_systeme = d_es_processus;
 				return;
 			}
 
+			action.sa_handler = SIG_IGN;
+			action.sa_flags = 0;
+
+			if (sigaction(SIGPIPE, &action, &registre) != 0)
+			{
+				pthread_mutex_unlock(&mutex_sigaction);
+				(*s_etat_processus).erreur_systeme = d_es_signal;
+				return;
+			}
+
 			if (send((*((struct_socket *) (*s_objet_argument_1).objet))
 					.socket, chaine, (size_t) longueur_effective, 0) < 0)
 			{
@@ -1741,10 +1762,17 @@ instruction_write(struct_processus *s_et
 
 				if (sigaction(SIGPIPE, &registre, NULL) != 0)
 				{
+					pthread_mutex_unlock(&mutex_sigaction);
 					(*s_etat_processus).erreur_systeme = d_es_signal;
 					return;
 				}
 
+				if (pthread_mutex_unlock(&mutex_sigaction) != 0)
+				{
+					(*s_etat_processus).erreur_systeme = d_es_processus;
+					return;
+				}
+
 #				ifndef SEMAPHORES_NOMMES
 					while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0)
 #				else
@@ -1769,6 +1797,41 @@ instruction_write(struct_processus *s_et
 				return;
 			}
 
+			if (sigaction(SIGPIPE, &registre, NULL) != 0)
+			{
+				pthread_mutex_unlock(&mutex_sigaction);
+
+#				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)
+					{
+						if (sigaction(SIGPIPE, &registre, NULL) != 0)
+						{
+							pthread_mutex_unlock(&mutex_sigaction);
+							(*s_etat_processus).erreur_systeme = d_es_signal;
+							return;
+						}
+
+						pthread_mutex_unlock(&mutex_sigaction);
+						(*s_etat_processus).erreur_systeme = d_es_processus;
+						return;
+					}
+				}
+
+				(*s_etat_processus).erreur_systeme = d_es_signal;
+				return;
+			}
+
+			if (pthread_mutex_unlock(&mutex_sigaction) != 0)
+			{
+				(*s_etat_processus).erreur_systeme = d_es_processus;
+				return;
+			}
+
 #			ifndef SEMAPHORES_NOMMES
 				while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0)
 #			else
@@ -1787,12 +1850,6 @@ instruction_write(struct_processus *s_et
 					return;
 				}
 			}
-
-			if (sigaction(SIGPIPE, &registre, NULL) != 0)
-			{
-				(*s_etat_processus).erreur_systeme = d_es_signal;
-				return;
-			}
 		}
 		else
 		{ // Sockets non connectées
@@ -2268,29 +2325,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;
@@ -2326,10 +2360,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));
@@ -3044,12 +3102,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);
 		}
@@ -3057,8 +3113,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);
 		}
@@ -3066,8 +3122,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);
 		}
@@ -3177,8 +3233,6 @@ instruction_wfsock(struct_processus *s_e
 	struct sockaddr_in6		adresse_ipv6;
 #	endif
 
-	unsigned long			i;
-
 	if ((*s_etat_processus).affichage_arguments == 'Y')
 	{
 		printf("\n  WFSOCK ");
@@ -3542,7 +3596,7 @@ instruction_wfsock(struct_processus *s_e
 				} while(drapeau == d_faux);
 
 				if (((*((struct_socket *) (*s_objet_resultat).objet))
-						.adresse_distante = malloc(55 *
+						.adresse_distante = malloc(47 *
 						sizeof(unsigned char))) == NULL)
 				{
 					(*s_etat_processus).erreur_systeme =
@@ -3550,22 +3604,26 @@ instruction_wfsock(struct_processus *s_e
 					return;
 				}
 
-				(*((struct_socket *) (*s_objet_resultat).objet))
-						.adresse_distante = d_code_fin_chaine;
-
-				for(i = 0; i < 16; i++)
-				{
-					sprintf((*((struct_socket *) (*s_objet_resultat)
-							.objet)).adresse_distante, (i == 0) ? "%s%X"
-							: "%s:%X", (*((struct_socket *) (*s_objet_resultat)
-							.objet)).adresse_distante,
-							adresse_ipv6.sin6_addr.s6_addr[i]);
-				}
-
 				sprintf((*((struct_socket *) (*s_objet_resultat)
-						.objet)).adresse_distante, "%s(%u)",
-						(*((struct_socket *) (*s_objet_resultat)
 						.objet)).adresse_distante,
+						"%02X%02X:%02X%02X:%02X%02X:%02X%02X:"
+						"%02X%02X:%02X%02X:%02X%02X:%02X%02X(%u)",
+						adresse_ipv6.sin6_addr.s6_addr[0],
+						adresse_ipv6.sin6_addr.s6_addr[1],
+						adresse_ipv6.sin6_addr.s6_addr[2],
+						adresse_ipv6.sin6_addr.s6_addr[3],
+						adresse_ipv6.sin6_addr.s6_addr[4],
+						adresse_ipv6.sin6_addr.s6_addr[5],
+						adresse_ipv6.sin6_addr.s6_addr[6],
+						adresse_ipv6.sin6_addr.s6_addr[7],
+						adresse_ipv6.sin6_addr.s6_addr[8],
+						adresse_ipv6.sin6_addr.s6_addr[9],
+						adresse_ipv6.sin6_addr.s6_addr[10],
+						adresse_ipv6.sin6_addr.s6_addr[11],
+						adresse_ipv6.sin6_addr.s6_addr[12],
+						adresse_ipv6.sin6_addr.s6_addr[13],
+						adresse_ipv6.sin6_addr.s6_addr[14],
+						adresse_ipv6.sin6_addr.s6_addr[15],
 						ntohs(adresse_ipv6.sin6_port));
 #			else
 				if ((*s_etat_processus).langue == 'F')
@@ -3866,7 +3924,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);
 			}