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 09:59:56 +00:00 committed by Glenn Y. Rolland
parent d4bfee18aa
commit b55e7e61be
2 changed files with 19 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
src/nzg_allocate.c
View file

@ -28,9 +28,9 @@ void * msgAllocate(msgSpace *space,
sem_t * ressourceSemFd=NULL; sem_t * ressourceSemFd=NULL;
int * ressourceSemVal=NULL; int * ressourceSemVal=NULL;
float minPoolCoef; float minPoolCoef;
int selectedIdx; int selectedPoolIndex;
selectedIdx=-1; selectedPoolIndex=-1;
/* TODO: verifier le premier arg du shm_open */ /* TODO: verifier le premier arg du shm_open */
mSPoolDataTabFd=shm_open(space->poolDataTabId,O_RDWR,MSGSPACE_DEFAULT_MODE); mSPoolDataTabFd=shm_open(space->poolDataTabId,O_RDWR,MSGSPACE_DEFAULT_MODE);
@ -90,7 +90,7 @@ void * msgAllocate(msgSpace *space,
/* choisir la 1ere pool de taille plus grande /* choisir la 1ere pool de taille plus grande
* libre si possible */ * libre si possible */
gotRessourceSem=true; gotRessourceSem=true;
selectedIdx=i; selectedPoolIndex=i;
break; break;
} }
if( sem_close(ressourceSemFd) <0){ if( sem_close(ressourceSemFd) <0){
@ -117,16 +117,16 @@ void * msgAllocate(msgSpace *space,
/* il n'y a aucune pool dont la taille satisfait la demande */ /* il n'y a aucune pool dont la taille satisfait la demande */
return NULL; return NULL;
} else { } else {
selectedIdx=idxPoolOptimum; selectedPoolIndex=idxPoolOptimum;
} }
} }
}else { }else {
selectedIdx=pool; selectedPoolIndex=pool;
} }
if (!gotRessourceSem){ if (!gotRessourceSem){
strcpy(resultPoolId,mSPoolDataTab[selectedIdx].id); strcpy(resultPoolId,mSPoolDataTab[selectedPoolIndex].id);
msgPoolSemIdIntern(ressourceSemId,space->id,selectedIdx); msgPoolSemIdIntern(ressourceSemId,space->id,selectedPoolIndex);
ressourceSemFd=sem_open(ressourceSemId,O_CREAT,SEM_DEFAULT_MODE,0); ressourceSemFd=sem_open(ressourceSemId,O_CREAT,SEM_DEFAULT_MODE,0);
if(ressourceSemFd==SEM_FAILED){ if(ressourceSemFd==SEM_FAILED){
perror("sem_open"); perror("sem_open");
@ -146,12 +146,12 @@ void * msgAllocate(msgSpace *space,
/* 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 */
//TODO:int bufferFreeIndex = msgBufferGetFreeIndex(space,selectedIdx); //TODO:int bufferFreeIndex = msgBufferGetFreeIndex(space,selectedPoolIndex);
/*TODO: mapper le buffer libre dans l'esp addr du proc */ /*TODO: mapper le buffer libre dans l'esp addr du proc */
//TODO: //TODO:
/* - on s'enregistre aupres de ce buffer */ /* - on s'enregistre aupres de ce buffer */
//TODO: msgBufferAttachProc(space,selectedIdx,resultAddr); //TODO: msgBufferAttachProc(space,selectedPoolIndex,resultAddr);
sem_close(poolDataTabSemFd); sem_close(poolDataTabSemFd);

10
src/nzg_buffer.c
View file

@ -0,0 +1,10 @@
#include "libnazgul.h"
#include "nzg_ids.h"
int msgBufferGetFreeIndex(msgSpaceId spaceId,int poolIndex){
return -1;
}
int msgBufferAttachProc(msgSpaceId spaceId,int poolIndex,void * addr){
return -1;
}