--- rpl/src/instructions_s10.c	2012/12/17 21:22:44	1.64
+++ rpl/src/instructions_s10.c	2020/01/10 11:15:48	1.105
@@ -1,7 +1,7 @@
 /*
 ================================================================================
-  RPL/2 (R) version 4.1.11
-  Copyright (C) 1989-2012 Dr. BERTRAND Joël
+  RPL/2 (R) version 4.1.32
+  Copyright (C) 1989-2020 Dr. BERTRAND Joël
 
   This file is part of RPL/2.
 
@@ -38,6 +38,8 @@
 void
 instruction_spawn(struct_processus *s_etat_processus)
 {
+	int							ios;
+
 	logical1					drapeau;
 	logical1					variable_partagee;
 
@@ -233,7 +235,7 @@ instruction_spawn(struct_processus *s_et
 		return;
 	}
 
-	if (pipe((*s_argument_thread).pipe_nombre_interruptions_attente) != 0)
+	if (pipe((*s_argument_thread).pipe_nombre_elements_attente) != 0)
 	{
 		(*s_etat_processus).erreur_systeme = d_es_processus;
 		return;
@@ -251,12 +253,6 @@ instruction_spawn(struct_processus *s_et
 		return;
 	}
 
-	if (pipe((*s_argument_thread).pipe_nombre_objets_attente) != 0)
-	{
-		(*s_etat_processus).erreur_systeme = d_es_processus;
-		return;
-	}
-
 	if (pipe((*s_argument_thread).pipe_injections) != 0)
 	{
 		(*s_etat_processus).erreur_systeme = d_es_processus;
@@ -293,12 +289,10 @@ instruction_spawn(struct_processus *s_et
 
 	(*s_nouvel_etat_processus).pipe_donnees =
 			(*s_argument_thread).pipe_objets[1];
-	(*s_nouvel_etat_processus).pipe_nombre_objets_attente =
-			(*s_argument_thread).pipe_nombre_objets_attente[1];
+	(*s_nouvel_etat_processus).pipe_nombre_elements_attente =
+			(*s_argument_thread).pipe_nombre_elements_attente[1];
 	(*s_nouvel_etat_processus).pipe_interruptions =
 			(*s_argument_thread).pipe_interruptions[1];
-	(*s_nouvel_etat_processus).pipe_nombre_interruptions_attente =
-			(*s_argument_thread).pipe_nombre_interruptions_attente[1];
 	(*s_nouvel_etat_processus).pipe_injections =
 			(*s_argument_thread).pipe_injections[0];
 	(*s_nouvel_etat_processus).pipe_nombre_injections =
@@ -407,13 +401,62 @@ instruction_spawn(struct_processus *s_et
 	attente.tv_sec = 0;
 	attente.tv_nsec = GRANULARITE_us * 1000;
 
+	if (pthread_mutex_lock(&((*s_argument_thread).mutex)) != 0)
+	{
+		(*s_etat_processus).erreur_systeme = d_es_processus;
+		return;
+	}
+
 	while((*s_argument_thread).thread_actif == d_faux)
 	{
 		scrutation_interruptions(s_etat_processus);
+
+		if (pthread_mutex_unlock(&((*s_argument_thread).mutex)) != 0)
+		{
+			(*s_etat_processus).erreur_systeme = d_es_processus;
+			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;
+		}
+
 		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;
+			}
+		}
+
+		if (pthread_mutex_lock(&((*s_argument_thread).mutex)) != 0)
+		{
+			(*s_etat_processus).erreur_systeme = d_es_processus;
+			return;
+		}
+
 		INCR_GRANULARITE(attente.tv_nsec);
 	}
 
+	if (pthread_mutex_unlock(&((*s_argument_thread).mutex)) != 0)
+	{
+		(*s_etat_processus).erreur_systeme = d_es_processus;
+		return;
+	}
+
 	if (pthread_attr_destroy(&attributs) != 0)
 	{
 		(*s_etat_processus).erreur_systeme = d_es_processus;
@@ -471,11 +514,34 @@ instruction_spawn(struct_processus *s_et
 		return;
 	}
 
-	if (pthread_mutex_lock(&((*s_etat_processus).mutex)) != 0)
+	attente.tv_sec = 0;
+	attente.tv_nsec = GRANULARITE_us * 1000;
+
+	while((ios = pthread_mutex_trylock(&((*s_etat_processus)
+			.mutex_pile_processus))) != 0)
 	{
-		pthread_mutex_unlock(&((*s_nouvel_etat_processus).mutex));
-		(*s_etat_processus).erreur_systeme = d_es_processus;
-		return;
+		if (ios != EBUSY)
+		{
+			(*s_etat_processus).erreur_systeme = d_es_processus;
+		}
+
+		if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
+		{
+			(*s_etat_processus).erreur_systeme = d_es_processus;
+			return;
+		}
+
+		nanosleep(&attente, NULL);
+		INCR_GRANULARITE(attente.tv_nsec);
+
+		while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0)
+		{
+			if (errno != EINTR)
+			{
+				(*s_etat_processus).erreur_systeme = d_es_processus;
+				return;
+			}
+		}
 	}
 
 	// Si le tid existe déjà  dans la pile des processus, il s'agit forcement
@@ -502,29 +568,49 @@ instruction_spawn(struct_processus *s_et
 						(*(*l_element_courant).donnee).objet)).thread)
 						.tid, (*s_argument_thread).tid) != 0)
 				{
-					if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
+					scrutation_injection(s_etat_processus);
+
+					if (pthread_mutex_lock(&((*s_etat_processus)
+							.mutex_interruptions)) != 0)
 					{
+						pthread_mutex_unlock(&((*s_etat_processus)
+								.mutex_pile_processus));
 						(*s_etat_processus).erreur_systeme = d_es_processus;
 						return;
 					}
 
-					scrutation_injection(s_etat_processus);
-
 					if ((*s_etat_processus).nombre_interruptions_non_affectees
 							!= 0)
 					{
 						affectation_interruptions_logicielles(s_etat_processus);
 					}
 
+					if (pthread_mutex_unlock(&((*s_etat_processus)
+							.mutex_interruptions)) != 0)
+					{
+						pthread_mutex_unlock(&((*s_etat_processus)
+								.mutex_pile_processus));
+						(*s_etat_processus).erreur_systeme = d_es_processus;
+						return;
+					}
+
 					if ((*s_etat_processus).nombre_interruptions_en_queue != 0)
 					{
 						traitement_interruptions_logicielles(s_etat_processus);
 					}
 
+					if (pthread_mutex_unlock(&((*s_etat_processus)
+							.mutex_pile_processus)) != 0)
+					{
+						(*s_etat_processus).erreur_systeme = d_es_processus;
+						return;
+					}
+
 					nanosleep(&attente, NULL);
 					INCR_GRANULARITE(attente.tv_nsec);
 
-					if (pthread_mutex_lock(&((*s_etat_processus).mutex)) != 0)
+					if (pthread_mutex_lock(&((*s_etat_processus)
+							.mutex_pile_processus)) != 0)
 					{
 						(*s_etat_processus).erreur_systeme = d_es_processus;
 						return;
@@ -544,11 +630,11 @@ instruction_spawn(struct_processus *s_et
 			(struct_liste_chainee **) &((*s_etat_processus)
 			.l_base_pile_processus), s_objet_systeme) == d_erreur)
 	{
-		pthread_mutex_unlock(&((*s_etat_processus).mutex));
+		pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus));
 		return;
 	}
 
-	if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
+	if (pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus)) != 0)
 	{
 		(*s_etat_processus).erreur_systeme = d_es_processus;
 		return;
@@ -599,7 +685,8 @@ instruction_spawn(struct_processus *s_et
 
 	// Le fils peut être présent sans être en attente du signal de départ.
 
-	if (envoi_signal_thread((*s_argument_thread).tid, rpl_sigstart) != 0)
+	if (envoi_signal_thread(s_etat_processus,
+			(*s_argument_thread).tid, rpl_sigstart) != 0)
 	{
 		(*s_etat_processus).erreur_systeme = d_es_processus;
 		return;
@@ -657,6 +744,7 @@ instruction_sqlconnect(struct_processus
 
 		printf("    { \"mysql\" \"server\" \"database\" "
 				"\"user\" \"password\" } SQLCONNECT\n");
+		printf("    { \"sqlite\" \"file\" } SQLCONNECT\n");
 		printf("    { \"postgresql:iso-8859-1\" \"server\" "
 				"\"database\" \"user\" \"password\" port }\n");
 	   	printf("          SQLCONNECT\n");
@@ -889,6 +977,21 @@ instruction_sqldisconnect(struct_process
 					drapeau = d_faux;
 #					endif
 				}
+				else if (strcmp((*((struct_connecteur_sql *) (*s_objet).objet))
+						.type, "SQLITE") == 0)
+				{
+					if ((*((struct_connecteur_sql *) (*(*l_element_courant)
+							.donnee).objet)).descripteur.sqlite ==
+							(*((struct_connecteur_sql *) (*s_objet).objet))
+							.descripteur.sqlite)
+					{
+						drapeau = d_vrai;
+					}
+					else
+					{
+						drapeau = d_faux;
+					}
+				}
 				else
 				{
 					BUG(1, printf("SQL type '%s' not allowed!",
@@ -1260,7 +1363,8 @@ instruction_smphrtrydecr(struct_processu
 				return;
 			}
 
-			horodatage.tv_sec += (*((integer8 *) (*s_objet_argument_1).objet));
+			horodatage.tv_sec += (time_t) (*((integer8 *)
+					(*s_objet_argument_1).objet));
 		}
 		else
 		{
@@ -1274,7 +1378,7 @@ instruction_smphrtrydecr(struct_processu
 			}
 
 			partie_entiere = floor((*((real8 *) (*s_objet_argument_1).objet)));
-			horodatage.tv_sec += partie_entiere;
+			horodatage.tv_sec += (time_t) partie_entiere;
 			horodatage.tv_usec += ((suseconds_t) ((*((real8 *)
 					(*s_objet_argument_1).objet)) - partie_entiere)) * 1000000;
 
@@ -1631,8 +1735,8 @@ instruction_svd(struct_processus *s_etat
 
 	struct_vecteur				s_vecteur;
 
-	unsigned long				i;
-	unsigned long				j;
+	integer8					i;
+	integer8					j;
 
 	(*s_etat_processus).erreur_execution = d_ex;
 
@@ -1724,8 +1828,8 @@ instruction_svd(struct_processus *s_etat
 				.nombre_lignes;
 
 		if (((*((struct_matrice *) (*s_objet_resultat_2).objet)).tableau =
-				malloc((*((struct_matrice *) (*s_objet_resultat_2).objet))
-				.nombre_lignes * sizeof(real8 *))) == NULL)
+				malloc(((size_t) (*((struct_matrice *) (*s_objet_resultat_2)
+				.objet)).nombre_lignes) * sizeof(real8 *))) == NULL)
 		{
 			(*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
 			return;
@@ -1735,9 +1839,9 @@ instruction_svd(struct_processus *s_etat
 				.nombre_lignes; i++)
 		{
 			if ((((real8 **) (*((struct_matrice *) (*s_objet_resultat_2)
-					.objet)).tableau)[i] = malloc((*((struct_matrice *)
-					(*s_objet_resultat_2).objet)).nombre_colonnes *
-					sizeof(real8 *))) == NULL)
+					.objet)).tableau)[i] = malloc(((size_t)
+					(*((struct_matrice *) (*s_objet_resultat_2).objet))
+					.nombre_colonnes) * sizeof(real8 *))) == NULL)
 			{
 				(*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
 				return;
@@ -1824,8 +1928,8 @@ instruction_svd(struct_processus *s_etat
 				.nombre_lignes;
 
 		if (((*((struct_matrice *) (*s_objet_resultat_2).objet)).tableau =
-				malloc((*((struct_matrice *) (*s_objet_resultat_2).objet))
-				.nombre_lignes * sizeof(real8 *))) == NULL)
+				malloc(((size_t) (*((struct_matrice *) (*s_objet_resultat_2)
+				.objet)).nombre_lignes) * sizeof(real8 *))) == NULL)
 		{
 			(*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
 			return;
@@ -1835,9 +1939,9 @@ instruction_svd(struct_processus *s_etat
 				.nombre_lignes; i++)
 		{
 			if ((((real8 **) (*((struct_matrice *) (*s_objet_resultat_2)
-					.objet)).tableau)[i] = malloc((*((struct_matrice *)
-					(*s_objet_resultat_2).objet)).nombre_colonnes *
-					sizeof(real8 *))) == NULL)
+					.objet)).tableau)[i] = malloc(((size_t)
+					(*((struct_matrice *) (*s_objet_resultat_2).objet))
+					.nombre_colonnes) * sizeof(real8 *))) == NULL)
 			{
 				(*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
 				return;