glenux-school/l3.libnazgul
glenux-school/l3.libnazgul
1
1
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

*** empty log message ***

Browse source
This commit is contained in:
glenux 2004-02-24 09:43:56 +00:00
parent f1d1234775
commit 7d84fce952
6 changed files with 11 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
src/proto.h
View file

@ -64,13 +64,13 @@ msgQueue *queueInit(msgSpaceId externId, int queueIdx);
/* queueOpen.c */ /* queueOpen.c */
void *msgQueueOpen(msgQueueId queueId); void *msgQueueOpen(msgQueueId queueId);
/* queueProtLock.c */ /* queueProtLock.c */
int queueProtLock(msgSpaceId externId, int queueIdx); int msgQueueProtLock(msgSpaceId externId, int queueIdx);
/* queueProtUnlock.c */ /* queueProtUnlock.c */
int queueProtUnlock(msgSpaceId externId, int queueIdx); int msgQueueProtUnlock(msgSpaceId externId, int queueIdx);
/* queueReadLock.c */ /* queueReadLock.c */
int queueReadLock(msgSpaceId externId, int queueIdx); int msgQueueReadLock(msgSpaceId externId, int queueIdx);
/* queueReadUnlock.c */ /* queueReadUnlock.c */
int queueReadUnlock(msgSpaceId externId, int queueIdx); int msgQueueReadUnlock(msgSpaceId externId, int queueIdx);
/* queueRem.c */ /* queueRem.c */
int msgQueueElemRem(msgQueue *queue, msgQueueElemId oldElemId); int msgQueueElemRem(msgQueue *queue, msgQueueElemId oldElemId);
/* spaceCreate.c */ /* spaceCreate.c */

3
src/put.c
View file

@ -22,6 +22,7 @@ int err;
msgQueueId queueId; msgQueueId queueId;
msgQueue * queue; msgQueue * queue;
msgQueueIdIntern(queueId,space->externId,queueIndex); msgQueueIdIntern(queueId,space->externId,queueIndex);
msgQueueProtLock(space->externId,queueIndex);
queue = msgQueueOpen(queueId); queue = msgQueueOpen(queueId);
// TODO:creer un element vide // TODO:creer un element vide
@ -42,10 +43,12 @@ msgQueueElemAdd(queue,newElemId);
// fermer la file // fermer la file
msgQueueClose(queue); msgQueueClose(queue);
msgQueueProtUnlock(space->externId,queueIndex);
msgPoolDataTabClose(space,poolDataTabAddr); msgPoolDataTabClose(space,poolDataTabAddr);
/* msgPoolDataTabUnlock(space->id); /* msgPoolDataTabUnlock(space->id);
*/ */
msgQueueReadUnlock(space->externId,queueIndex);
return 0; return 0;
ERROR: ERROR:
return -1; return -1;

2
src/queueProtLock.c
View file

@ -1,7 +1,7 @@
#include "libnazgul.h" #include "libnazgul.h"
#include "ids.h" #include "ids.h"
int queueProtLock(msgSpaceId externId,int queueIdx){ int msgQueueProtLock(msgSpaceId externId,int queueIdx){
sem_t * queueSemFd; sem_t * queueSemFd;
msgQueueSemId queueSemId; msgQueueSemId queueSemId;

2
src/queueProtUnlock.c
View file

@ -1,7 +1,7 @@
#include "libnazgul.h" #include "libnazgul.h"
#include "ids.h" #include "ids.h"
int queueProtUnlock(msgSpaceId externId,int queueIdx){ int msgQueueProtUnlock(msgSpaceId externId,int queueIdx){
sem_t * queueSemFd; sem_t * queueSemFd;
msgQueueSemId queueSemId; msgQueueSemId queueSemId;

2
src/queueReadLock.c
View file

@ -1,7 +1,7 @@
#include "libnazgul.h" #include "libnazgul.h"
#include "ids.h" #include "ids.h"
int queueReadLock(msgSpaceId externId,int queueIdx){ int msgQueueReadLock(msgSpaceId externId,int queueIdx){
sem_t * queueSemFd; sem_t * queueSemFd;
msgQueueSemId queueSemId; msgQueueSemId queueSemId;

2
src/queueReadUnlock.c
View file

@ -1,7 +1,7 @@
#include "libnazgul.h" #include "libnazgul.h"
#include "ids.h" #include "ids.h"
int queueReadUnlock(msgSpaceId externId,int queueIdx){ int msgQueueReadUnlock(msgSpaceId externId,int queueIdx){
sem_t * queueSemFd; sem_t * queueSemFd;
msgQueueSemId queueSemId; msgQueueSemId queueSemId;