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

* modifié le selecteur ANYPOOL

Browse source 
* corrigé un bug de semaphore
This commit is contained in:
glenux 2004-02-23 10:01:26 +00:00
parent d316e51e84
commit c8091765fc
1 changed files with 9 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
src/nzg_allocate.c
View file

@ -89,7 +89,7 @@ void * msgAllocate(msgSpace *space,
printf("resVal < 0 : %d\n",ressourceSemVal); printf("resVal < 0 : %d\n",ressourceSemVal);
/* il y a ressourceSemVal processus qui attendent déja... */ /* il y a ressourceSemVal processus qui attendent déja... */
semPoolCoef[nbLockedSem] = semPoolCoef[nbLockedSem] =
(float) (- (ressourceSemVal) / mSPoolDataTabAddr[i].bufferNb); (float) ((1-ressourceSemVal) / mSPoolDataTabAddr[i].bufferNb);
nbLockedSem++; nbLockedSem++;
} }
if(sem_trywait(ressourceSemFd)==0) { if(sem_trywait(ressourceSemFd)==0) {
@ -146,7 +146,10 @@ void * msgAllocate(msgSpace *space,
return NULL; return NULL;
} }
printf("SemWait... %s\n",ressourceSemId); //TODO:virer la ligne suivante:
sem_getvalue(ressourceSemFd, &ressourceSemVal);
printf("SemWait... %s : %d\n",ressourceSemId,ressourceSemVal);
if (sem_wait(ressourceSemFd) < 0){ if (sem_wait(ressourceSemFd) < 0){
NZG_ERROR("sem_wait",ressourceSemId); NZG_ERROR("sem_wait",ressourceSemId);
sem_close(ressourceSemFd); sem_close(ressourceSemFd);
@ -157,8 +160,11 @@ void * msgAllocate(msgSpace *space,
/* on a acqui un semaphore pour la ressouce */ /* on a acqui un semaphore pour la ressouce */
/* on acquiert le droit de modifier les infos sur la ressource */ /* on acquiert le droit de modifier les infos sur la ressource */
poolDataTabSemFd=sem_open(space->poolDataTabSemId,O_CREAT,SEM_DEFAULT_MODE,1); poolDataTabSemFd=sem_open(space->poolDataTabSemId,O_CREAT,SEM_DEFAULT_MODE,1);
//sem_wait(poolDataTabSemFd);
/* on modifie maintenant les données */ /* on modifie maintenant les données */
/* - on récupere l'index du premier buffer libre */ /* - on récupere l'index du premier buffer libre */
bufferFreeIndex = msgBufferGetFreeIndex(mSPoolDataTabAddr,selectedPoolIndex); bufferFreeIndex = msgBufferGetFreeIndex(mSPoolDataTabAddr,selectedPoolIndex);
@ -174,6 +180,7 @@ void * msgAllocate(msgSpace *space,
//TODO: msgBufferAttachProc(space,selectedPoolIndex,resultAddr); //TODO: msgBufferAttachProc(space,selectedPoolIndex,resultAddr);
// sem_post(poolDataTabSemFd);
sem_close(poolDataTabSemFd); sem_close(poolDataTabSemFd);
/* TODO: unmapper le msgPoolDataTab */ /* TODO: unmapper le msgPoolDataTab */