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-25 08:50:44 +00:00
parent 1ef280444c
commit fe22a053d9
1 changed files with 12 additions and 34 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

42
src/get.c
View file

@ -7,9 +7,7 @@ void * msgGet(msgSpace * space,int queueIndex,int option){
msgQueueId queueId; msgQueueId queueId;
msgQueue * queue; msgQueue * queue;
msgQueueElemId oldElemId; msgQueueElemId oldElemId;
msgQueueElem * oldElem; msgQueueElem * oldElem;
int poolIndex;
// on teste la possibilité de lecture sur la liste... // on teste la possibilité de lecture sur la liste...
if (option == NONBLOCK){ if (option == NONBLOCK){
if (msgQueueReadTryLock(space->externId,queueIndex) <0){ if (msgQueueReadTryLock(space->externId,queueIndex) <0){
@ -32,37 +30,17 @@ void * msgGet(msgSpace * space,int queueIndex,int option){
// recupérer l'id de l'ancien element... // recupérer l'id de l'ancien element...
msgQueueRem(queue, oldElemId); msgQueueRem(queue, oldElemId);
oldElem = msgQueueElemOpen(oldElemId); oldElem = msgQueueElemOpen(oldElemId);
poolIndex=oldElem->poolIndex;
/* on récupere la taille des buffer dans la pool du buffer */ /* on récupere la taille des buffer dans la pool du buffer */
int bufferSize; int bufferSize;
msgPoolData * poolDataTab; msgPoolData * poolDataTab;
poolDataTab=msgPoolDataTabOpen(space); poolDataTab=msgPoolDataTabOpen(space);
bufferSize=poolDataTab[oldElem->poolIndex].bufferSize; // mapper le buffer dans l'espace mémoire du processus
msgPoolDataTabClose(space,poolDataTab); resultAddr=msgBufferMap(poolDataTab,oldElem->poolIndex,oldElem->bufferIndex);
// mapper le buffer dans l'espace mémoire du processus msgPoolDataTabClose(space,poolDataTab);
/* resultAddr = mmap( NULL,
bufferSize,
PROT_NONE, //prot PROT_READ | PROT_WRITE
MAP_SHARED, mSPoolFd,
(off_t)0);
bufferNb=mSPoolDataTabAddr[selectedPoolIndex].bufferNb;
*/
/* TODO: ecrire msgBufferMap(space,poolIndex,bufferIndex) */
resultAddr = msgBufferMap(poolDataTab, poolIndex, 0); // attacher au buffer...
if(resultAddr == NULL) {
NZG_ERROR("BufferMap", poolDataTab->poolId);
goto ERROR;
}
// attacher au buffer...
msgBufferAttachProc(poolDataTab,
poolIndex,
0, // c le buff en tete de file....
resultAddr);
// fermer la file // fermer la file
msgQueueClose(queue); msgQueueClose(queue);