From 55bdcbca9dde5fe51c6d736fb92234116944aaec Mon Sep 17 00:00:00 2001 From: glenux Date: Tue, 24 Feb 2004 09:43:56 +0000 Subject: [PATCH] *** empty log message *** --- src/proto.h | 8 ++++---- src/put.c | 3 +++ src/queueProtLock.c | 2 +- src/queueProtUnlock.c | 2 +- src/queueReadLock.c | 2 +- src/queueReadUnlock.c | 2 +- 6 files changed, 11 insertions(+), 8 deletions(-) diff --git a/src/proto.h b/src/proto.h index cbd5c9f..0a7c472 100644 --- a/src/proto.h +++ b/src/proto.h @@ -64,13 +64,13 @@ msgQueue *queueInit(msgSpaceId externId, int queueIdx); /* queueOpen.c */ void *msgQueueOpen(msgQueueId queueId); /* queueProtLock.c */ -int queueProtLock(msgSpaceId externId, int queueIdx); +int msgQueueProtLock(msgSpaceId externId, int queueIdx); /* queueProtUnlock.c */ -int queueProtUnlock(msgSpaceId externId, int queueIdx); +int msgQueueProtUnlock(msgSpaceId externId, int queueIdx); /* queueReadLock.c */ -int queueReadLock(msgSpaceId externId, int queueIdx); +int msgQueueReadLock(msgSpaceId externId, int queueIdx); /* queueReadUnlock.c */ -int queueReadUnlock(msgSpaceId externId, int queueIdx); +int msgQueueReadUnlock(msgSpaceId externId, int queueIdx); /* queueRem.c */ int msgQueueElemRem(msgQueue *queue, msgQueueElemId oldElemId); /* spaceCreate.c */ diff --git a/src/put.c b/src/put.c index 1ba76e4..3c27b0d 100644 --- a/src/put.c +++ b/src/put.c @@ -22,6 +22,7 @@ int err; msgQueueId queueId; msgQueue * queue; msgQueueIdIntern(queueId,space->externId,queueIndex); + msgQueueProtLock(space->externId,queueIndex); queue = msgQueueOpen(queueId); // TODO:creer un element vide @@ -42,10 +43,12 @@ msgQueueElemAdd(queue,newElemId); // fermer la file msgQueueClose(queue); + msgQueueProtUnlock(space->externId,queueIndex); msgPoolDataTabClose(space,poolDataTabAddr); /* msgPoolDataTabUnlock(space->id); */ + msgQueueReadUnlock(space->externId,queueIndex); return 0; ERROR: return -1; diff --git a/src/queueProtLock.c b/src/queueProtLock.c index a80405c..6494c93 100644 --- a/src/queueProtLock.c +++ b/src/queueProtLock.c @@ -1,7 +1,7 @@ #include "libnazgul.h" #include "ids.h" -int queueProtLock(msgSpaceId externId,int queueIdx){ +int msgQueueProtLock(msgSpaceId externId,int queueIdx){ sem_t * queueSemFd; msgQueueSemId queueSemId; diff --git a/src/queueProtUnlock.c b/src/queueProtUnlock.c index bebe704..5e521a3 100644 --- a/src/queueProtUnlock.c +++ b/src/queueProtUnlock.c @@ -1,7 +1,7 @@ #include "libnazgul.h" #include "ids.h" -int queueProtUnlock(msgSpaceId externId,int queueIdx){ +int msgQueueProtUnlock(msgSpaceId externId,int queueIdx){ sem_t * queueSemFd; msgQueueSemId queueSemId; diff --git a/src/queueReadLock.c b/src/queueReadLock.c index 24a9ece..99e2ab3 100644 --- a/src/queueReadLock.c +++ b/src/queueReadLock.c @@ -1,7 +1,7 @@ #include "libnazgul.h" #include "ids.h" -int queueReadLock(msgSpaceId externId,int queueIdx){ +int msgQueueReadLock(msgSpaceId externId,int queueIdx){ sem_t * queueSemFd; msgQueueSemId queueSemId; diff --git a/src/queueReadUnlock.c b/src/queueReadUnlock.c index cb05b02..d3e7a10 100644 --- a/src/queueReadUnlock.c +++ b/src/queueReadUnlock.c @@ -1,7 +1,7 @@ #include "libnazgul.h" #include "ids.h" -int queueReadUnlock(msgSpaceId externId,int queueIdx){ +int msgQueueReadUnlock(msgSpaceId externId,int queueIdx){ sem_t * queueSemFd; msgQueueSemId queueSemId;