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-21 14:46:24 +00:00 committed by Glenn Y. Rolland
parent e085e22af4
commit f76e0520a1
3 changed files with 40 additions and 18 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

44
src/nzg_allocate.c
View file

@ -23,11 +23,18 @@ void * msgAllocate(msgSpace *space,
* qui sera libéré le plus rapidement */ * qui sera libéré le plus rapidement */
float semPoolCoef[space->poolNb]; float semPoolCoef[space->poolNb];
int idxPoolOptimum; int idxPoolOptimum;
bool gotSem;
sem_t * semFd; bool gotRessourceSem;
int * sval;
msgPoolDataId poolDataId;
sem_t * poolDataSemFd;
msgPoolDataSemId ressourceSemId;
sem_t * ressourceSemFd;
int * ressourceSemVal;
float minPoolCoef; float minPoolCoef;
/* TODO: verifier le premier arg du shm_open */ /* TODO: verifier le premier arg du shm_open */
mSPoolDataTabFd=shm_open(space->poolDataId,O_RDWR,MSGSPACE_DEFAULT_MODE); mSPoolDataTabFd=shm_open(space->poolDataId,O_RDWR,MSGSPACE_DEFAULT_MODE);
if (mSPoolDataTabFd == -1 ) { if (mSPoolDataTabFd == -1 ) {
@ -49,7 +56,7 @@ void * msgAllocate(msgSpace *space,
return NULL; return NULL;
} }
gotSem=false; gotRessourceSem=false;
int gotIdx=-1; int gotIdx=-1;
/* initialisation des coefs */ /* initialisation des coefs */
@ -60,21 +67,22 @@ void * msgAllocate(msgSpace *space,
int nbLockedSem=0; int nbLockedSem=0;
if ( pool == ANYPOOL){ if ( pool == ANYPOOL){
// choisir le pool au hasard (ou presque) // choisir le pool au hasard (ou presque)
poolDataSemFd=sem_open(space->poolDataSemId,0);
for(i=0; i<(space->poolNb); i++) { for(i=0; i<(space->poolNb); i++) {
if(mSPoolDataTab[i].bufferSize >= taille) { if(mSPoolDataTab[i].bufferSize >= taille) {
/* choisir le numero du semaphore /* 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 */
semFd = sem_open(mSPoolDataTab[i].id,0); ressourceSemFd = sem_open(mSPoolDataTab[i].id,0);
/* on remplit le tableau avec les valeurs des semaphores */ /* on remplit le tableau avec les valeurs des semaphores */
sem_getvalue(semFd, sval); sem_getvalue(ressourceSemFd, ressourceSemVal);
if ((*sval) < 0){ if ((*ressourceSemVal) < 0){
semPoolCoef[nbLockedSem] = (float) (- (*sval) / mSPoolDataTab[i].bufferNb); semPoolCoef[nbLockedSem] = (float) (- (*ressourceSemVal) / mSPoolDataTab[i].bufferNb);
nbLockedSem++; nbLockedSem++;
} }
if(sem_trywait(semFd)) { if(sem_trywait(ressourceSemFd)) {
/* choisir la 1ere pool de taille plus grande /* choisir la 1ere pool de taille plus grande
* libre si possible */ * libre si possible */
gotSem=true; gotRessourceSem=true;
gotIdx=i; gotIdx=i;
strcpy(resultPoolID,mSPoolDataTab[gotIdx].id); strcpy(resultPoolID,mSPoolDataTab[gotIdx].id);
break; break;
@ -82,7 +90,7 @@ void * msgAllocate(msgSpace *space,
} // if buffSize > taille } // if buffSize > taille
} // for } // for
if (!gotSem) { if (!gotRessourceSem) {
minPoolCoef= semPoolCoef[0]; minPoolCoef= semPoolCoef[0];
idxPoolOptimum = 0; idxPoolOptimum = 0;
/* on cherche le pool avec le moins de lock poses / nbre de buffer /* on cherche le pool avec le moins de lock poses / nbre de buffer
@ -99,7 +107,7 @@ 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 {
if (sem_wait(semFd) < 0){ if (sem_wait(ressourceSemFd) < 0){
perror("sem_wait"); perror("sem_wait");
} }
strncpy(resultPoolID, strncpy(resultPoolID,
@ -110,8 +118,8 @@ void * msgAllocate(msgSpace *space,
} }
}else { }else {
semFd=sem_open(mSPoolDataTab[i].id,0); ressourceSemFd=sem_open(mSPoolDataTab[i].id,0);
if (sem_wait(semFd) < 0){ if (sem_wait(ressourceSemFd) < 0){
perror("sem_wait"); perror("sem_wait");
} }
@ -121,6 +129,14 @@ void * msgAllocate(msgSpace *space,
); );
} }
/* on a acqui un semaphore pour la ressouce */
/* on modifie maintenant les données */
/* TODO:
dataRWsem=semOpen(,0);
sem_wait(dataRWsem);
sem_close(dataRWsem);
*/
/* trouver un buffer libre, ou dormir */ /* trouver un buffer libre, ou dormir */
/* TODO: mapper le buffer dans l'esp addr du proc */ /* TODO: mapper le buffer dans l'esp addr du proc */

9
src/nzg_ids.c
View file

@ -17,15 +17,18 @@ int msgSpaceIdIntern(msgSpaceId dest,const msgSpaceId src ){
return 0; return 0;
} }
int msgPoolSemIdIntern(msgSemId destSemId,const msgPoolDataId srcPoolId ){ int msgPoolSemIdIntern(
msgPoolSemId destSemId,
const msgSpaceId srcPoolId,
int poolIdx){
if (strlen(srcPoolId)>MSGSPACE_ID_LEN*4){ if (strlen(srcPoolId)>MSGSPACE_ID_LEN*4){
return -1; return -1;
} }
/* sprintf(resNzgId,"/tmp/.nzg-%s",(char *)spaceId); */ /* sprintf(resNzgId,"/tmp/.nzg-%s",(char *)spaceId); */
#ifdef _NZG_REALFILEID #ifdef _NZG_REALFILEID
sprintf(destSemId,"/tmp/nzgPoolData%s",(char *)srcPoolId); sprintf(destSemId,"/tmp/nzgPoolSem%s-%d",(char *)srcPoolId,poolIdx);
#else #else
sprintf(destSemId,"/nzgPoolData%s",(char *)srcPoolId); sprintf(destSemId,"/nzgPoolSem%s-%d",(char *)srcPoolId,poolIdx);
#endif #endif
return 0; return 0;
} }

5
src/nzg_iface.h
View file

@ -11,8 +11,10 @@ typedef char msgSpaceListId[4*MSGSPACE_ID_LEN];
typedef char msgSpaceListElemId[4*MSGSPACE_ID_LEN]; typedef char msgSpaceListElemId[4*MSGSPACE_ID_LEN];
typedef char msgPoolDataId[4*MSGSPACE_ID_LEN]; typedef char msgPoolDataId[4*MSGSPACE_ID_LEN];
typedef char msgPoolDataSemId[4*MSGSPACE_ID_LEN];
typedef char msgPoolId[4*MSGSPACE_ID_LEN]; typedef char msgPoolId[4*MSGSPACE_ID_LEN];
typedef char msgSemId[4*MSGSPACE_ID_LEN]; typedef char msgPoolSemId[4*MSGSPACE_ID_LEN];
typedef char msgQueueDataId[4*MSGSPACE_ID_LEN]; typedef char msgQueueDataId[4*MSGSPACE_ID_LEN];
typedef char msgQueueId[4*MSGSPACE_ID_LEN]; typedef char msgQueueId[4*MSGSPACE_ID_LEN];
@ -41,6 +43,7 @@ typedef struct MsgSpace {
int queueNb; int queueNb;
int pid; int pid;
msgPoolDataId poolDataId; msgPoolDataId poolDataId;
msgPoolDataSemId poolDataSemId;
} msgSpace; } msgSpace;