--- rpl/src/rpl.h	2011/09/15 19:23:54	1.123
+++ rpl/src/rpl.h	2011/09/20 15:45:53	1.131
@@ -122,16 +122,20 @@
 				ULONG	*nopened;
 				ULONG	allocated;
 			} sem_t;
-#		else
+#		else // IPCS_SYSV
 			typedef struct
 		   	{
 				int				sem;
+				int				alloue;
 				unsigned char	*path;
 				pid_t			pid;
+				pthread_t		tid;
 			} sem_t;
 #		endif
 
-#		define SEM_FAILED	NULL
+#		ifndef SEM_FAILED
+#			define SEM_FAILED	NULL
+#		endif
 
 		sem_t *sem_open_SysV(const char *nom, int oflag, ...);
 		int sem_init_SysV(sem_t *sem, int shared, unsigned int value);
@@ -239,11 +243,13 @@ enum signaux_rpl
 
 typedef struct queue_signaux
 {
-	sem_t
-#	ifdef SEMAPHORES_NOMMES
-		*
+#	ifndef IPCS_SYSV
+#		ifndef SEMAPHORES_NOMMES
+			sem_t				semaphore;
+#		endif
+#	else
+		sem_t					semaphore;
 #	endif
-								semaphore;
 
 	volatile int				pointeur_lecture;
 	volatile int				pointeur_ecriture;
@@ -259,9 +265,15 @@ typedef struct queue_signaux
 #	ifndef MAIN_RPL
 		extern struct_queue_signaux			*s_queue_signaux;
 		extern int							f_queue_signaux;
+#		ifdef SEMAPHORES_NOMMES
+			extern sem_t					*semaphore_queue_signaux;
+#		endif
 #	else
 		struct_queue_signaux				*s_queue_signaux;
 		int									f_queue_signaux;
+#		ifdef SEMAPHORES_NOMMES
+			sem_t							*semaphore_queue_signaux;
+#		endif
 #	endif
 #endif
 
@@ -428,7 +440,7 @@ typedef unsigned char			t_8_bits;
 
 		pthread_mutex_t				mutex_liste_threads =
 											PTHREAD_MUTEX_INITIALIZER;
-		pthread_mutex_t				mutex_gestiionnaires_signaux =
+		pthread_mutex_t				mutex_gestionnaires_signaux =
 											PTHREAD_MUTEX_INITIALIZER;
 		pthread_mutex_t				mutex_gestionnaires_signaux_atomique =
 											PTHREAD_MUTEX_INITIALIZER;
@@ -441,14 +453,19 @@ typedef unsigned char			t_8_bits;
 #endif
 
 #ifdef SEMAPHORES_NOMMES
-enum t_semaphore	{ sem_liste_threads = 0,
-		sem_gestionnaires_signaux = 1,
-		sem_gestionnaires_signaux_atomique = 2,
-		sem_fork = 3 };
-
-sem_t *sem_init2(unsigned int valeur, enum t_semaphore semaphore);
-int sem_destroy2(sem_t *semaphore_p, enum t_semaphore semaphore);
+#define SEM_FORK			0
+#define	SEM_QUEUE			1
+#define	SEM_SIGNAUX			2
+sem_t *sem_init2(unsigned int valeur, pid_t pid, int ordre);
+sem_t *sem_init3(unsigned int valeur, pid_t pid, pthread_t tid, int ordre);
+int sem_destroy2(sem_t *semaphore_p, pid_t pid, int ordre);
+int sem_destroy3(sem_t *semaphore_p, pid_t pid, pthread_t tid, int ordre);
 int sem_getvalue2(sem_t *semaphore, int *valeur);
+sem_t *sem_open2(pid_t pid, int ordre);
+
+// Le mutex est là uniquement pour pouvoir émuler le comportement
+// de sem_getvalue() sur un système comme MacOS X qui ne possède pas
+// cette fonction.
 
 #define sem_getvalue(semaphore, value) sem_getvalue2(semaphore, value)
 #define sem_post(semaphore) \
@@ -480,10 +497,6 @@ int sem_getvalue2(sem_t *semaphore, int
 #define ufprintf(flux, ...) transliterated_fprintf(NULL, \
 			flux, __VA_ARGS__)
 
-// Tous les messages pour DISP, INPUT et les E/S par readline sont sur stderr.
-// Cela évite aux messages envoyés par les gestionnaires de signaux d'être
-// indéfiniment bloqués.
-
 #ifdef SunOS
 #	define fopen(...) ({ FILE *desc; \
 	        while((desc = fopen(__VA_ARGS__)) == NULL) \
@@ -732,7 +745,6 @@ pid_t debug_fork();
 --------------------------------------------------------------------------------
 */
 
-#define DEBUG_ERREURS
 #ifdef DEBUG_ERREURS
 #	ifdef MESSAGES
 #		define __erreur(i)	i
@@ -2170,7 +2182,11 @@ typedef struct processus
 	pthread_mutex_t				mutex_allocation;
 
 	// Mutex autorisant les fork()
-	pthread_mutex_t				mutex_fork;
+	sem_t
+#	ifdef SEMAPHORES_NOMMES
+		*
+#	endif
+		 						semaphore_fork;
 
 /* Mutexes											*/