/* remove the message from the source list */
*source_prev = p->prev;
assert(eq_s->cur_len > 0);
- es_s->cur_len--;
+ eq_s->cur_len--;
if(eq_d) {
/* append the message at the end of destination list */
p->prev = NULL;
il_log(LOG_DEBUG, " queuing event at %ld to bookkeeping server\n", last);
- if(r=enqueue_msg(eq_b, msg) < 0) {
+ if((r=enqueue_msg(eq_b, msg)) < 0) {
break;
} else if(r > 0) {
throttle = 1;
event_queue_cond_lock(eq);
/* insert new event */
- if(ret = event_queue_insert(eq, msg) < 0) {
+ if((ret = event_queue_insert(eq, msg)) < 0) {
event_queue_cond_unlock(eq);
return ret;
}