--- rpl/src/semaphores.c 2011/08/09 11:31:37 1.28 +++ rpl/src/semaphores.c 2011/09/18 12:42:50 1.29 @@ -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,61 @@ */ sem_t * -sem_init2(unsigned int valeur, enum t_semaphore semaphore) +sem_init2(unsigned int valeur, pid_t pid) +{ + sem_t *semaphore; + + unsigned char *chemin; + + if ((chemin = nom_segment_semaphore(pid)) == NULL) + { + return(SEM_FAILED); + } + + semaphore = sem_open(chemin, O_CREAT, (S_IRUSR | S_IWUSR), valeur); + free(chemin); + + return(semaphore); +} + + +sem_t * +sem_open2(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)); + 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 +124,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;