--- rpl/src/semaphores.c	2010/08/18 12:56:55	1.11
+++ rpl/src/semaphores.c	2011/09/18 18:06:01	1.30
@@ -1,7 +1,7 @@
 /*
 ================================================================================
-  RPL/2 (R) version 4.0.18
-  Copyright (C) 1989-2010 Dr. BERTRAND Joël
+  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;
@@ -107,7 +178,7 @@ sem_getvalue2(sem_t *semaphore, int *val
 
 #endif
 
-#ifdef SEMAPHORES_SYSV
+#ifdef IPCS_SYSV
 
 /*
 ================================================================================
@@ -125,17 +196,7 @@ sem_getvalue2(sem_t *semaphore, int *val
 	extern unsigned char *chemin_semaphores_SysV;
 #else
 	unsigned char racine_semaphores_OS2[] = "\\SEM32\\";
-	unsigned char racine_memoire_OS2[] = "\\SHAREDMEM\\";
-#endif
-
-#ifndef UNION_SEMUN
-union semun
-{
-	int					val;
-	struct semid_ds		*buf;
-	unsigned short		*array;
-	struct seminfo		*__buf;
-};
+	unsigned char racine_memoire_OS2[] = "\\SHAREMEM\\";
 #endif
 
 int
@@ -162,7 +223,6 @@ sem_init_SysV(sem_t *semaphore, int shar
 
 	if ((*semaphore).sem == -1)
 	{
-perror("sem_init");
 		errno = EINVAL;
 		return(-1);
 	}
@@ -242,7 +302,7 @@ sem_destroy_SysV(sem_t *semaphore)
 		return(0);
 	}
 
-	if (semctl((*semaphore).sem, IPC_RMID, 0) == -1)
+	if (semctl((*semaphore).sem, 0, IPC_RMID) == -1)
 	{
 		return(EINVAL);
 	}
@@ -310,7 +370,6 @@ sem_wait_SysV(sem_t *semaphore)
 	{
 		if (errno != EINTR)
 		{
-perror("sem_wait");
 			errno = EINVAL;
 			return(-1);
 		}
@@ -865,7 +924,7 @@ sem_unlink_SysV(const char *nom)
 	}
 
 	sprintf(nom_absolu, "%s%s", chemin_semaphores_SysV, nom);
-	semctl(semget(ftok(nom_absolu, 1), 0, 0), IPC_RMID, 0);
+	semctl(semget(ftok(nom_absolu, 1), 0, 0), 0, IPC_RMID);
 
 	if (unlink(nom_absolu) == -1)
 	{