--- rpl/src/interruptions.c	2010/06/02 10:28:45	1.19
+++ rpl/src/interruptions.c	2010/06/04 07:48:20	1.20
@@ -184,6 +184,7 @@ insertion_thread_surveillance(struct_pro
 		}
 	}
 
+printf("<1> +1 %d\n", (*s_argument_thread).nombre_references);
 	(*l_nouvel_objet).suivant = liste_threads_surveillance;
 	(*l_nouvel_objet).donnee = (void *) s_argument_thread;
 
@@ -390,11 +391,13 @@ retrait_thread_surveillance(struct_proce
 	}
 
 	(*s_argument_thread).nombre_references--;
+printf("<3> -1 %d %p\n", (*s_argument_thread).nombre_references, s_argument_thread);
 
 	BUG((*s_argument_thread).nombre_references < 0,
 			printf("(*s_argument_thread).nombre_references = %d\n",
 			(int) (*s_argument_thread).nombre_references));
 
+printf("retrait_thread_surveillance : %d\n", (*s_argument_thread).nombre_references);
 	if ((*s_argument_thread).nombre_references == 0)
 	{
 		if (pthread_mutex_unlock(&((*s_argument_thread).mutex)) != 0)
@@ -448,6 +451,7 @@ retrait_thread_surveillance(struct_proce
 
 	pthread_sigmask(SIG_SETMASK, &oldset, NULL);
 	sigpending(&set);
+
 	return;
 }
 
@@ -669,22 +673,74 @@ 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--;
+printf("<1> -1 %d %p\n", (*s_argument_thread).nombre_references, s_argument_thread);
+
+				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)).donnee)
-						.objet);
-				free((*((struct_liste_chainee *) element_courant)).donnee);
-				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);
@@ -1295,14 +1351,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;
@@ -1311,6 +1359,7 @@ liberation_threads(struct_processus *s_e
 		}
 
 		(*s_argument_thread).nombre_references--;
+printf("<2> -1 %d %p\n", (*s_argument_thread).nombre_references, s_argument_thread);
 
 		BUG((*s_argument_thread).nombre_references < 0,
 				printf("(*s_argument_thread).nombre_references = %d\n",
@@ -1318,6 +1367,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;
@@ -1326,6 +1383,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