*** empty log message ***

src/allocate.c

@@ -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);
@@ -47,7 +48,7 @@ void * msgAllocate(msgSpace *space,
 	return NULL;
   }
 
-
+  
   mSPoolDataTabAddr = mmap( 0, (space->poolNb) * sizeof( msgPoolData ),
 	  PROT_READ | PROT_WRITE,
 	  MAP_SHARED, mSPoolDataTabFd, 0 );
@@ -57,7 +58,7 @@ void * msgAllocate(msgSpace *space,
 		strerror( errno ) );
 	return NULL;
   }
-
+*/
   gotRessourceSem=false;
 
   /* initialisation des coefs */

src/get.c

@@ -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

src/put.c

@@ -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);