--- rpl/src/gestion_processus.c	2011/06/21 15:26:29	1.38
+++ rpl/src/gestion_processus.c	2013/03/21 16:34:08	1.64
@@ -1,7 +1,7 @@
 /*
 ================================================================================
-  RPL/2 (R) version 4.1.0.prerelease.2
-  Copyright (C) 1989-2011 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.
 
@@ -40,7 +40,6 @@
 void *
 surveillance_processus(void *argument)
 {
-	int								iostat;
 	int								status;
 
 	integer8						nombre_donnees;
@@ -57,8 +56,7 @@ surveillance_processus(void *argument)
 
 	pthread_t						tid_candidat;
 
-	sigset_t						masque;
-
+	ssize_t							iostat;
 	ssize_t							longueur_ecriture;
 
 	struct_descripteur_thread		*s_argument_thread;
@@ -72,18 +70,13 @@ surveillance_processus(void *argument)
 
 	unsigned char					caractere;
 
-	unsigned int					tampon_erreur_execution;
-	unsigned int					tampon_erreur_systeme;
+	int								tampon_erreur_execution;
+	int								tampon_erreur_systeme;
+
+	sigset_t						set;
 
-	sigemptyset(&masque);
-	sigaddset(&masque, SIGINJECT);
-	sigaddset(&masque, SIGFSTOP);
-	sigaddset(&masque, SIGFABORT);
-	sigaddset(&masque, SIGURG);
-	sigaddset(&masque, SIGALRM);
-	sigaddset(&masque, SIGCONT);
-	sigaddset(&masque, SIGINT);
-	pthread_sigmask(SIG_BLOCK, &masque, NULL);
+	sigfillset(&set);
+	pthread_sigmask(SIG_BLOCK, &set, NULL);
 
 	s_argument_thread = argument;
 	s_etat_processus = (*s_argument_thread).s_etat_processus;
@@ -344,8 +337,8 @@ surveillance_processus(void *argument)
 									d_es_processus;
 						}
 
-						pthread_kill((*s_argument_thread).thread_pere,
-								SIGINJECT);
+						envoi_signal_thread((*s_argument_thread).thread_pere,
+								rpl_siginject);
 					}
 				}
 				else
@@ -530,8 +523,8 @@ surveillance_processus(void *argument)
 									d_es_processus;
 						}
 
-						pthread_kill((*s_argument_thread).thread_pere,
-								SIGINJECT);
+						envoi_signal_thread((*s_argument_thread).thread_pere,
+								rpl_siginject);
 					}
 				}
 				else
@@ -926,8 +919,8 @@ surveillance_processus(void *argument)
 									d_es_processus;
 						}
 
-						pthread_kill((*s_argument_thread).thread_pere,
-								SIGINJECT);
+						envoi_signal_thread((*s_argument_thread).thread_pere,
+								rpl_siginject);
 					}
 				}
 				else
@@ -1867,8 +1860,8 @@ ecriture_pipe(struct_processus *s_etat_p
 
 	struct timespec					attente;
 
-	unsigned long					i;
-	unsigned long					j;
+	integer8						i;
+	integer8						j;
 
 	size_t							longueur;
 	ssize_t							longueur_ecriture;
@@ -1998,7 +1991,7 @@ ecriture_pipe(struct_processus *s_etat_p
 
 		while((longueur_ecriture = write_atomic(s_etat_processus, pipe,
 				&((*((struct_vecteur *) (*s_objet).objet))
-				.taille), sizeof(unsigned long))) != sizeof(unsigned long))
+				.taille), sizeof(integer8))) != sizeof(integer8))
 		{
 			if (longueur_ecriture == -1)
 			{
@@ -2051,7 +2044,7 @@ ecriture_pipe(struct_processus *s_etat_p
 
 		while((longueur_ecriture = write_atomic(s_etat_processus, pipe,
 				&((*((struct_vecteur *) (*s_objet).objet))
-				.taille), sizeof(unsigned long))) != sizeof(unsigned long))
+				.taille), sizeof(integer8))) != sizeof(integer8))
 		{
 			if (longueur_ecriture == -1)
 			{
@@ -2104,7 +2097,7 @@ ecriture_pipe(struct_processus *s_etat_p
 
 		while((longueur_ecriture = write_atomic(s_etat_processus, pipe,
 				&((*((struct_vecteur *) (*s_objet).objet))
-				.taille), sizeof(unsigned long))) != sizeof(unsigned long))
+				.taille), sizeof(integer8))) != sizeof(integer8))
 		{
 			if (longueur_ecriture == -1)
 			{
@@ -2157,7 +2150,7 @@ ecriture_pipe(struct_processus *s_etat_p
 
 		while((longueur_ecriture = write_atomic(s_etat_processus, pipe,
 				&((*((struct_matrice *) (*s_objet).objet)).nombre_lignes),
-				sizeof(unsigned long))) != sizeof(unsigned long))
+				sizeof(integer8))) != sizeof(integer8))
 		{
 			if (longueur_ecriture == -1)
 			{
@@ -2173,7 +2166,7 @@ ecriture_pipe(struct_processus *s_etat_p
 
 		while((longueur_ecriture = write_atomic(s_etat_processus, pipe,
 				&((*((struct_matrice *) (*s_objet).objet)).nombre_colonnes),
-				sizeof(unsigned long))) != sizeof(unsigned long))
+				sizeof(integer8))) != sizeof(integer8))
 		{
 			if (longueur_ecriture == -1)
 			{
@@ -2232,7 +2225,7 @@ ecriture_pipe(struct_processus *s_etat_p
 
 		while((longueur_ecriture = write_atomic(s_etat_processus, pipe,
 				&((*((struct_matrice *) (*s_objet).objet)).nombre_lignes),
-				sizeof(unsigned long))) != sizeof(unsigned long))
+				sizeof(integer8))) != sizeof(integer8))
 		{
 			if (longueur_ecriture == -1)
 			{
@@ -2248,7 +2241,7 @@ ecriture_pipe(struct_processus *s_etat_p
 
 		while((longueur_ecriture = write_atomic(s_etat_processus, pipe,
 				&((*((struct_matrice *) (*s_objet).objet)).nombre_colonnes),
-				sizeof(unsigned long))) != sizeof(unsigned long))
+				sizeof(integer8))) != sizeof(integer8))
 		{
 			if (longueur_ecriture == -1)
 			{
@@ -2307,7 +2300,7 @@ ecriture_pipe(struct_processus *s_etat_p
 
 		while((longueur_ecriture = write_atomic(s_etat_processus, pipe,
 				&((*((struct_matrice *) (*s_objet).objet)).nombre_lignes),
-				sizeof(unsigned long))) != sizeof(unsigned long))
+				sizeof(integer8))) != sizeof(integer8))
 		{
 			if (longueur_ecriture == -1)
 			{
@@ -2323,7 +2316,7 @@ ecriture_pipe(struct_processus *s_etat_p
 
 		while((longueur_ecriture = write_atomic(s_etat_processus, pipe,
 				&((*((struct_matrice *) (*s_objet).objet)).nombre_colonnes),
-				sizeof(unsigned long))) != sizeof(unsigned long))
+				sizeof(integer8))) != sizeof(integer8))
 		{
 			if (longueur_ecriture == -1)
 			{
@@ -2517,7 +2510,7 @@ ecriture_pipe(struct_processus *s_etat_p
 
 		while((longueur_ecriture = write_atomic(s_etat_processus, pipe,
 				&((*((struct_fonction *) (*s_objet).objet)).nombre_arguments),
-				sizeof(unsigned long))) != sizeof(unsigned long))
+				sizeof(integer8))) != sizeof(integer8))
 		{
 			if (longueur_ecriture == -1)
 			{
@@ -2659,7 +2652,7 @@ ecriture_pipe(struct_processus *s_etat_p
 
 		while((longueur_ecriture = write_atomic(s_etat_processus, pipe,
 				&((*((struct_tableau *) (*s_objet).objet)).nombre_elements),
-				sizeof(unsigned long))) != sizeof(unsigned long))
+				sizeof(integer8))) != sizeof(integer8))
 		{
 			if (longueur_ecriture == -1)
 			{
@@ -2715,8 +2708,8 @@ lecture_pipe(struct_processus *s_etat_pr
 
 	struct timespec			attente;
 
-	unsigned long			i;
-	unsigned long			j;
+	integer8				i;
+	integer8				j;
 
 	if ((s_objet = allocation(s_etat_processus, NON)) == NULL)
 	{
@@ -2803,15 +2796,15 @@ lecture_pipe(struct_processus *s_etat_pr
 
 		while(read_atomic(s_etat_processus, pipe, &((*((struct_vecteur *)
 				(*s_objet).objet)).taille),
-				sizeof(unsigned long)) != sizeof(unsigned long))
+				sizeof(integer8)) != sizeof(integer8))
 		{
 			nanosleep(&attente, NULL);
 			INCR_GRANULARITE(attente.tv_nsec);
 		}
 
 		if (((*((struct_vecteur *) (*s_objet).objet)).tableau =
-				malloc((*((struct_vecteur *) (*s_objet).objet)).taille *
-				sizeof(integer8))) == NULL)
+				malloc(((size_t) (*((struct_vecteur *) (*s_objet).objet))
+				.taille) * sizeof(integer8))) == NULL)
 		{
 			(*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
 			return(NULL);
@@ -2847,15 +2840,15 @@ lecture_pipe(struct_processus *s_etat_pr
 
 		while(read_atomic(s_etat_processus, pipe, &((*((struct_vecteur *)
 				(*s_objet).objet)).taille),
-				sizeof(unsigned long)) != sizeof(unsigned long))
+				sizeof(integer8)) != sizeof(integer8))
 		{
 			nanosleep(&attente, NULL);
 			INCR_GRANULARITE(attente.tv_nsec);
 		}
 
 		if (((*((struct_vecteur *) (*s_objet).objet)).tableau =
-				malloc((*((struct_vecteur *) (*s_objet).objet)).taille *
-				sizeof(real8))) == NULL)
+				malloc(((size_t) (*((struct_vecteur *) (*s_objet).objet))
+				.taille) * sizeof(real8))) == NULL)
 		{
 			(*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
 			return(NULL);
@@ -2891,15 +2884,15 @@ lecture_pipe(struct_processus *s_etat_pr
 
 		while(read_atomic(s_etat_processus, pipe, &((*((struct_vecteur *)
 				(*s_objet).objet)).taille),
-				sizeof(unsigned long)) != sizeof(unsigned long))
+				sizeof(integer8)) != sizeof(integer8))
 		{
 			nanosleep(&attente, NULL);
 			INCR_GRANULARITE(attente.tv_nsec);
 		}
 
 		if (((*((struct_vecteur *) (*s_objet).objet)).tableau =
-				malloc((*((struct_vecteur *) (*s_objet).objet)).taille *
-				sizeof(complex16))) == NULL)
+				malloc(((size_t) (*((struct_vecteur *) (*s_objet).objet))
+				.taille) * sizeof(complex16))) == NULL)
 		{
 			(*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
 			return(NULL);
@@ -2935,7 +2928,7 @@ lecture_pipe(struct_processus *s_etat_pr
 
 		while(read_atomic(s_etat_processus, pipe, &((*((struct_matrice *)
 				(*s_objet).objet)).nombre_lignes),
-				sizeof(unsigned long)) != sizeof(unsigned long))
+				sizeof(integer8)) != sizeof(integer8))
 		{
 			nanosleep(&attente, NULL);
 			INCR_GRANULARITE(attente.tv_nsec);
@@ -2946,15 +2939,15 @@ lecture_pipe(struct_processus *s_etat_pr
 
 		while(read_atomic(s_etat_processus, pipe, &((*((struct_matrice *)
 				(*s_objet).objet)).nombre_colonnes),
-				sizeof(unsigned long)) != sizeof(unsigned long))
+				sizeof(integer8)) != sizeof(integer8))
 		{
 			nanosleep(&attente, NULL);
 			INCR_GRANULARITE(attente.tv_nsec);
 		}
 
 		if (((*((struct_matrice *) (*s_objet).objet)).tableau =
-				malloc((*((struct_matrice *) (*s_objet).objet)).nombre_lignes *
-				sizeof(integer8 *))) == NULL)
+				malloc(((size_t) (*((struct_matrice *) (*s_objet).objet))
+				.nombre_lignes) * sizeof(integer8 *))) == NULL)
 		{
 			(*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
 			return(NULL);
@@ -2964,8 +2957,8 @@ lecture_pipe(struct_processus *s_etat_pr
 				(*s_objet).objet)).nombre_lignes; i++)
 		{
 			if ((((*((struct_matrice *) (*s_objet).objet)).tableau)[i] =
-					malloc((*((struct_matrice *) (*s_objet).objet))
-					.nombre_colonnes * sizeof(integer8))) == NULL)
+					malloc(((size_t) (*((struct_matrice *) (*s_objet).objet))
+					.nombre_colonnes) * sizeof(integer8))) == NULL)
 			{
 				(*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
 				return(NULL);
@@ -3003,7 +2996,7 @@ lecture_pipe(struct_processus *s_etat_pr
 
 		while(read_atomic(s_etat_processus, pipe, &((*((struct_matrice *)
 				(*s_objet).objet)).nombre_lignes),
-				sizeof(unsigned long)) != sizeof(unsigned long))
+				sizeof(integer8)) != sizeof(integer8))
 		{
 			nanosleep(&attente, NULL);
 			INCR_GRANULARITE(attente.tv_nsec);
@@ -3014,15 +3007,15 @@ lecture_pipe(struct_processus *s_etat_pr
 
 		while(read_atomic(s_etat_processus, pipe, &((*((struct_matrice *)
 				(*s_objet).objet)).nombre_colonnes),
-				sizeof(unsigned long)) != sizeof(unsigned long))
+				sizeof(integer8)) != sizeof(integer8))
 		{
 			nanosleep(&attente, NULL);
 			INCR_GRANULARITE(attente.tv_nsec);
 		}
 
 		if (((*((struct_matrice *) (*s_objet).objet)).tableau =
-				malloc((*((struct_matrice *) (*s_objet).objet)).nombre_lignes *
-				sizeof(real8 *))) == NULL)
+				malloc(((size_t) (*((struct_matrice *) (*s_objet).objet))
+				.nombre_lignes) * sizeof(real8 *))) == NULL)
 		{
 			(*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
 			return(NULL);
@@ -3032,8 +3025,8 @@ lecture_pipe(struct_processus *s_etat_pr
 				(*s_objet).objet)).nombre_lignes; i++)
 		{
 			if ((((*((struct_matrice *) (*s_objet).objet)).tableau)[i] =
-					malloc((*((struct_matrice *) (*s_objet).objet))
-					.nombre_colonnes * sizeof(real8))) == NULL)
+					malloc(((size_t) (*((struct_matrice *) (*s_objet).objet))
+					.nombre_colonnes) * sizeof(real8))) == NULL)
 			{
 				(*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
 				return(NULL);
@@ -3071,7 +3064,7 @@ lecture_pipe(struct_processus *s_etat_pr
 
 		while(read_atomic(s_etat_processus, pipe, &((*((struct_matrice *)
 				(*s_objet).objet)).nombre_lignes),
-				sizeof(unsigned long)) != sizeof(unsigned long))
+				sizeof(integer8)) != sizeof(integer8))
 		{
 			nanosleep(&attente, NULL);
 			INCR_GRANULARITE(attente.tv_nsec);
@@ -3082,15 +3075,15 @@ lecture_pipe(struct_processus *s_etat_pr
 
 		while(read_atomic(s_etat_processus, pipe, &((*((struct_matrice *)
 				(*s_objet).objet)).nombre_colonnes),
-				sizeof(unsigned long)) != sizeof(unsigned long))
+				sizeof(integer8)) != sizeof(integer8))
 		{
 			nanosleep(&attente, NULL);
 			INCR_GRANULARITE(attente.tv_nsec);
 		}
 
 		if (((*((struct_matrice *) (*s_objet).objet)).tableau =
-				malloc((*((struct_matrice *) (*s_objet).objet)).nombre_lignes *
-				sizeof(complex16 *))) == NULL)
+				malloc(((size_t) (*((struct_matrice *) (*s_objet).objet))
+				.nombre_lignes) * sizeof(complex16 *))) == NULL)
 		{
 			(*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
 			return(NULL);
@@ -3100,8 +3093,8 @@ lecture_pipe(struct_processus *s_etat_pr
 				(*s_objet).objet)).nombre_lignes; i++)
 		{
 			if ((((*((struct_matrice *) (*s_objet).objet)).tableau)[i] =
-					malloc((*((struct_matrice *) (*s_objet).objet))
-					.nombre_colonnes * sizeof(complex16))) == NULL)
+					malloc(((size_t) (*((struct_matrice *) (*s_objet).objet))
+					.nombre_colonnes) * sizeof(complex16))) == NULL)
 			{
 				(*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
 				return(NULL);
@@ -3229,8 +3222,8 @@ lecture_pipe(struct_processus *s_etat_pr
 
 		while(read_atomic(s_etat_processus, pipe,
 				&((*((struct_fonction *) (*s_objet).objet))
-				.nombre_arguments), sizeof(unsigned long)) !=
-				sizeof(unsigned long))
+				.nombre_arguments), sizeof(integer8)) !=
+				sizeof(integer8))
 		{
 			nanosleep(&attente, NULL);
 			INCR_GRANULARITE(attente.tv_nsec);
@@ -3350,15 +3343,15 @@ lecture_pipe(struct_processus *s_etat_pr
 
 		while(read_atomic(s_etat_processus, pipe, &((*((struct_tableau *)
 				(*s_objet).objet)).nombre_elements),
-				sizeof(unsigned long)) != sizeof(unsigned long))
+				sizeof(integer8)) != sizeof(integer8))
 		{
 			nanosleep(&attente, NULL);
 			INCR_GRANULARITE(attente.tv_nsec);
 		}
 
 		if (((*((struct_tableau *) (*s_objet).objet)).elements = malloc(
-				(*((struct_tableau *) (*s_objet).objet)).nombre_elements *
-				sizeof(struct_objet *))) == NULL)
+				((size_t) (*((struct_tableau *) (*s_objet).objet))
+				.nombre_elements) * sizeof(struct_objet *))) == NULL)
 		{
 			(*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
 			return(NULL);
@@ -3408,7 +3401,7 @@ scrutation_injection(struct_processus *s
 	logical1						drapeau_erreur;
 	logical1						registre_arret_si_exception;
 
-#	if !defined(OpenBSD) && !defined(OS2)
+#	ifdef PSELECT
 		struct timespec				timeout;
 #	else
 		struct timeval				timeout;
@@ -3419,13 +3412,15 @@ scrutation_injection(struct_processus *s
 
 	// Si on est dans le processus père, il n'y a rien à surveiller.
 
+	scrutation_interruptions(s_etat_processus);
+
 	if ((*s_etat_processus).var_volatile_processus_racine == 0)
 	{
 		FD_ZERO(&ensemble_descripteurs);
 		FD_SET((*s_etat_processus).pipe_nombre_injections,
 				&ensemble_descripteurs);
 
-#		if !defined(OpenBSD) && !defined(OS2)
+#		ifdef PSELECT
 		timeout.tv_sec = 0;
 		timeout.tv_nsec = 0;