le queueInit qui marche?
This commit is contained in:
parent
b764455d36
commit
d4e9c5ae3d
3 changed files with 76 additions and 0 deletions
16
src/ids.c
16
src/ids.c
|
@ -102,5 +102,21 @@ int msgQueueSemIdIntern(
|
|||
return 0;
|
||||
}
|
||||
|
||||
int msgQueueIdIntern(
|
||||
msgQueueId dest,
|
||||
msgSpaceId externId,
|
||||
int queueIdx){
|
||||
if (strlen(externId)>MSGSPACE_ID_LEN){
|
||||
return -1;
|
||||
}
|
||||
#ifdef _NZG_REALFILEID
|
||||
sprintf(dest,"/tmp/nzgQueue-%s-%d",(char *)externId,queueIdx);
|
||||
#else
|
||||
sprintf(dest,"/nzgQueue-%s-%d",(char *)externId,queueIdx);
|
||||
#endif
|
||||
return 0;
|
||||
}
|
||||
|
||||
|
||||
|
||||
#endif
|
||||
|
|
|
@ -12,5 +12,9 @@ int msgQueueSemIdIntern(
|
|||
msgQueueSemId dest,
|
||||
msgSpaceId externId,
|
||||
int queueIdx);
|
||||
int msgQueueIdIntern(
|
||||
msgQueueId dest,
|
||||
msgSpaceId externId,
|
||||
int queueIdx);
|
||||
|
||||
#endif
|
||||
|
|
|
@ -0,0 +1,56 @@
|
|||
#include "libnazgul.h"
|
||||
#include "ids.h"
|
||||
|
||||
msgQueue * queueInit(msgSpaceId externId, int queueIdx) {
|
||||
int queueFd;
|
||||
msgQueue * queue;
|
||||
sem_t * semaphore;
|
||||
msgQueueId queueId;
|
||||
|
||||
queue = NULL;
|
||||
|
||||
if(msgQueueIdIntern(queueId, externId, queueIdx) < 0) {
|
||||
return NULL;
|
||||
}
|
||||
|
||||
queueFd = shm_open(queueId, O_RDWR|O_CREAT|O_EXCL|O_TRUNC, MSGSPACE_DEFAULT_MODE);
|
||||
if(queueFd == -1) {
|
||||
fprintf(stderr, "queueInit : %s initialisation failed: %s\n", queueId, strerror(errno));
|
||||
return NULL;
|
||||
}
|
||||
|
||||
if(ftruncate(queueFd, sizeof(* queue)) == -1) {
|
||||
fprintf( stderr, "Queue resizing failed: %s\n",
|
||||
strerror( errno ) );
|
||||
return NULL;
|
||||
}
|
||||
|
||||
|
||||
/* on remplit la structure msgQueue */
|
||||
queue->elemCounter = 0;
|
||||
//queue->head = NULL;
|
||||
//queue->tail = NULL;
|
||||
|
||||
|
||||
|
||||
// creation du semaphore
|
||||
semaphore = sem_open(queueId, O_CREAT|O_EXCL, SEM_DEFAULT_MODE, 1);
|
||||
if(semaphore == SEM_FAILED) {
|
||||
NZG_ERROR("sem_open", queueId);
|
||||
goto ERROR;
|
||||
}
|
||||
|
||||
if(sem_wait(semaphore)==-1){
|
||||
NZG_ERROR("sem_wait",queueId);
|
||||
goto ERROR;
|
||||
}
|
||||
|
||||
/* on ferme tout ce qu'il faut */
|
||||
sem_close(semaphore);
|
||||
close(queueFd);
|
||||
|
||||
return queue;
|
||||
ERROR:
|
||||
return NULL;
|
||||
|
||||
}
|
Loading…
Reference in a new issue