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

et voila les semaphores qui pointent le bout de leur nez ;)

Browse source
This commit is contained in:
stormrider1982 2004-02-20 21:47:08 +00:00
parent 27633f3ab6
commit d63bce6b91
3 changed files with 12 additions and 59 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
src/allocate.c
View file

@ -10,18 +10,18 @@
#define ANYPOOL -1 #define ANYPOOL -1
#define SPECIFICPOOL 0 #define SPECIFICPOOL 0
msgAllocate(msgSpace *space, void * msgAllocate(msgSpace *space,
int pool, int pool,
int taille, int taille,
int option=0 int option=0
){ ){
void * resultAddr; void * resultAddr;
int i; int i, mSPoolDataTabFd;
msgPoolDataId resultPoolID; msgPoolDataId resultPoolID;
mSPoolDataTabFd=shm_open( sem_t * sem;
space->msgPoolDataTabID,O_RDWR,MSGSPACE_DEFAULT_MODE); mSPoolDataTabFd=shm_open(space->msgPoolDataTabID,O_RDWR,MSGSPACE_DEFAULT_MODE);
if (mSFd == -1 ) { if (mSFd == -1 ) {
fprintf( stderr, "msgSpace %s creation failed: %s\n", fprintf( stderr, "msgSpace %s creation failed: %s\n",
(char*)nzgId, (char*)nzgId,
@ -44,7 +44,6 @@ msgAllocate(msgSpace *space,
bool gotSem=false; bool gotSem=false;
int gotIdx=-1; int gotIdx=-1;
int
if (pool == ANYPOOL){ if (pool == ANYPOOL){
/* se debrouiller pour choisir la 1ere pool /* se debrouiller pour choisir la 1ere pool
@ -53,7 +52,7 @@ msgAllocate(msgSpace *space,
if(msgPoolDataTab[i].bufferSize >= taille) { if(msgPoolDataTab[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 */
gotIdx=i; gotIdx=i;
if(sem_trywait(sem)) { if(sem_trywait(sem)) {
gotSem=true; gotSem=true;
@ -68,6 +67,7 @@ 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 */ /* mapper le buffer dans l'esp addr du proc */

2
src/nzg_iface.h
View file

@ -27,7 +27,7 @@ typedef struct MsgPoolData {
int bufferNb; int bufferNb;
int bufferSize; int bufferSize;
int allocDispBuffer; int allocDispBuffer;
bool allocOverload; sem_t * allocOverload;
} msgPoolData; } msgPoolData;
/* TODO: queueId */ /* TODO: queueId */

55
src/nzg_pool.c
View file

@ -12,6 +12,7 @@ int msgPoolCreate(
int poolFd; int poolFd;
static int poolNb; static int poolNb;
msgSpacePoolId id; msgSpacePoolId id;
sem_t * sem;
if (msgSpacePoolId2nzgPoolId(id,poolId,poolNb) == -1){ if (msgSpacePoolId2nzgPoolId(id,poolId,poolNb) == -1){
fprintf( stderr, "msgPoolId creation failed for id %s\n", fprintf( stderr, "msgPoolId creation failed for id %s\n",
@ -26,6 +27,9 @@ int msgPoolCreate(
return -1; return -1;
} }
// on met un semaphore sur le pool
sem = sem_open(id, O_CREAT|O_EXCL, poolNb);
// 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
if (ftruncate(poolFd, (buffSize*buffNb)) == -1){ if (ftruncate(poolFd, (buffSize*buffNb)) == -1){
@ -50,54 +54,3 @@ int msgSpacePoolId2nzgPoolId(msgSpacePoolId dest,msgSpacePoolId src, int num){
#endif #endif
return 0; return 0;
} }
//TODO: msgPoolAllocate
// //donne l'adr en mappant in the memory
//poolAddr = mmap(NULL, sizeof(*msgPool), PROT_NONE, MAP_SHARED, poolFd, 0);
msgPool * msgPoolAllocate(int poolIdx, msgSpace *msg) {
msgPool * poolAddr;
//msgSpacePoolDataId dataId;
msgPoolData * poolData;
int i, buffSize, poolId;
sem_t * sem;
poolId = -1;
// TODO:récupérer l'id du poolData dans le msgSpace
// détacher le morceau de mémoire du processus
//dataId = msg->poolDataId;
// TODO:récupérer le poolData qui correspond à notre poolIdx.
// attacher la zone mémoire correspondant à l'Id
// utiliser des sémaphores pour vérouiller les acces en modif
// sur la poolData de notre
buffSize = poolData[poolIdx].bufferSize;
if(poolData[poolIdx].allocOverload == 1) {
for(i=0; i<128; i++) {
if( (poolData[i].allocOverload != 1)
&& (poolData[i].bufferSize >= buffSize) ) {
buffSize = poolData[i].bufferSize;
poolId = i;
}
}
}
//donne l'adr en mappant in the memory
//GYR:poolAddr = mmap(NULL, sizeof(*msgPool), PROT_NONE, MAP_SHARED, poolFd, 0);
if(poolAddr == MAP_FAILED) {
fprintf( stderr, "mmap failed: %s\n", strerror( errno ) );
return NULL;
}
// semaphores
sem = sem_open(poolData[(poolId != -1)?poolId:poolIdx].id, O_CREAT|O_EXCL, 0);
sem_wait(sem);
// on renvoie le pointeur sur le bon pool
return poolAddr;
}