--- rpl/src/semaphores.c	2010/08/17 11:59:28	1.10
+++ rpl/src/semaphores.c	2010/08/18 12:56:55	1.11
@@ -141,6 +141,8 @@ union semun
 int
 sem_init_SysV(sem_t *semaphore, int shared, unsigned int valeur)
 {
+	// Création d'un sémaphore anonyme qui devra être supprimé par
+	// sem_destroy_SysV
 #	ifndef OS2
 
 	int				ios;
@@ -153,16 +155,20 @@ sem_init_SysV(sem_t *semaphore, int shar
 		return(-1);
 	}
 
-	(*semaphore) = semget(IPC_PRIVATE, 1, IPC_CREAT | IPC_EXCL | SEM_R | SEM_A);
+	(*semaphore).sem = semget(IPC_PRIVATE, 1, IPC_CREAT | IPC_EXCL |
+			S_IRUSR | S_IWUSR);
+	(*semaphore).path = NULL;
+	(*semaphore).pid = getpid();
 
-	if ((*semaphore) == -1)
+	if ((*semaphore).sem == -1)
 	{
+perror("sem_init");
 		errno = EINVAL;
 		return(-1);
 	}
 
 	argument.val = valeur;
-	ios = semctl((*semaphore), 0, SETVAL, argument);
+	ios = semctl((*semaphore).sem, 0, SETVAL, argument);
 
 	return(ios);
 
@@ -223,9 +229,20 @@ sem_init_SysV(sem_t *semaphore, int shar
 int
 sem_destroy_SysV(sem_t *semaphore)
 {
+	// Détruit un sémaphore anonmyme
 #	ifndef OS2
 
-	if (semctl((*semaphore), IPC_RMID, 0) == -1)
+	if ((*semaphore).path != NULL)
+	{
+		return(EINVAL);
+	}
+
+	if ((*semaphore).pid != getpid())
+	{
+		return(0);
+	}
+
+	if (semctl((*semaphore).sem, IPC_RMID, 0) == -1)
 	{
 		return(EINVAL);
 	}
@@ -289,10 +306,14 @@ sem_wait_SysV(sem_t *semaphore)
 	commande.sem_op = -1;
 	commande.sem_flg = 0;
 
-	if (semop((*semaphore), &commande, 1) == -1)
+	while(semop((*semaphore).sem, &commande, 1) == -1)
 	{
-		errno = EINVAL;
-		return(-1);
+		if (errno != EINTR)
+		{
+perror("sem_wait");
+			errno = EINVAL;
+			return(-1);
+		}
 	}
 
 	return(0);
@@ -344,9 +365,13 @@ sem_trywait_SysV(sem_t *semaphore)
 	commande.sem_op = -1;
 	commande.sem_flg = IPC_NOWAIT;
 
-	if (semop((*semaphore), &commande, 1) == -1)
+	while(semop((*semaphore).sem, &commande, 1) == -1)
 	{
-		return(-1);
+		if (errno != EINTR)
+		{
+			errno = EINVAL;
+			return(-1);
+		}
 	}
 
 	return(0);
@@ -400,10 +425,13 @@ sem_post_SysV(sem_t *semaphore)
 	commande.sem_op = 1;
 	commande.sem_flg = 0;
 
-	if (semop((*semaphore), &commande, 1) == -1)
+	while(semop((*semaphore).sem, &commande, 1) == -1)
 	{
-		errno = EINVAL;
-		return(-1);
+		if (errno != EINTR)
+		{
+			errno = EINVAL;
+			return(-1);
+		}
 	}
 
 	return(0);
@@ -434,7 +462,7 @@ sem_getvalue_SysV(sem_t *semaphore, int
 {
 #	ifndef OS2
 
-	(*valeur) = semctl((*semaphore), 0, GETVAL);
+	(*valeur) = semctl((*semaphore).sem, 0, GETVAL);
 
 	if ((*valeur) < 0)
 	{
@@ -510,8 +538,6 @@ sem_t
 		return(SEM_FAILED);
 	}
 
-	(*psem).allocated = 1;
-
 #	else
 
 	if ((nom_segment = malloc((strlen(racine_memoire_OS2) + strlen(nom) + 1)
@@ -559,6 +585,8 @@ sem_t
 		return(SEM_FAILED);
 	}
 
+	(*psem).allocated = 1;
+
 #	endif
 
 	if ((oflag & O_CREAT) == 0)
@@ -567,9 +595,18 @@ sem_t
 
 #		ifndef OS2
 
-		(*semaphore) = semget(ftok(nom_absolu, 1), 0, 0);
+		clef = ftok(nom_absolu, 1);
 
-		if ((*semaphore) == -1)
+		if (clef == -1)
+		{
+			return(SEM_FAILED);
+		}
+
+		(*semaphore).sem = semget(clef, 0, 0);
+		(*semaphore).path = nom_absolu;
+		(*semaphore).pid = getpid();
+
+		if ((*semaphore).sem == -1)
 		{	
 			free(semaphore);
 			free(nom_absolu);
@@ -678,13 +715,14 @@ sem_t
 			return(SEM_FAILED);
 		}
 
-		(*semaphore) = semget(clef, 1,
-				((oflag & O_CREAT) == 0) ? 0 : IPC_CREAT |
-				((oflag & O_EXCL) == 0) ? 0 : IPC_EXCL |
-				((oflag & S_IRUSR) == 0) ? 0 : SEM_R |
-				((oflag & S_IWUSR) == 0) ? 0 : SEM_A);
+		(*semaphore).sem = semget(clef, 1,
+				(((oflag & O_CREAT) == 0) ? 0 : IPC_CREAT) |
+				(((oflag & O_EXCL) == 0) ? 0 : IPC_EXCL) |
+				(int) mode);
+		(*semaphore).path = nom_absolu;
+		(*semaphore).pid = getpid();
 
-		if ((*semaphore) == -1)
+		if ((*semaphore).sem == -1)
 		{	
 			free(semaphore);
 			free(nom_absolu);
@@ -693,7 +731,7 @@ sem_t
 		}
 
 		argument.val = valeur;
-		semctl((*semaphore), 0, SETVAL, argument);
+		semctl((*semaphore).sem, 0, SETVAL, argument);
 
 #		else
 
@@ -754,16 +792,20 @@ sem_t
 #		endif
 	}
 
-	free(nom_absolu);
-
 	return(semaphore);
 }
 
 int
 sem_close_SysV(sem_t *semaphore)
 {
+	// Ferme un sémaphore nommé créé par sem_open_SysV()
 #	ifndef OS2
 
+	if ((*semaphore).path != NULL)
+	{
+		free((*semaphore).path);
+	}
+
 	free(semaphore);
 	return(0);
 
@@ -811,12 +853,9 @@ sem_close_SysV(sem_t *semaphore)
 int
 sem_unlink_SysV(const char *nom)
 {
+	// Détruit un sémaphore nommé créé par sem_open_SysV()
 #	ifndef OS2
 
-	sem_t				semaphore;
-
-	struct sembuf		commande;
-
 	unsigned char		*nom_absolu;
 
 	if ((nom_absolu = malloc((strlen(chemin_semaphores_SysV) + strlen(nom)
@@ -826,28 +865,7 @@ sem_unlink_SysV(const char *nom)
 	}
 
 	sprintf(nom_absolu, "%s%s", chemin_semaphores_SysV, nom);
-
-	if ((semaphore = semget(ftok(nom_absolu, 1), 0, 0)) == -1)
-	{	
-		free(nom_absolu);
-		return(EINVAL);
-	}
-
-	commande.sem_num = 0;
-	commande.sem_op = 0;
-	commande.sem_flg = 0;
-
-	if (semop(semaphore, &commande, 1) == -1)
-	{
-		free(nom_absolu);
-		return(EINVAL);
-	}
-
-	if (semctl(semaphore, IPC_RMID, 0) == -1)
-	{
-		free(nom_absolu);
-		return(EINVAL);
-	}
+	semctl(semget(ftok(nom_absolu, 1), 0, 0), IPC_RMID, 0);
 
 	if (unlink(nom_absolu) == -1)
 	{