From 8bcb94ec42e55347c05153f9fddb6bf982dc83ce Mon Sep 17 00:00:00 2001 From: stormrider1982 Date: Wed, 25 Feb 2004 08:08:31 +0000 Subject: [PATCH] c'est mieux comme ca... --- src/allocate.c | 4 ++-- src/put.c | 1 + 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/src/allocate.c b/src/allocate.c index cce3b92..b848053 100644 --- a/src/allocate.c +++ b/src/allocate.c @@ -186,14 +186,14 @@ void * msgAllocate(msgSpace *space, int bufferFreeSize; bufferFreeSize=mSPoolDataTabAddr[selectedPoolIndex].bufferSize; printf("BufferSize : %d", bufferFreeSize); - + + bufferNb=mSPoolDataTabAddr[selectedPoolIndex].bufferNb; // on mappe la totalité du pool resultAddr = mmap( NULL, bufferFreeSize*bufferNb, /* bufferFreeSize*/ PROT_NONE, //prot PROT_READ | PROT_WRITE MAP_SHARED, mSPoolFd, (off_t)0); - bufferNb=mSPoolDataTabAddr[selectedPoolIndex].bufferNb; // mprotect(resultAddr,bufferFreeSize*bufferNb,PROT_NONE); mprotect(resultAddr,bufferFreeSize*(bufferFreeIndex+1),PROT_READ|PROT_WRITE); diff --git a/src/put.c b/src/put.c index 818dd74..d035101 100644 --- a/src/put.c +++ b/src/put.c @@ -21,6 +21,7 @@ int msgPut(msgSpace * space,int queueIndex, void * addr){ msgQueueId queueId; msgQueue * queue; msgQueueIdIntern(queueId,space->externId,queueIndex); + msgQueueProtLock(space->externId,queueIndex); queue = msgQueueOpen(queueId);