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

on progresse ;)

Browse source
This commit is contained in:
stormrider1982 2004-02-21 00:03:35 +00:00 committed by Glenn Y. Rolland
parent 1ede8180e9
commit 347995e6fe
2 changed files with 45 additions and 20 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

49
src/allocate.c
View file

@ -13,18 +13,21 @@
void * msgAllocate(msgSpace *space, void * msgAllocate(msgSpace *space,
int pool, int pool,
int taille, int taille,
int option=0 int option
){ ){
void * resultAddr; void * resultAddr;
int i, mSPoolDataTabFd; int i, mSPoolDataTabFd;
msgPoolDataId resultPoolID; msgSpacePoolId resultPoolID;
float sems[space->poolNb]; /* tableau des valeurs des sems/pool pour identifier le pool
qui sera libéré le plus rapidement */
sem_t * sem; sem_t * sem;
mSPoolDataTabFd=shm_open(space->msgPoolDataTabID,O_RDWR,MSGSPACE_DEFAULT_MODE); /* TODO: verifier le premier arg du shm_open */
if (mSFd == -1 ) { mSPoolDataTabFd=shm_open(space->poolDataId,O_RDWR,MSGSPACE_DEFAULT_MODE);
fprintf( stderr, "msgSpace %s creation failed: %s\n", if (mSPoolDataTabFd == -1 ) {
(char*)nzgId, fprintf( stderr, "Allocate %s failed: %s\n",
(char*)space->poolDataId,
strerror( errno ) ); strerror( errno ) );
return NULL; return NULL;
} }
@ -43,25 +46,45 @@ void * msgAllocate(msgSpace *space,
bool gotSem=false; bool gotSem=false;
int gotIdx=-1; int gotIdx=-1;
int * sval;
if (pool == ANYPOOL){ if (pool == ANYPOOL){
/* se debrouiller pour choisir la 1ere pool /* se debrouiller pour choisir la 1ere pool
de taille plus grande libre si possible */ de taille plus grande libre si possible */
for(i=0; i<(space->poolNb); i++) { for(i=0; i<(space->poolNb); i++) {
if(msgPoolDataTab[i].bufferSize >= taille) { if(mSPoolDataTab[i].bufferSize >= taille) {
/* TODO: choisir le numero du semaphore /* TODO: choisir le numero du semaphore
en fonction du nombre de lock poses / nombre de buffer */ en fonction du nombre de lock poses / nombre de buffer */
sem = sem_open(mSPoolDataTab[i]->id,O_CREAT);
gotIdx=i; gotIdx=i;
if(sem_trywait(sem)) { if(sem_trywait(sem)) {
gotSem=true; gotSem=true;
resultPoolID=mSPoolDataTab[gotIdx]->id;
break; break;
} }
else {
// on remplit le tableau avec les valeurs des semaphores
sem_getvalue(sem, sval);
sems[i] = (float*)sval / (mSPoolDataTab[i]->bufferNb);
} }
} }
resultPoolID=mSPoolDataTab[i]->id;
} else { if(!gotSem) {
float min = sems[0];
int idxPoolOptimum;
// on cherche le pool avec le moins de lock poses / nbre de buffer
for(i=1; i<(space->poolNb); i++) {
if(sems[i] < min) {
min = sems[i];
idxPoolOptimum = i;
}
}
resultPoolID=mSPoolDataTab[idxPoolOptimum]->id;
}
}
}else {
resultPoolID=mSPoolDataTab[pool]->id; resultPoolID=mSPoolDataTab[pool]->id;
@ -70,8 +93,10 @@ void * msgAllocate(msgSpace *space,
/* TODO: trouver un buffer libre, ou dormir */ /* TODO: trouver un buffer libre, ou dormir */
/* mapper le buffer dans l'esp addr du proc */ /* TODO: mapper le buffer dans l'esp addr du proc */
/* TODO: unmapper le msgPoolDataTab */ /* TODO: unmapper le msgPoolDataTab */
return resultAddr;
return resultAddr;
} }

2
src/nzg_pool.c
View file

@ -28,7 +28,7 @@ int msgPoolCreate(
} }
// on met un semaphore sur le pool // on met un semaphore sur le pool
sem = sem_open(id, O_CREAT|O_EXCL, poolNb); sem = sem_open(id, O_CREAT|O_EXCL, 0666, buffNb);
// on met le pool a la taille voulue pour qu'il // on met le pool a la taille voulue pour qu'il
// puisse contenir les buffs // puisse contenir les buffs