From d916cb6fe35416028abf5451749020aa6e08d1f7 Mon Sep 17 00:00:00 2001 From: =?utf8?q?Michal=20Voc=C5=AF?= Date: Tue, 18 Jan 2005 10:58:33 +0000 Subject: [PATCH] * added asserts for bug hunting --- org.glite.lb.logger/src/event_queue.c | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) diff --git a/org.glite.lb.logger/src/event_queue.c b/org.glite.lb.logger/src/event_queue.c index 75a723f..b4f592c 100644 --- a/org.glite.lb.logger/src/event_queue.c +++ b/org.glite.lb.logger/src/event_queue.c @@ -110,7 +110,8 @@ event_queue_empty(struct event_queue *eq) assert(eq != NULL); event_queue_lock_ro(eq); - ret = eq->head == NULL; + assert((eq->head != NULL) || (eq->tail == NULL)); + ret = (eq->head == NULL); event_queue_unlock(eq); return(ret); @@ -189,7 +190,8 @@ event_queue_get(struct event_queue *eq, struct server_msg **msg) assert(eq != NULL); assert(msg != NULL); - event_queue_lock_ro(eq); + event_queue_lock(eq); + assert((eq->head != NULL) || (eq->tail == NULL)); el = eq->head; #if defined(INTERLOGD_EMS) /* this message is marked for removal, it is first on the queue */ @@ -219,6 +221,7 @@ event_queue_remove(struct event_queue *eq) /* this is critical section */ event_queue_lock(eq); + assert((eq->head != NULL) || (eq->tail == NULL)); #if defined(INTERLOGD_EMS) el = eq->mark_this; prev = eq->mark_prev; @@ -235,7 +238,7 @@ event_queue_remove(struct event_queue *eq) /* removing from middle of the queue */ prev->prev = el->prev; } - if(el == eq->tail) { + if(eq->head == NULL) { /* we are removing the last message */ eq->tail = NULL; } @@ -257,6 +260,7 @@ event_queue_remove(struct event_queue *eq) eq->tail = NULL; } #endif + assert((eq->head != NULL) || (eq->tail == NULL)); event_queue_unlock(eq); /* end of critical section */ -- 1.8.2.3