le queueInit qui marche?

This commit is contained in:
stormrider1982 2004-02-23 21:30:30 +00:00 committed by Glenn Y. Rolland
parent 35202f9911
commit 0682b592e4
3 changed files with 76 additions and 0 deletions

View file

@ -102,5 +102,21 @@ int msgQueueSemIdIntern(
return 0; 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 #endif

View file

@ -12,5 +12,9 @@ int msgQueueSemIdIntern(
msgQueueSemId dest, msgQueueSemId dest,
msgSpaceId externId, msgSpaceId externId,
int queueIdx); int queueIdx);
int msgQueueIdIntern(
msgQueueId dest,
msgSpaceId externId,
int queueIdx);
#endif #endif

View file

@ -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;
}