*** empty log message ***
This commit is contained in:
parent
9718406b73
commit
39205742fd
1 changed files with 17 additions and 6 deletions
|
@ -1,14 +1,25 @@
|
|||
#include "libnazgul.h"
|
||||
|
||||
int queueLock(msgSpaceId spaceid,int queueIdx){
|
||||
int queueLock(msgSpaceId externId,int queueIdx){
|
||||
sem_t * queueSemFd;
|
||||
msgQueueSemId queueSemId;
|
||||
|
||||
queueSemFd=sem_open(queueSemId,O_CREAT|O_EXCL,0666,1);
|
||||
msgQueueSemIdIntern(queueSemId,externId);
|
||||
queueSemFd=sem_open(queueSemId,O_CREAT|O_EXCL,SEM_DEFAULT_MODE,1);
|
||||
if(queueSemFd==SEM_FAILED){
|
||||
NZG_ERROR("sem_open",queueSemId);
|
||||
return -1;
|
||||
}
|
||||
return -1;
|
||||
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;
|
||||
}
|
||||
|
||||
|
|
Loading…
Reference in a new issue