*** empty log message ***

This commit is contained in:
glenux 2004-02-25 08:53:54 +00:00 committed by Glenn Y. Rolland
parent 60450c4b17
commit d59f193804
3 changed files with 14 additions and 8 deletions

View file

@ -15,7 +15,7 @@ void * msgAllocate(msgSpace *space,
int option
){
void * resultAddr=NULL;
int i, mSPoolDataTabFd;
int i;
msgPoolId resultPoolId;
/* tableau des valeurs des semPoolCoef/pool pour identifier le pool
* qui sera libéré le plus rapidement */
@ -35,8 +35,9 @@ void * msgAllocate(msgSpace *space,
selectedPoolIndex=-1;
/* verifier le premier arg du shm_open */
mSPoolDataTabAddr=msgPoolDataTabOpen(space);
/*
// verifier le premier arg du shm_open
mSPoolDataTabFd=shm_open(space->poolDataTabId,
O_RDWR,
MSGSPACE_DEFAULT_MODE);
@ -57,7 +58,7 @@ void * msgAllocate(msgSpace *space,
strerror( errno ) );
return NULL;
}
*/
gotRessourceSem=false;
/* initialisation des coefs */

View file

@ -33,7 +33,6 @@ void * msgGet(msgSpace * space,int queueIndex,int option){
oldElem = msgQueueElemOpen(oldElemId);
/* on récupere la taille des buffer dans la pool du buffer */
int bufferSize;
msgPoolData * poolDataTab;
poolDataTab=msgPoolDataTabOpen(space);
// mapper le buffer dans l'espace mémoire du processus

View file

@ -38,10 +38,16 @@ int msgPut(msgSpace * space,int queueIndex, void * addr){
queueElem->bufferIndex=bufferIndex;
// fermer l'element
msgQueueElemClose(queueElem);
if (msgQueueElemClose(queueElem) <0 ){
NZG_ERROR("msgQueueElemClose","");
goto ERROR;
}
//ajouter le message a la bonne file...
msgQueueAdd(queue,newElemId);
if (msgQueueAdd(queue,newElemId) <0){
NZG_ERROR("msgQueueAdd","");
goto ERROR;
}
// fermer la file
msgQueueClose(queue);