*** empty log message ***
This commit is contained in:
parent
427380eda3
commit
f7856350c1
2 changed files with 17 additions and 1 deletions
10
src/get.c
10
src/get.c
|
@ -19,6 +19,16 @@ void * msgGet(msgSpace * space,int queueIndex,int option){
|
||||||
// la lecture est possible
|
// la lecture est possible
|
||||||
// on essaye donc de modifier la liste
|
// on essaye donc de modifier la liste
|
||||||
msgQueueProtLock(space->externId,queueIndex);
|
msgQueueProtLock(space->externId,queueIndex);
|
||||||
|
msgQueueId queueId;
|
||||||
|
msgQueue * queue;
|
||||||
|
msgQueueIdIntern(queueId,space->externId,queueIndex);
|
||||||
|
// ouvrir la file
|
||||||
|
queue = msgQueueOpen(queueId);
|
||||||
|
|
||||||
|
// recupérer l'id de l'ancien element...
|
||||||
|
|
||||||
|
// fermer la file
|
||||||
|
msgQueueClose(queue);
|
||||||
|
|
||||||
// on a fini de modifier la liste
|
// on a fini de modifier la liste
|
||||||
msgQueueProtUnlock(space->externId,queueIndex);
|
msgQueueProtUnlock(space->externId,queueIndex);
|
||||||
|
|
|
@ -17,7 +17,13 @@ int msgQueueElemRem(msgQueue * queue, msgQueueElemId oldElemId){
|
||||||
NZG_ERROR("msgQueueElemOpen",oldElemId);
|
NZG_ERROR("msgQueueElemOpen",oldElemId);
|
||||||
goto ERROR;
|
goto ERROR;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// on indique à la queue le nouveau premier element
|
||||||
strcpy(queue->headId,queueOldHeadElem->next);
|
strcpy(queue->headId,queueOldHeadElem->next);
|
||||||
|
// on fait en sorte que l'element ne connaisse plus
|
||||||
|
// ses voisins (utile pour le Delete)
|
||||||
|
strcpy(queueOldHeadElem->next,queueOldHeadElem->id);
|
||||||
|
|
||||||
if (msgQueueElemClose(queueOldHeadElem)<0 ){
|
if (msgQueueElemClose(queueOldHeadElem)<0 ){
|
||||||
NZG_ERROR("msgQueueElemClose",oldElemId);
|
NZG_ERROR("msgQueueElemClose",oldElemId);
|
||||||
goto ERROR;
|
goto ERROR;
|
||||||
|
|
Loading…
Reference in a new issue