*corection de la fonction msgSpaceListUnlock
This commit is contained in:
parent
1007ca56c6
commit
a1c27d5b98
1 changed files with 48 additions and 30 deletions
|
@ -4,43 +4,61 @@
|
||||||
// verouille le semaphore de la liste
|
// verouille le semaphore de la liste
|
||||||
|
|
||||||
int msgSpaceListLock(){
|
int msgSpaceListLock(){
|
||||||
sem_t * spacesListSemFd;
|
sem_t * spacesListSemFd;
|
||||||
msgSpaceListSemId spacesListSemId;
|
msgSpaceListSemId spacesListSemId;
|
||||||
|
|
||||||
/*Ouverture d'un verrou d'un semafore*/
|
/*Ouverture d'un verrou d'un semafore*/
|
||||||
//TODO: remplacer par la bonne valeur d'initialisation du
|
//TODO: remplacer par la bonne valeur d'initialisation du
|
||||||
//semaphore
|
//semaphore
|
||||||
spacesListSemFd=sem_open(spacesListSemId,O_CREAT|O_EXCL,0666,1024);
|
spacesListSemFd=sem_open(spacesListSemId,O_CREAT|O_EXCL,0666,1024);
|
||||||
if(spacesListSemFd==SEM_FAILED){
|
if(spacesListSemFd==SEM_FAILED){
|
||||||
NZG_ERROR("sem_open",spacesListSemId);
|
NZG_ERROR("sem_open",spacesListSemId);
|
||||||
return -1;
|
return -1;
|
||||||
}
|
}
|
||||||
|
|
||||||
/*Pose d'un semafore et bloque*/
|
/*Pose d'un semaphore et le verrouille*/
|
||||||
if(sem_wait(spacesListSemFd)==-1){
|
if(sem_wait(spacesListSemFd)==-1){
|
||||||
NZG_ERROR("sem_wait",spacesListSemId);
|
NZG_ERROR("sem_wait",spacesListSemId);
|
||||||
return -1;
|
return -1;
|
||||||
}
|
}
|
||||||
return 0;
|
|
||||||
|
|
||||||
|
/* Ferme le semaphore*/
|
||||||
|
if(sem_close(spacesListSemFd)==-1){
|
||||||
|
NZG_ERROR("sem_close",spacesListSemId);
|
||||||
|
return -1;
|
||||||
|
}
|
||||||
|
|
||||||
|
return 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
// deverouille le semaphore de la liste
|
// deverouille le semaphore de la liste
|
||||||
int msgSpaceListUnlock(){
|
int msgSpaceListUnlock(){
|
||||||
sem_t * spacesListSemFd;
|
sem_t * spacesListSemFd;
|
||||||
msgSpaceListSemId spacesListSemId;
|
msgSpaceListSemId spacesListSemId;
|
||||||
|
|
||||||
/* Ferme le semaphore*/
|
/*Ouverture dun semaphore*/
|
||||||
if(sem_close(spacesListSemFd)==-1){
|
spacesListSemFd=sem_open(spacesListSemId,O_CREAT|O_EXCL,0666,1024);
|
||||||
NZG_ERROR("sem_close",spacesListSemId);
|
if(spacesListSemFd==SEM_FAILED){
|
||||||
return -1;
|
NZG_ERROR("sem_open",spacesListSemId);
|
||||||
}
|
return -1;
|
||||||
/*semaphore non bloquant*/
|
}
|
||||||
if (sem_trywait(spacesListSemFd)==-1){
|
|
||||||
NZG_ERROR("sem_trywait",spacesListSemId);
|
|
||||||
return -1;
|
/*Relachement du semaphore*/
|
||||||
}
|
if(sem_post(spacesListSemFd)==-1){
|
||||||
return 0;
|
NZG_ERROR("sem_relache",spacesListSemId);
|
||||||
|
return -1;
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
/* Ferme le semaphore*/
|
||||||
|
if(sem_close(spacesListSemFd)==-1){
|
||||||
|
NZG_ERROR("sem_close",spacesListSemId);
|
||||||
|
return -1;
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
return 0;
|
||||||
};
|
};
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue