From 67bca7f3bcd1c22e5f03e55c85a94fb4770a9d85 Mon Sep 17 00:00:00 2001
From: glenux <glenux>
Date: Wed, 25 Feb 2004 08:53:54 +0000
Subject: [PATCH] *** empty log message ***

---
 src/allocate.c | 11 ++++++-----
 src/get.c      |  1 -
 src/put.c      | 10 ++++++++--
 3 files changed, 14 insertions(+), 8 deletions(-)

diff --git a/src/allocate.c b/src/allocate.c
index 964d19c..7c64673 100644
--- a/src/allocate.c
+++ b/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 */
diff --git a/src/get.c b/src/get.c
index 5e07175..99396fa 100644
--- a/src/get.c
+++ b/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
diff --git a/src/put.c b/src/put.c
index d035101..3c0eb79 100644
--- a/src/put.c
+++ b/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);