Revert change in queue handler wait logic. Bug #988.

pull/576/merge
Victor Julien 12 years ago
parent 8d6bca72f7
commit c1190545cf

@ -88,7 +88,7 @@ Packet *TmqhInputFlow(ThreadVars *tv)
SCPerfSyncCountersIfSignalled(tv, 0);
SCMutexLock(&q->mutex_q);
while (q->len == 0) {
if (q->len == 0) {
/* if we have no packets in queue, wait... */
SCCondWait(&q->cond_q, &q->mutex_q);
}

@ -50,7 +50,7 @@ Packet *TmqhInputSimple(ThreadVars *t)
SCMutexLock(&q->mutex_q);
while (q->len == 0) {
if (q->len == 0) {
/* if we have no packets in queue, wait... */
SCCondWait(&q->cond_q, &q->mutex_q);
}
@ -111,7 +111,7 @@ void TmqhOutputSimple(ThreadVars *t, Packet *p)
SCDQGenericQData *TmqhInputSimpleOnQ(SCDQDataQueue *q)
{
SCMutexLock(&q->mutex_q);
while (q->len == 0) {
if (q->len == 0) {
/* if we have no packets in queue, wait... */
SCCondWait(&q->cond_q, &q->mutex_q);
}

Loading…
Cancel
Save