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:31:11 +00:00
parent f96b6f24d2
commit f1d1234775
5 changed files with 64 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
src/proto.h
View file

@ -61,14 +61,18 @@ int msgQueueElemDelete(msgQueueElemId queueElemId);
void *msgQueueElemOpen(msgQueueElemId queueElemId); void *msgQueueElemOpen(msgQueueElemId queueElemId);
/* queueInit.c */ /* queueInit.c */
msgQueue *queueInit(msgSpaceId externId, int queueIdx); msgQueue *queueInit(msgSpaceId externId, int queueIdx);
/* queueLock.c */
int queueLock(msgSpaceId externId, int queueIdx);
/* queueOpen.c */ /* queueOpen.c */
void *msgQueueOpen(msgQueueId queueId); void *msgQueueOpen(msgQueueId queueId);
/* queueProtLock.c */
int queueProtLock(msgSpaceId externId, int queueIdx);
/* queueProtUnlock.c */
int queueProtUnlock(msgSpaceId externId, int queueIdx);
/* queueReadLock.c */
int queueReadLock(msgSpaceId externId, int queueIdx);
/* queueReadUnlock.c */
int queueReadUnlock(msgSpaceId externId, int queueIdx);
/* queueRem.c */ /* queueRem.c */
int msgQueueElemRem(msgQueue *queue, msgQueueElemId oldElemId); int msgQueueElemRem(msgQueue *queue, msgQueueElemId oldElemId);
/* queueUnlock.c */
int queueUnlock(msgSpaceId externId, int queueIdx);
/* spaceCreate.c */ /* spaceCreate.c */
msgSpace *msgSpaceCreate(msgSpaceId externId, int queueNb, int poolNb, msgPool *poolInfos); msgSpace *msgSpaceCreate(msgSpaceId externId, int queueNb, int poolNb, msgPool *poolInfos);
/* spaceDelete.c */ /* spaceDelete.c */

4
src/queueProtLock.c
View file

@ -1,11 +1,11 @@
#include "libnazgul.h" #include "libnazgul.h"
#include "ids.h" #include "ids.h"
int queueLock(msgSpaceId externId,int queueIdx){ int queueProtLock(msgSpaceId externId,int queueIdx){
sem_t * queueSemFd; sem_t * queueSemFd;
msgQueueSemId queueSemId; msgQueueSemId queueSemId;
msgQueueSemIdIntern(queueSemId,externId,queueIdx); msgQueueProtSemIdIntern(queueSemId,externId,queueIdx);
queueSemFd=sem_open(queueSemId,O_CREAT|O_EXCL,SEM_DEFAULT_MODE,1); queueSemFd=sem_open(queueSemId,O_CREAT|O_EXCL,SEM_DEFAULT_MODE,1);
if(queueSemFd==SEM_FAILED){ if(queueSemFd==SEM_FAILED){
NZG_ERROR("sem_open",queueSemId); NZG_ERROR("sem_open",queueSemId);

4
src/queueProtUnlock.c
View file

@ -1,11 +1,11 @@
#include "libnazgul.h" #include "libnazgul.h"
#include "ids.h" #include "ids.h"
int queueUnlock(msgSpaceId externId,int queueIdx){ int queueProtUnlock(msgSpaceId externId,int queueIdx){
sem_t * queueSemFd; sem_t * queueSemFd;
msgQueueSemId queueSemId; msgQueueSemId queueSemId;
msgQueueSemIdIntern(queueSemId,externId,queueIdx); msgQueueProtSemIdIntern(queueSemId,externId,queueIdx);
queueSemFd=sem_open(queueSemId,O_CREAT|O_EXCL,SEM_DEFAULT_MODE,1); queueSemFd=sem_open(queueSemId,O_CREAT|O_EXCL,SEM_DEFAULT_MODE,1);
if(queueSemFd==SEM_FAILED){ if(queueSemFd==SEM_FAILED){
NZG_ERROR("sem_open",queueSemId); NZG_ERROR("sem_open",queueSemId);

26
src/queueReadLock.c Normal file
View file

@ -0,0 +1,26 @@
#include "libnazgul.h"
#include "ids.h"
int queueReadLock(msgSpaceId externId,int queueIdx){
sem_t * queueSemFd;
msgQueueSemId queueSemId;
msgQueueReadSemIdIntern(queueSemId,externId,queueIdx);
queueSemFd=sem_open(queueSemId,O_CREAT|O_EXCL,SEM_DEFAULT_MODE,1);
if(queueSemFd==SEM_FAILED){
NZG_ERROR("sem_open",queueSemId);
goto ERROR;
}
if(sem_wait(queueSemFd)==-1){
NZG_ERROR("sem_wait",queueSemId);
goto ERROR;
}
sem_close(queueSemFd);
return 0;
ERROR:
return -1;
}

26
src/queueReadUnlock.c Normal file
View file

@ -0,0 +1,26 @@
#include "libnazgul.h"
#include "ids.h"
int queueReadUnlock(msgSpaceId externId,int queueIdx){
sem_t * queueSemFd;
msgQueueSemId queueSemId;
msgQueueReadSemIdIntern(queueSemId,externId,queueIdx);
queueSemFd=sem_open(queueSemId,O_CREAT|O_EXCL,SEM_DEFAULT_MODE,1);
if(queueSemFd==SEM_FAILED){
NZG_ERROR("sem_open",queueSemId);
goto ERROR;
}
if(sem_post(queueSemFd)==-1){
NZG_ERROR("sem_post",queueSemId);
goto ERROR;
}
sem_close(queueSemFd);
return 0;
ERROR:
return -1;
}