glenux-school/l3.libnazgul
glenux-school/l3.libnazgul
1
1
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

*** empty log message ***

Browse source
This commit is contained in:
glenux 2004-02-22 22:46:09 +00:00
parent c135ae172c
commit e16fcbad78
3 changed files with 45 additions and 35 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
src/nzg_iface.h
View file

@ -8,6 +8,7 @@ typedef enum { true=1, false=0} bool;
typedef char msgSpaceId[MSGSPACE_ID_LEN]; typedef char msgSpaceId[MSGSPACE_ID_LEN];
typedef char msgSpaceListId[4*MSGSPACE_ID_LEN]; typedef char msgSpaceListId[4*MSGSPACE_ID_LEN];
typedef char msgSpaceListSemId[4*MSGSPACE_ID_LEN];
typedef char msgSpaceListElemId[4*MSGSPACE_ID_LEN]; typedef char msgSpaceListElemId[4*MSGSPACE_ID_LEN];
typedef char msgPoolDataTabId[4*MSGSPACE_ID_LEN]; typedef char msgPoolDataTabId[4*MSGSPACE_ID_LEN];

26
src/nzg_spaceListInit.c
View file

@ -7,27 +7,29 @@
// //
// crée également un sémaphore de gestion de liste // crée également un sémaphore de gestion de liste
// a verouiller avant toute modification // a verouiller avant toute modification
int msgSpaceListInit();
int msgSpaceListInit(){ int msgSpaceListInit(){
int descMemory; int descMemory;
msgSpaceListElemId idList; sem_t * spacesListSemFd;
/*Fait un segment de memoir partager sur espace de listelement*/ msgSpaceListSemId spacesListSemId;
if( (descMemory=shm_open(idList,O_RDWR|O_CREAT|O_EXCL|O_TRUNC,0600))==-1){ msgSpaceListElemId spacesListId;
printf("Erreur de shmopen"); /*Fait un segment de memoir partager sur espace de listelement*/
descMemory=shm_open(spacesListId,O_RDWR|O_CREAT|O_EXCL|O_TRUNC,0600);
if (descMemory == -1){
NZG_ERROR("shm_open",spacesListId);
return -1;
} }
/*Creation de semaphore*/ /*Creation de semaphore*/
sem=sem_open(spaceList,O_CREAT|O_EXCL,0666,1024); spacesListSemFd=sem_open(spacesListSemId,O_CREAT|O_EXCL,0666,1024);
if(sem==SEM_FAILED){ if(spacesListSemFd==SEM_FAILED){
printf("erreur de semaphore"); NZG_ERROR("sem_open",spacesListSemId);
return -1; return -1;
} }
/*Verouille le semaphore*/ /*Verouille le semaphore*/
if(sem_wait(sem)==-1){ if(sem_wait(spacesListSemFd)==-1){
printf("erreur pour l'ajout d'un semaphore"); NZG_ERROR("sem_wait",spacesListSemId);
return -1; return -1;
} }

53
src/nzg_spaceListLocking.c
View file

@ -4,36 +4,43 @@
// verouille le semaphore de la liste // verouille le semaphore de la liste
int msgSpaceListLock(){ int msgSpaceListLock(){
sem_t * spacesListSemFd;
msgSpaceListSemId spacesListSemId;
/*Ouverture d'un verrou d'un semafore*/ /*Ouverture d'un verrou d'un semafore*/
sem=sem_open(spaceList,O_CREAT|O_EXCL,0666,1024); //TODO: remplacer par la bonne valeur d'initialisation du
if(sem==SEM_FAILED){ //semaphore
printf("erreur de semaphore"); spacesListSemFd=sem_open(spacesListSemId,O_CREAT|O_EXCL,0666,1024);
return -1; if(spacesListSemFd==SEM_FAILED){
} NZG_ERROR("sem_open",spacesListSemId);
return -1;
}
/*Pose d'un semafore et bloque*/ /*Pose d'un semafore et bloque*/
if(sem_wait(sem)==-1){ if(sem_wait(spacesListSemFd)==-1){
printf("erreur pour l'ajout d'un semaphore"); NZG_ERROR("sem_wait",spacesListSemId);
return -1; return -1;
} }
return 0; return 0;
} }
// deverouille le semaphore de la liste // deverouille le semaphore de la liste
int msgSpaceListUnlock(){ int msgSpaceListUnlock(){
/* Ferme le semaphore*/ sem_t * spacesListSemFd;
if(sem_close(sem)==-1){ msgSpaceListSemId spacesListSemId;
printf("erreur sem_close");
return -1; /* Ferme le semaphore*/
} if(sem_close(spacesListSemFd)==-1){
/*semaphore non bloquant*/ NZG_ERROR("sem_close",spacesListSemId);
if (sem_trywait(sem)==-1){ return -1;
printf("erreur sem_trywait"); }
return -1; /*semaphore non bloquant*/
} if (sem_trywait(spacesListSemFd)==-1){
return 0; NZG_ERROR("sem_trywait",spacesListSemId);
return -1;
}
return 0;
}; };