--- rpl/src/semaphores.c	2011/06/24 20:31:42	1.24
+++ rpl/src/semaphores.c	2011/09/18 18:06:01	1.30
@@ -1,6 +1,6 @@
 /*
 ================================================================================
-  RPL/2 (R) version 4.1.0.prerelease.4
+  RPL/2 (R) version 4.1.3
   Copyright (C) 1989-2011 Dr. BERTRAND Joël
 
   This file is part of RPL/2.
@@ -24,6 +24,25 @@
 
 #ifdef SEMAPHORES_NOMMES
 
+// Les fonctions suivantes ne sont utilisées que dans le cas d'un
+// système POSIX qui ne possède pas de sémaphores anonymes. MacOS X
+// est dans ce cas.
+
+static unsigned char *
+nom_segment_semaphore(pid_t pid)
+{
+	unsigned char				*fichier;
+
+	if ((fichier = malloc((1 + 256 + 1) * sizeof(unsigned char))) == NULL)
+	{
+		return(NULL);
+	}
+
+	sprintf(fichier, "/RPL-SIGSEMAPHORE-%d", (int) pid);
+	return(fichier);
+}
+
+
 /*
 ================================================================================
   Fonctions d'émulation de sémaphores anonymes
@@ -37,21 +56,71 @@
 */
 
 sem_t *
-sem_init2(unsigned int valeur, enum t_semaphore semaphore)
+sem_init2(unsigned int valeur, pid_t pid)
 {
-	snprintf(noms_semaphores[semaphore], LONGUEUR_NOM_SEMAPHORE,
-			"/RPL-SEM-%d-%llu-%d", (int) getpid(),
-			(unsigned long long) pthread_self(),
-			(int) semaphore);
-	return(sem_open(noms_semaphores[semaphore], O_CREAT,
-			(S_IRUSR | S_IWUSR), valeur));
+	sem_t						*semaphore;
+
+	unsigned char				*chemin;
+	unsigned int				i;
+
+	if ((chemin = nom_segment_semaphore(pid)) == NULL)
+	{
+		return(SEM_FAILED);
+	}
+
+	semaphore = sem_open(chemin, O_CREAT, (S_IRUSR | S_IWUSR), valeur);
+	free(chemin);
+
+	for(i = 0; i < valeur; i++)
+	{
+		if (sem_post(semaphore) != 0)
+		{
+			sem_close(semaphore);
+			return(SEM_FAILED);
+		}
+	}
+
+	return(semaphore);
 }
 
+
+sem_t *
+sem_open2(pid_t pid)
+{
+	unsigned char				*chemin;
+
+	sem_t						*semaphore;
+
+	if ((chemin = nom_segment_semaphore(pid)) == NULL)
+	{
+		return(1);
+	}
+
+	semaphore = sem_open(chemin, O_RDWR);
+	free(chemin);
+
+	return(semaphore);
+}
+
+
 int
-sem_destroy2(sem_t *semaphore_p, enum t_semaphore semaphore)
+sem_destroy2(sem_t *semaphore, pid_t pid)
 {
-	sem_close(semaphore_p);
-	return(sem_unlink(noms_semaphores[semaphore]));
+	int							erreur;
+
+	unsigned char				*chemin;
+
+	sem_close(semaphore);
+
+	if ((chemin = nom_segment_semaphore(pid)) == NULL)
+	{
+		return(1);
+	}
+
+	erreur = sem_unlink(chemin);
+	free(chemin);
+
+	return(erreur);
 }
 
 #undef sem_post
@@ -65,6 +134,8 @@ sem_getvalue2(sem_t *semaphore, int *val
 
 	logical1				drapeau_fin;
 
+	// Si on ne peut pas décrémenter le sémaphore, c'est qu'il était
+	// déjà nul.
 	pthread_mutex_lock(&mutex_sem);
 
 	(*valeur) = 0;