--- rpl/src/interruptions.c	2010/05/24 10:58:36	1.18
+++ rpl/src/interruptions.c	2010/08/13 21:00:37	1.29
@@ -1,6 +1,6 @@
 /*
 ================================================================================
-  RPL/2 (R) version 4.0.16
+  RPL/2 (R) version 4.0.18
   Copyright (C) 1989-2010 Dr. BERTRAND Joël
 
   This file is part of RPL/2.
@@ -20,7 +20,7 @@
 */
 
 
-#include "rpl.conv.h"
+#include "rpl-conv.h"
 
 
 /*
@@ -125,7 +125,6 @@ insertion_thread(struct_processus *s_eta
 	}
 
 	(*l_nouvel_objet).suivant = liste_threads;
-
 	liste_threads = l_nouvel_objet;
 
 #	ifndef SEMAPHORES_NOMMES
@@ -184,6 +183,10 @@ insertion_thread_surveillance(struct_pro
 		}
 	}
 
+	pthread_mutex_lock(&((*s_argument_thread).mutex));
+	(*s_argument_thread).nombre_references++;
+	pthread_mutex_unlock(&((*s_argument_thread).mutex));
+
 	(*l_nouvel_objet).suivant = liste_threads_surveillance;
 	(*l_nouvel_objet).donnee = (void *) s_argument_thread;
 
@@ -448,6 +451,7 @@ retrait_thread_surveillance(struct_proce
 
 	pthread_sigmask(SIG_SETMASK, &oldset, NULL);
 	sigpending(&set);
+
 	return;
 }
 
@@ -669,18 +673,73 @@ liberation_threads(struct_processus *s_e
 					.l_base_pile_processus;
 			while(element_courant != NULL)
 			{
-				pthread_mutex_trylock(&((*(*((struct_liste_chainee *)
-						element_courant)).donnee).mutex));
-				pthread_mutex_unlock(&((*(*((struct_liste_chainee *)
-						element_courant)).donnee).mutex));
-				liberation(s_etat_processus,
-						(*((struct_liste_chainee *) element_courant)).donnee);
+				s_argument_thread = (struct_descripteur_thread *)
+						(*((struct_liste_chainee *) element_courant)).donnee;
+
+				if (pthread_mutex_lock(&((*s_argument_thread).mutex)) != 0)
+				{
+					(*s_etat_processus).erreur_systeme = d_es_processus;
+					sem_post(&semaphore_liste_threads);
+					return;
+				}
+
+				(*s_argument_thread).nombre_references--;
+
+				BUG((*s_argument_thread).nombre_references < 0,
+						printf("(*s_argument_thread).nombre_references = %d\n",
+						(int) (*s_argument_thread).nombre_references));
+
+				if ((*s_argument_thread).nombre_references == 0)
+				{
+					close((*s_argument_thread).pipe_objets[0]);
+					close((*s_argument_thread).pipe_acquittement[1]);
+					close((*s_argument_thread).pipe_injections[1]);
+					close((*s_argument_thread).pipe_nombre_injections[1]);
+					close((*s_argument_thread).pipe_nombre_objets_attente[0]);
+					close((*s_argument_thread).pipe_interruptions[0]);
+					close((*s_argument_thread)
+							.pipe_nombre_interruptions_attente[0]);
+
+					if (pthread_mutex_unlock(&((*s_argument_thread).mutex))
+							!= 0)
+					{
+						(*s_etat_processus).erreur_systeme = d_es_processus;
+						sem_post(&semaphore_liste_threads);
+						return;
+					}
+
+					pthread_mutex_destroy(&((*s_argument_thread).mutex));
+
+					if ((*s_argument_thread).processus_detache == d_faux)
+					{
+						if ((*s_argument_thread).destruction_objet == d_vrai)
+						{
+							liberation(s_etat_processus, (*s_argument_thread)
+									.argument);
+						}
+					}
+
+					free(s_argument_thread);
+				}
+				else
+				{
+					if (pthread_mutex_unlock(&((*s_argument_thread).mutex))
+							!= 0)
+					{
+						(*s_etat_processus).erreur_systeme = d_es_processus;
+						sem_post(&semaphore_liste_threads);
+						return;
+					}
+				}
+
 				element_suivant = (*((struct_liste_chainee *) element_courant))
 						.suivant;
-				free((struct_liste_chainee *) element_courant);
+				free(element_courant);
 				element_courant = element_suivant;
 			}
 
+			(*s_etat_processus).l_base_pile_processus = NULL;
+
 			pthread_mutex_trylock(&((*(*s_etat_processus).indep).mutex));
 			pthread_mutex_unlock(&((*(*s_etat_processus).indep).mutex));
 			liberation(s_etat_processus, (*s_etat_processus).indep);
@@ -1291,14 +1350,6 @@ liberation_threads(struct_processus *s_e
 		s_argument_thread = (struct_descripteur_thread *)
 				(*l_element_courant).donnee;
 
-		close((*s_argument_thread).pipe_objets[0]);
-		close((*s_argument_thread).pipe_acquittement[1]);
-		close((*s_argument_thread).pipe_injections[1]);
-		close((*s_argument_thread).pipe_nombre_injections[1]);
-		close((*s_argument_thread).pipe_nombre_objets_attente[0]);
-		close((*s_argument_thread).pipe_interruptions[0]);
-		close((*s_argument_thread).pipe_nombre_interruptions_attente[0]);
-
 		if (pthread_mutex_lock(&((*s_argument_thread).mutex)) != 0)
 		{
 			(*s_etat_processus).erreur_systeme = d_es_processus;
@@ -1314,6 +1365,14 @@ liberation_threads(struct_processus *s_e
 
 		if ((*s_argument_thread).nombre_references == 0)
 		{
+			close((*s_argument_thread).pipe_objets[0]);
+			close((*s_argument_thread).pipe_acquittement[1]);
+			close((*s_argument_thread).pipe_injections[1]);
+			close((*s_argument_thread).pipe_nombre_injections[1]);
+			close((*s_argument_thread).pipe_nombre_objets_attente[0]);
+			close((*s_argument_thread).pipe_interruptions[0]);
+			close((*s_argument_thread).pipe_nombre_interruptions_attente[0]);
+
 			if (pthread_mutex_unlock(&((*s_argument_thread).mutex)) != 0)
 			{
 				(*s_etat_processus).erreur_systeme = d_es_processus;
@@ -1322,6 +1381,15 @@ liberation_threads(struct_processus *s_e
 			}
 
 			pthread_mutex_destroy(&((*s_argument_thread).mutex));
+
+			if ((*s_argument_thread).processus_detache == d_faux)
+			{
+				if ((*s_argument_thread).destruction_objet == d_vrai)
+				{
+					liberation(s_etat_processus, (*s_argument_thread).argument);
+				}
+			}
+
 			free(s_argument_thread);
 		}
 		else
@@ -1665,6 +1733,10 @@ interruption1(int signal, siginfo_t *sig
 
 	volatile sig_atomic_t	exclusion = 0;
 
+#	ifdef _BROKEN_SIGINFO
+	(*siginfo).si_pid=getpid();
+#	endif
+
 	verrouillage_gestionnaire_signaux();
 
 	switch(signal)
@@ -1800,6 +1872,10 @@ interruption2(int signal, siginfo_t *sig
 	pthread_t				thread;
 	struct_processus		*s_etat_processus;
 
+#	ifdef _BROKEN_SIGINFO
+	(*siginfo).si_pid=getpid();
+#	endif
+
 	verrouillage_gestionnaire_signaux();
 
 	if (siginfo == NULL)
@@ -1873,6 +1949,10 @@ interruption3(int signal, siginfo_t *sig
 
 	static int				compteur = 0;
 
+#	ifdef _BROKEN_SIGINFO
+	(*siginfo).si_pid=getpid();
+#	endif
+
 	verrouillage_gestionnaire_signaux();
 
 	if ((s_etat_processus = recherche_thread(getpid(), pthread_self())) == NULL)
@@ -1931,6 +2011,10 @@ interruption4(int signal, siginfo_t *sig
 {
 	struct_processus		*s_etat_processus;
 
+#	ifdef _BROKEN_SIGINFO
+	(*siginfo).si_pid=getpid();
+#	endif
+
 	verrouillage_gestionnaire_signaux();
 
 	if ((s_etat_processus = recherche_thread(getpid(), pthread_self())) == NULL)
@@ -1960,6 +2044,10 @@ interruption5(int signal, siginfo_t *sig
 	pthread_t				thread;
 	struct_processus		*s_etat_processus;
 
+#	ifdef _BROKEN_SIGINFO
+	(*siginfo).si_pid=getpid();
+#	endif
+
 	verrouillage_gestionnaire_signaux();
 
 	if ((*siginfo).si_pid == getpid())
@@ -2022,6 +2110,10 @@ interruption6(int signal, siginfo_t *sig
 {
 	struct_processus		*s_etat_processus;
 
+#	ifdef _BROKEN_SIGINFO
+	(*siginfo).si_pid=getpid();
+#	endif
+
 	verrouillage_gestionnaire_signaux();
 
 	if ((s_etat_processus = recherche_thread(getpid(), pthread_self())) == NULL)
@@ -2046,6 +2138,10 @@ interruption7(int signal, siginfo_t *sig
 {
 	struct_processus		*s_etat_processus;
 
+#	ifdef _BROKEN_SIGINFO
+	(*siginfo).si_pid=getpid();
+#	endif
+
 	verrouillage_gestionnaire_signaux();
 
 	if ((s_etat_processus = recherche_thread(getpid(), pthread_self())) == NULL)
@@ -2074,6 +2170,10 @@ interruption8(int signal, siginfo_t *sig
 	pthread_t				thread;
 	struct_processus		*s_etat_processus;
 
+#	ifdef _BROKEN_SIGINFO
+	(*siginfo).si_pid=getpid();
+#	endif
+
 	verrouillage_gestionnaire_signaux();
 
 	if ((*siginfo).si_pid == getpid())
@@ -2116,6 +2216,10 @@ interruption9(int signal, siginfo_t *sig
 {
 	struct_processus		*s_etat_processus;
 
+#	ifdef _BROKEN_SIGINFO
+	(*siginfo).si_pid=getpid();
+#	endif
+
 	verrouillage_gestionnaire_signaux();
 
 	if ((s_etat_processus = recherche_thread(getpid(), pthread_self())) == NULL)
@@ -2145,6 +2249,10 @@ interruption10(int signal, siginfo_t *si
 
 	unsigned char			nom[8 + 64 + 1];
 
+#	ifdef _BROKEN_SIGINFO
+	(*siginfo).si_pid=getpid();
+#	endif
+
 	verrouillage_gestionnaire_signaux();
 
 	if ((s_etat_processus = recherche_thread(getpid(), pthread_self())) == NULL)
@@ -2183,6 +2291,10 @@ interruption11(int signal, siginfo_t *si
 	pthread_t				thread;
 	struct_processus		*s_etat_processus;
 
+#	ifdef _BROKEN_SIGINFO
+	(*siginfo).si_pid=getpid();
+#	endif
+
 	verrouillage_gestionnaire_signaux();
 
 	if ((*siginfo).si_pid == getpid())