--- rpl/src/semaphores.c 2010/08/09 13:51:48 1.8 +++ rpl/src/semaphores.c 2010/08/13 21:00:37 1.9 @@ -121,7 +121,12 @@ sem_getvalue2(sem_t *semaphore, int *val ================================================================================ */ -extern unsigned char *chemin_semaphores_SysV; +#ifndef OS2 + 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 @@ -136,42 +141,148 @@ union semun int sem_init_SysV(sem_t *semaphore, int shared, unsigned int valeur) { +# ifndef OS2 + int ios; union semun argument; if (shared != 0) { - return(ENOSYS); + errno = ENOSYS; + return(-1); } (*semaphore) = semget(IPC_PRIVATE, 1, IPC_CREAT | IPC_EXCL | SEM_R | SEM_A); if ((*semaphore) == -1) { - return(EINVAL); + errno = EINVAL; + return(-1); } argument.val = valeur; ios = semctl((*semaphore), 0, SETVAL, argument); return(ios); + +# else + + sem_t *psem; + + psem = semaphore; + + if (shared != 0) + { + errno = ENOSYS; + return(-1); + } + + if (((*psem).cnt = malloc(sizeof(ULONG))) == NULL) + { + free(psem); + errno = ENOMEM; + return(-1); + } + + if (((*psem).nopened = malloc(sizeof(ULONG))) == NULL) + { + free((*psem).cnt); + free(psem); + errno = ENOMEM; + return(-1); + } + + if (DosCreateMutexSem(NULL, &((*psem).hmtx), 0, 0) != 0) + { + free((*psem).cnt); + free((*psem).nopened); + free(psem); + return(-1); + } + + if (DosCreateEventSem(NULL, &((*psem).hev), 0, (valeur != 0) ? 1 : 0) != 0) + { + DosCloseMutexSem((*psem).hmtx); + free((*psem).cnt); + free((*psem).nopened); + free(psem); + return(-1); + } + + (*(*psem).cnt) = valeur; + (*(*psem).nopened) = 1; + (*psem).shared = shared; + (*psem).allocated = 0; + + return(0); + +# endif } int sem_destroy_SysV(sem_t *semaphore) { +# ifndef OS2 + if (semctl((*semaphore), IPC_RMID, 0) == -1) { return(EINVAL); } return(0); + +# else + + sem_t *psem; + + psem = semaphore; + + if (DosRequestMutexSem((*psem).hmtx, SEM_INDEFINITE_WAIT) != 0) + { + return(EINVAL); + } + + if (DosCloseMutexSem((*psem).hmtx) != 0) + { + return(EINVAL); + } + + while(DosCloseEventSem((*psem).hev) == ERROR_SEM_BUSY) + { + DosPostEventSem((*psem).hev); + } + + (*(*psem).nopened)--; + + if ((*psem).shared == 0) + { + free((*psem).cnt); + free((*psem).nopened); + } + else + { + if ((*(*psem).nopened) == 0) + { + DosFreeMem((*psem).cnt); + } + } + + if ((*psem).allocated != 0) + { + free(psem); + } + + return(0); + +# endif } int sem_wait_SysV(sem_t *semaphore) { +# ifndef OS2 + struct sembuf commande; commande.sem_num = 0; @@ -180,15 +291,53 @@ sem_wait_SysV(sem_t *semaphore) if (semop((*semaphore), &commande, 1) == -1) { - return(EINVAL); + errno = EINVAL; + return(-1); + } + + return(0); + +# else + + sem_t *psem; + + ULONG cnt; + + psem = semaphore; + + if (DosWaitEventSem((*psem).hev, SEM_INDEFINITE_WAIT) != 0) + { + errno = EINVAL; + return(-1); } + if (DosRequestMutexSem((*psem).hmtx, SEM_INDEFINITE_WAIT) != 0) + { + errno = EINVAL; + return(-1); + } + + if ((*(*psem).cnt) > 0) + { + (*(*psem).cnt)--; + } + + if ((*(*psem).cnt) == 0) + { + DosResetEventSem((*psem).hev, &cnt); + } + + DosReleaseMutexSem((*psem).hmtx); return(0); + +# endif } int sem_trywait_SysV(sem_t *semaphore) { +# ifndef OS2 + struct sembuf commande; commande.sem_num = 0; @@ -197,20 +346,54 @@ sem_trywait_SysV(sem_t *semaphore) if (semop((*semaphore), &commande, 1) == -1) { - if (errno == EAGAIN) - { - return(EAGAIN); - } + return(-1); + } - return(EINVAL); + return(0); + +# else + + int ios; + + sem_t *psem; + + ULONG cnt; + + psem = semaphore; + + if ((ios = DosWaitEventSem((*psem).hev, SEM_IMMEDIATE_RETURN)) != 0) + { + errno = (ios == ERROR_TIMEOUT) ? EAGAIN : EINVAL; + return(-1); + } + + if (DosRequestMutexSem((*psem).hmtx, SEM_INDEFINITE_WAIT) != 0) + { + errno = EINVAL; + return(-1); + } + + if ((*(*psem).cnt) > 0) + { + (*(*psem).cnt)--; + } + + if ((*(*psem).cnt) == 0) + { + DosResetEventSem((*psem).hev, &cnt); } + DosReleaseMutexSem((*psem).hmtx); return(0); + +# endif } int sem_post_SysV(sem_t *semaphore) { +# ifndef OS2 + struct sembuf commande; commande.sem_num = 0; @@ -219,15 +402,38 @@ sem_post_SysV(sem_t *semaphore) if (semop((*semaphore), &commande, 1) == -1) { - return(EINVAL); + errno = EINVAL; + return(-1); } return(0); + +# else + + sem_t *psem; + + psem = semaphore; + + if (DosRequestMutexSem((*psem).hmtx, SEM_INDEFINITE_WAIT) != 0) + { + errno = EINVAL; + return(-1); + } + + (*(*psem).cnt)++; + DosPostEventSem((*psem).hev); + DosReleaseMutexSem((*psem).hmtx); + + return(0); + +# endif } int sem_getvalue_SysV(sem_t *semaphore, int *valeur) { +# ifndef OS2 + (*valeur) = semctl((*semaphore), 0, GETVAL); if ((*valeur) < 0) @@ -236,6 +442,25 @@ sem_getvalue_SysV(sem_t *semaphore, int } return(0); + +# else + + sem_t *psem; + + psem = semaphore; + + if (DosRequestMutexSem((*psem).hmtx, SEM_INDEFINITE_WAIT) != 0) + { + errno = EINVAL; + return(-1); + } + + (*valeur) = (*(*psem).cnt); + DosReleaseMutexSem((*psem).hmtx); + + return(0); + +# endif } sem_t @@ -247,7 +472,9 @@ sem_t sem_t *semaphore; +# ifndef OS2 union semun argument; +# endif unsigned char *nom_absolu; @@ -255,6 +482,17 @@ sem_t va_list liste; +# ifdef OS2 + sem_t *psem; + + PVOID base; + + unsigned char *ptr; + unsigned char *nom_segment; +# endif + +# ifndef OS2 + if ((nom_absolu = malloc((strlen(chemin_semaphores_SysV) + strlen(nom) + 1) * sizeof(unsigned char))) == NULL) { @@ -268,9 +506,63 @@ sem_t return(SEM_FAILED); } + (*psem).allocated = 1; + +# else + + if ((nom_segment = malloc((strlen(racine_memoire_OS2) + strlen(nom) + 1) + * sizeof(unsigned char))) == NULL) + { + return(SEM_FAILED); + } + + sprintf(nom_segment, "%s%s", racine_memoire_OS2, nom); + ptr = nom_segment; + + while((*ptr) != d_code_fin_chaine) + { + if ((*ptr) == '/') + { + (*ptr) = '\\'; + } + + ptr++; + } + + if ((nom_absolu = malloc((strlen(racine_semaphores_OS2) + strlen(nom) + + 2) * sizeof(unsigned char))) == NULL) + { + return(SEM_FAILED); + } + + sprintf(nom_absolu, "%s%s", racine_semaphores_OS2, nom); + ptr = nom_absolu; + + while((*ptr) != d_code_fin_chaine) + { + if ((*ptr) == '/') + { + (*ptr) = '\\'; + } + + ptr++; + } + + (*(ptr + 1)) = d_code_fin_chaine; + + if ((psem = malloc(sizeof(sem_t))) == NULL) + { + return(SEM_FAILED); + } + +# endif + if ((oflag & O_CREAT) == 0) { // 2 arguments + +# ifndef OS2 + (*semaphore) = semget(ftok(nom_absolu, 1), 0, 0); if ((*semaphore) == -1) @@ -280,6 +572,75 @@ sem_t return(SEM_FAILED); } + +# else + + if ((psem = malloc(sizeof(sem_t))) == NULL) + { + free(nom_absolu); + free(nom_segment); + return(SEM_FAILED); + } + + (*ptr) = 'M'; + + if (DosOpenMutexSem(nom_absolu, &((*psem).hmtx)) != 0) + { + free(psem); + free(nom_absolu); + free(nom_segment); + + return(SEM_FAILED); + } + + (*ptr) = 'S'; + + if (DosOpenEventSem(nom_absolu, &((*psem).hev)) != 0) + { + DosCloseMutexSem((*psem).hmtx); + + free(psem); + free(nom_absolu); + free(nom_segment); + + return(SEM_FAILED); + } + + if (DosGetNamedSharedMem(&base, nom_segment, PAG_WRITE | PAG_READ) != 0) + { + DosCloseMutexSem((*psem).hmtx); + + free(nom_absolu); + free(nom_segment); + free(psem); + + return(SEM_FAILED); + } + + free(nom_segment); + + (*psem).cnt = (ULONG *) base; + (*psem).nopened = ((ULONG *) base) + 1; + (*psem).shared = 1; + + if (DosRequestMutexSem((*psem).hmtx, SEM_INDEFINITE_WAIT) != 0) + { + DosCloseMutexSem((*psem).hmtx); + + free(nom_absolu); + free(nom_segment); + free(psem); + + return(SEM_FAILED); + } + + (*((*psem).nopened))++; + + DosReleaseMutexSem((*psem).hmtx); + + semaphore = psem; + +# endif } else { @@ -293,6 +654,8 @@ sem_t valeur = va_arg(liste, unsigned int); va_end(liste); +# ifndef OS2 + (*semaphore) = semget(ftok(nom_absolu, 1), 1, ((oflag & O_CREAT) == 0) ? 0 : IPC_CREAT | ((oflag & O_EXCL) == 0) ? 0 : IPC_EXCL | @@ -309,6 +672,64 @@ sem_t argument.val = valeur; semctl((*semaphore), 0, SETVAL, argument); + +# else + + if ((psem = malloc(sizeof(sem_t))) == NULL) + { + free(nom_absolu); + free(nom_segment); + + return(SEM_FAILED); + } + + (*ptr) = 'M'; + + if (DosCreateMutexSem(nom_absolu, &((*psem).hmtx), 0, 0) != 0) + { + free(psem); + free(nom_absolu); + free(nom_segment); + + return(SEM_FAILED); + } + + (*ptr) = 'S'; + + if (DosCreateEventSem(nom_absolu, &((*psem).hev), 0, + (valeur != 0) ? 1 : 0) != 0) + { + DosCloseMutexSem((*psem).hmtx); + + free(nom_absolu); + free(nom_segment); + free(psem); + + return(SEM_FAILED); + } + + if (DosAllocSharedMem(&base, nom_segment, 2 * sizeof(ULONG), + PAG_WRITE | PAG_READ | PAG_COMMIT) != 0) + { + DosCloseMutexSem((*psem).hmtx); + + free(nom_absolu); + free(nom_segment); + free(psem); + + return(SEM_FAILED); + } + + free(nom_segment); + + (*psem).cnt = (ULONG *) base; + (*psem).nopened = ((ULONG *) base) + 1; + (*(*psem).cnt) = valeur; + (*(*psem).nopened) = 1; + (*psem).shared = 1; + semaphore = psem; + +# endif } free(nom_absolu); @@ -319,13 +740,57 @@ sem_t int sem_close_SysV(sem_t *semaphore) { +# ifndef OS2 + free(semaphore); return(0); + +# else + + sem_t *psem; + + psem = semaphore; + + if (DosCloseMutexSem((*psem).hmtx) != 0) + { + return(EINVAL); + } + + while(DosCloseEventSem((*psem).hev) == ERROR_SEM_BUSY) + { + DosPostEventSem((*psem).hev); + } + + (*(*psem).nopened)--; + + if ((*psem).shared == 0) + { + free((*psem).cnt); + free((*psem).nopened); + } + else + { + if ((*(*psem).nopened) == 0) + { + DosFreeMem((*psem).cnt); + } + } + + if ((*psem).allocated != 0) + { + free(psem); + } + + return(0); + +# endif } int sem_unlink_SysV(const char *nom) { +# ifndef OS2 + sem_t semaphore; struct sembuf commande; @@ -371,6 +836,12 @@ sem_unlink_SysV(const char *nom) free(nom_absolu); return(0); + +# else + + return(0); + +# endif } #endif