--- rpl/src/interruptions.c	2010/04/28 11:05:45	1.10
+++ rpl/src/interruptions.c	2010/04/30 15:01:14	1.13
@@ -82,30 +82,9 @@ insertion_thread(struct_processus *s_eta
 	sigfillset(&set);
 	pthread_sigmask(SIG_BLOCK, &set, &oldset);
 
-#	ifndef SEMAPHORES_NOMMES
-	while(sem_wait(&semaphore_liste_threads) == -1)
-#	else
-	while(sem_wait(semaphore_liste_threads) == -1)
-#	endif
-	{
-		if (errno != EINTR)
-		{
-			pthread_sigmask(SIG_SETMASK, &oldset, NULL);
-			sigpending(&set);
-
-			(*s_etat_processus).erreur_systeme = d_es_processus;
-			return;
-		}
-	}
-
 	if ((l_nouvel_objet = malloc(sizeof(struct_liste_chainee_volatile)))
 			== NULL)
 	{
-#		ifndef SEMAPHORES_NOMMES
-		sem_post(&semaphore_liste_threads);
-#		else
-		sem_post(semaphore_liste_threads);
-#		endif
 		pthread_sigmask(SIG_SETMASK, &oldset, NULL);
 		sigpending(&set);
 
@@ -113,15 +92,8 @@ insertion_thread(struct_processus *s_eta
 		return;
 	}
 
-	(*l_nouvel_objet).suivant = liste_threads;
-
 	if (((*l_nouvel_objet).donnee = malloc(sizeof(struct_thread))) == NULL)
 	{
-#		ifndef SEMAPHORES_NOMMES
-		sem_post(&semaphore_liste_threads);
-#		else
-		sem_post(semaphore_liste_threads);
-#		endif
 		pthread_sigmask(SIG_SETMASK, &oldset, NULL);
 		sigpending(&set);
 
@@ -136,6 +108,24 @@ insertion_thread(struct_processus *s_eta
 	(*((struct_thread *) (*l_nouvel_objet).donnee)).s_etat_processus =
 			s_etat_processus;
 
+#	ifndef SEMAPHORES_NOMMES
+	while(sem_wait(&semaphore_liste_threads) == -1)
+#	else
+	while(sem_wait(semaphore_liste_threads) == -1)
+#	endif
+	{
+		if (errno != EINTR)
+		{
+			pthread_sigmask(SIG_SETMASK, &oldset, NULL);
+			sigpending(&set);
+
+			(*s_etat_processus).erreur_systeme = d_es_processus;
+			return;
+		}
+	}
+
+	(*l_nouvel_objet).suivant = liste_threads;
+
 	liste_threads = l_nouvel_objet;
 
 #	ifndef SEMAPHORES_NOMMES
@@ -168,6 +158,16 @@ insertion_thread_surveillance(struct_pro
 	sigfillset(&set);
 	pthread_sigmask(SIG_BLOCK, &set, &oldset);
 
+	if ((l_nouvel_objet = malloc(sizeof(struct_liste_chainee_volatile)))
+			== NULL)
+	{
+		pthread_sigmask(SIG_SETMASK, &oldset, NULL);
+		sigpending(&set);
+
+		(*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
+		return;
+	}
+
 #	ifndef SEMAPHORES_NOMMES
 	while(sem_wait(&semaphore_liste_threads) == -1)
 #	else
@@ -184,21 +184,6 @@ insertion_thread_surveillance(struct_pro
 		}
 	}
 
-	if ((l_nouvel_objet = malloc(sizeof(struct_liste_chainee_volatile)))
-			== NULL)
-	{
-#		ifndef SEMAPHORES_NOMMES
-		sem_post(&semaphore_liste_threads);
-#		else
-		sem_post(semaphore_liste_threads);
-#		endif
-		pthread_sigmask(SIG_SETMASK, &oldset, NULL);
-		sigpending(&set);
-
-		(*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
-		return;
-	}
-
 	(*l_nouvel_objet).suivant = liste_threads_surveillance;
 	(*l_nouvel_objet).donnee = (void *) s_argument_thread;
 
@@ -289,9 +274,6 @@ retrait_thread(struct_processus *s_etat_
 		(*l_element_precedent).suivant = (*l_element_courant).suivant;
 	}
 
-	free((void *) (*l_element_courant).donnee);
-	free((struct_liste_chainee_volatile *) l_element_courant);
-
 	if (pthread_setspecific(semaphore_fork_processus_courant, NULL) != 0)
 	{
 		(*s_etat_processus).erreur_systeme = d_es_processus;
@@ -319,6 +301,9 @@ retrait_thread(struct_processus *s_etat_
 		return;
 	}
 
+	free((void *) (*l_element_courant).donnee);
+	free((struct_liste_chainee_volatile *) l_element_courant);
+
 	pthread_sigmask(SIG_SETMASK, &oldset, NULL);
 	sigpending(&set);
 	return;
@@ -381,6 +366,7 @@ retrait_thread_surveillance(struct_proce
 		return;
 	}
 
+	// l_element_courant->donnee n'est pas bonne lorsque ça part en vrille.
 	if (l_element_precedent == NULL)
 	{
 		liste_threads_surveillance = (*l_element_courant).suivant;
@@ -390,10 +376,13 @@ retrait_thread_surveillance(struct_proce
 		(*l_element_precedent).suivant = (*l_element_courant).suivant;
 	}
 
-	free((struct_liste_chainee_volatile *) l_element_courant);
-
 	if (pthread_mutex_lock(&((*s_argument_thread).mutex)) != 0)
 	{
+#		ifndef SEMAPHORES_NOMMES
+		sem_post(&semaphore_liste_threads);
+#		else
+		sem_post(semaphore_liste_threads);
+#		endif
 		pthread_sigmask(SIG_SETMASK, &oldset, NULL);
 		sigpending(&set);
 
@@ -411,6 +400,11 @@ retrait_thread_surveillance(struct_proce
 	{
 		if (pthread_mutex_unlock(&((*s_argument_thread).mutex)) != 0)
 		{
+#			ifndef SEMAPHORES_NOMMES
+			sem_post(&semaphore_liste_threads);
+#			else
+			sem_post(semaphore_liste_threads);
+#			endif
 			pthread_sigmask(SIG_SETMASK, &oldset, NULL);
 			sigpending(&set);
 
@@ -425,6 +419,11 @@ retrait_thread_surveillance(struct_proce
 	{
 		if (pthread_mutex_unlock(&((*s_argument_thread).mutex)) != 0)
 		{
+#			ifndef SEMAPHORES_NOMMES
+			sem_post(&semaphore_liste_threads);
+#			else
+			sem_post(semaphore_liste_threads);
+#			endif
 			pthread_sigmask(SIG_SETMASK, &oldset, NULL);
 			sigpending(&set);
 
@@ -446,6 +445,8 @@ retrait_thread_surveillance(struct_proce
 		return;
 	}
 
+	free((struct_liste_chainee_volatile *) l_element_courant);
+
 	pthread_sigmask(SIG_SETMASK, &oldset, NULL);
 	sigpending(&set);
 	return;
@@ -626,6 +627,8 @@ liberation_threads(struct_processus *s_e
 			close((*s_etat_processus).pipe_nombre_objets_attente);
 			close((*s_etat_processus).pipe_nombre_interruptions_attente);
 
+			liberation(s_etat_processus, (*s_etat_processus).at_exit);
+
 			if ((*s_etat_processus).nom_fichier_impression != NULL)
 			{
 				free((*s_etat_processus).nom_fichier_impression);
@@ -1291,6 +1294,7 @@ liberation_threads(struct_processus *s_e
 		if (pthread_mutex_lock(&((*s_argument_thread).mutex)) != 0)
 		{
 			(*s_etat_processus).erreur_systeme = d_es_processus;
+			sem_post(&semaphore_liste_threads);
 			return;
 		}
 
@@ -1305,6 +1309,7 @@ liberation_threads(struct_processus *s_e
 			if (pthread_mutex_unlock(&((*s_argument_thread).mutex)) != 0)
 			{
 				(*s_etat_processus).erreur_systeme = d_es_processus;
+				sem_post(&semaphore_liste_threads);
 				return;
 			}
 
@@ -1316,6 +1321,7 @@ liberation_threads(struct_processus *s_e
 			if (pthread_mutex_unlock(&((*s_argument_thread).mutex)) != 0)
 			{
 				(*s_etat_processus).erreur_systeme = d_es_processus;
+				sem_post(&semaphore_liste_threads);
 				return;
 			}
 		}
@@ -1957,6 +1963,11 @@ interruption5(int signal, siginfo_t *sig
 			return;
 		}
 
+		if (signal == SIGFABORT)
+		{
+			(*s_etat_processus).arret_depuis_abort = -1;
+		}
+
 		if (((*s_etat_processus).type_debug & d_debug_signaux) != 0)
 		{
 			if (signal == SIGFSTOP)
@@ -1980,25 +1991,29 @@ interruption5(int signal, siginfo_t *sig
 		 * -1 -> traitement retardé (un ou plusieurs signaux stop reçus)
 		 */
 
-		if (signal == SIGFSTOP)
+		if ((*s_etat_processus).var_volatile_traitement_retarde_stop == 0)
 		{
-			if ((*s_etat_processus).var_volatile_traitement_retarde_stop == 0)
-			{
-				(*s_etat_processus).var_volatile_requete_arret = -1;
-			}
-			else
-			{
-				(*s_etat_processus).var_volatile_traitement_retarde_stop = -1;
-			}
+			(*s_etat_processus).var_volatile_requete_arret = -1;
 		}
 		else
 		{
-			(*s_etat_processus).var_volatile_requete_arret = -1;
-			(*s_etat_processus).arret_depuis_abort = -1;
+			(*s_etat_processus).var_volatile_traitement_retarde_stop = -1;
 		}
 	}
 	else
 	{
+		if ((s_etat_processus = recherche_thread(getpid(), pthread_self()))
+				== NULL)
+		{
+			deverrouillage_gestionnaire_signaux();
+			return;
+		}
+
+		if (signal == SIGFABORT)
+		{
+			(*s_etat_processus).arret_depuis_abort = -1;
+		}
+
 		// Envoi d'un signal au thread maître du groupe.
 
 		if (recherche_thread_principal(getpid(), &thread) == d_vrai)
@@ -2127,7 +2142,7 @@ interruption9(int signal, siginfo_t *sig
 		fflush(stdout);
 	}
 
-	pthread_kill((*s_etat_processus).tid_processus_pere, SIGFSTOP);
+	pthread_kill((*s_etat_processus).tid_processus_pere, SIGFABORT);
 	deverrouillage_gestionnaire_signaux();
 	return;
 }