--- rpl/src/rpl.c	2011/09/14 14:34:28	1.83
+++ rpl/src/rpl.c	2011/09/20 15:45:53	1.92
@@ -23,12 +23,6 @@
 #define  MAIN_RPL
 #include "rpl-conv.h"
 
-#ifdef IPCS_SYSV
-#ifndef OS2
-	unsigned char		*chemin_semaphores_SysV;
-#endif
-#endif
-
 
 /*
 ================================================================================
@@ -105,6 +99,7 @@ rplinit(int argc, char *argv[], unsigned
 	volatile unsigned char				traitement_fichier_temporaire;
 
 	errno = 0;
+	s_queue_signaux = NULL;
 	pid_processus_pere = getpid();
 
 #	ifdef DEBUG_MEMOIRE
@@ -115,18 +110,11 @@ rplinit(int argc, char *argv[], unsigned
 	setvbuf(stderr, NULL, _IOLBF, 0);
 
 #	ifndef SEMAPHORES_NOMMES
-	sem_init(&semaphore_liste_threads, 0, 1);
 	sem_init(&semaphore_gestionnaires_signaux, 0, 0);
-	sem_init(&semaphore_gestionnaires_signaux_atomique, 0, 1);
 #	else
-	semaphore_liste_threads = sem_init2(1, sem_liste_threads);
-	semaphore_gestionnaires_signaux = sem_init2(0, sem_gestionnaires_signaux);
-	semaphore_gestionnaires_signaux_atomique = sem_init2(1,
-			sem_gestionnaires_signaux_atomique);
-
-	if ((semaphore_liste_threads == SEM_FAILED) ||
-			(semaphore_gestionnaires_signaux == SEM_FAILED) ||
-			(semaphore_gestionnaires_signaux_atomique == SEM_FAILED))
+	semaphore_gestionnaires_signaux = sem_init2(0, getpid(), SEM_SIGNAUX);
+	
+	if (semaphore_gestionnaires_signaux == SEM_FAILED)
 	{
 		erreur = d_es_allocation_memoire;
 
@@ -189,7 +177,6 @@ rplinit(int argc, char *argv[], unsigned
 	(*s_etat_processus).erreur_systeme = d_es;
 	(*s_etat_processus).erreur_execution = d_ex;
 	(*s_etat_processus).compteur_violation_d_acces = 0;
-	(*s_etat_processus).tid_courant = pthread_self();
 
 	(*s_etat_processus).rpl_home = rpl_home;
 
@@ -205,22 +192,22 @@ rplinit(int argc, char *argv[], unsigned
 	pthread_mutexattr_destroy(&attributs_mutex);
 
 #	ifndef SEMAPHORES_NOMMES
-	sem_init(&((*s_etat_processus).semaphore_fork), 0, 0);
+		sem_init(&((*s_etat_processus).semaphore_fork), 0, 0);
 #	else
-	if (((*s_etat_processus).semaphore_fork = sem_init2(0, sem_fork)) ==
-			SEM_FAILED)
-	{
-		if ((*s_etat_processus).langue == 'F')
-		{
-			uprintf("+++Système : Mémoire insuffisante\n");
-		}
-		else
+		if (((*s_etat_processus).semaphore_fork = sem_init3(0, getpid(),
+				pthread_self(), SEM_FORK)) == SEM_FAILED)
 		{
-			uprintf("+++System : Not enough memory\n");
-		}
+			if ((*s_etat_processus).langue == 'F')
+			{
+				uprintf("+++Système : Mémoire insuffisante\n");
+			}
+			else
+			{
+				uprintf("+++System : Not enough memory\n");
+			}
 
-		return(EXIT_FAILURE);
-	}
+			return(EXIT_FAILURE);
+		}
 #	endif
 
 	pthread_mutexattr_init(&attributs_mutex);
@@ -244,13 +231,6 @@ rplinit(int argc, char *argv[], unsigned
 	(*s_etat_processus).chemin_fichiers_temporaires =
 			recherche_chemin_fichiers_temporaires(s_etat_processus);
 
-#	ifdef IPCS_SYSV
-#		ifndef OS2
-			chemin_semaphores_SysV =
-					(*s_etat_processus).chemin_fichiers_temporaires;
-#		endif
-#	endif
-
 	insertion_thread(s_etat_processus, d_vrai);
 	creation_queue_signaux(s_etat_processus);
 
@@ -334,42 +314,6 @@ rplinit(int argc, char *argv[], unsigned
 		home = "";
 	}
 
-	// Initialisation d'une clef
-
-	if (pthread_key_create(&semaphore_fork_processus_courant, NULL) != 0)
-	{
-		if ((*s_etat_processus).langue == 'F')
-		{
-			printf("+++Système : Mémoire insuffisante\n");
-		}
-		else
-		{
-			printf("+++System : Not enough memory\n");
-		}
-
-		return(EXIT_FAILURE);
-	}
-
-#	ifndef SEMAPHORES_NOMMES
-	if (pthread_setspecific(semaphore_fork_processus_courant,
-			&((*s_etat_processus).semaphore_fork)) != 0)
-#	else
-	if (pthread_setspecific(semaphore_fork_processus_courant,
-			(*s_etat_processus).semaphore_fork) != 0)
-#	endif
-	{
-		if ((*s_etat_processus).langue == 'F')
-		{
-			printf("+++Système : Mémoire insuffisante\n");
-		}
-		else
-		{
-			printf("+++System : Not enough memory\n");
-		}
-
-		return(EXIT_FAILURE);
-	}
-
 	// Initialisation d'une pile de signal pour récupérer les
 	// débordement de pile
 
@@ -655,6 +599,15 @@ rplinit(int argc, char *argv[], unsigned
 		option_t = d_faux;
 		option_v = d_faux;
 
+		// Lorsque le programme est appelé depuis un shebang, argv[0] contient
+		// le chemin du programme et argv[1] tous les arguments.
+		// argv[2] contient quant à lui le nom du script RPL/2.
+		//
+		// Exemple :
+		// argv[0] : /usr/local/bin/rpl
+		// argv[1] : -csdp -t 800
+		// argv[2] : ./on_exit.rpl
+
 		while((--argc) > 0)
 		{
 			if ((*(++argv))[0] == '-')
@@ -1450,6 +1403,12 @@ rplinit(int argc, char *argv[], unsigned
 							break;
 						}
 
+						case '-':
+						case ' ':
+						{
+							break;
+						}
+
 						default :
 						{
 							if ((*s_etat_processus).langue == 'F')
@@ -2679,8 +2638,6 @@ rplinit(int argc, char *argv[], unsigned
 							lancement_daemon(s_etat_processus);
 						}
 
-// A FIXER
-// création signaux
 						if (option_p == d_faux)
 						{
 							if (setjmp(contexte_initial) == 0)
@@ -2723,8 +2680,6 @@ rplinit(int argc, char *argv[], unsigned
 								}
 							}
 						}
-// A FIXER
-// destruction signaux
 					}
 
 					liberation(s_etat_processus, (*s_etat_processus).at_exit);
@@ -3005,6 +2960,7 @@ rplinit(int argc, char *argv[], unsigned
 						}
 
 						nanosleep(&attente, NULL);
+						scrutation_interruptions(s_etat_processus);
 						pthread_mutex_lock(&((*s_etat_processus).mutex));
 					}
 
@@ -3531,29 +3487,25 @@ rplinit(int argc, char *argv[], unsigned
 	pthread_mutex_destroy(&((*s_etat_processus).mutex_allocation));
 
 #	ifndef SEMAPHORES_NOMMES
-	sem_post(&((*s_etat_processus).semaphore_fork));
-	sem_destroy(&((*s_etat_processus).semaphore_fork));
+	sem_post(&((*s_etat_processus).semaphore_fork);
+	sem_destroy(&((*s_etat_processus).semaphore_fork);
 #	else
 	sem_post((*s_etat_processus).semaphore_fork);
-	sem_destroy2((*s_etat_processus).semaphore_fork, sem_fork);
+	sem_destroy3((*s_etat_processus).semaphore_fork, getpid(), pthread_self(),
+			SEM_FORK);
 #	endif
 
 	free((*s_etat_processus).localisation);
 
-#	ifndef SEMAPHORES_NOMMES
-	sem_destroy(&semaphore_liste_threads);
-#	else
-	sem_destroy2(semaphore_liste_threads, sem_liste_threads);
-#	endif
+	pthread_mutex_destroy(&mutex_liste_threads);
+	pthread_mutex_destroy(&mutex_gestionnaires_signaux_atomique);
+
 #	ifndef SEMAPHORES_NOMMES
 	sem_post(&semaphore_gestionnaires_signaux);
 	sem_destroy(&semaphore_gestionnaires_signaux);
-	sem_destroy(&semaphore_gestionnaires_signaux_atomique);
 #	else
 	sem_post(semaphore_gestionnaires_signaux);
-	sem_destroy2(semaphore_gestionnaires_signaux, sem_gestionnaires_signaux);
-	sem_destroy2(semaphore_gestionnaires_signaux_atomique,
-			sem_gestionnaires_signaux_atomique);
+	sem_destroy2(semaphore_gestionnaires_signaux, getpid(), SEM_SIGNAUX);
 #	endif
 
 	destruction_queue_signaux(s_etat_processus);