From 4b6a8715fd5293d1ecd1660bc408fc77dd1cb235 Mon Sep 17 00:00:00 2001
From: Victor Julien <victor@inliniac.net>
Date: Fri, 31 Oct 2008 10:21:56 +0100
Subject: [PATCH] Fix packets getting stuck in NFQ under high load.

---
 src/source-nfq.c | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git a/src/source-nfq.c b/src/source-nfq.c
index 06f3cb1f8b..88b2775fe5 100644
--- a/src/source-nfq.c
+++ b/src/source-nfq.c
@@ -82,10 +82,9 @@ void NFQSetupPkt (Packet *p, void *data)
     ret = nfq_get_payload(tb, &pktdata);
     if (ret > 0) {
         /* nfq_get_payload returns a pointer to a part of memory
-         * that is not preserved over the lifetime of out packet.
+         * that is not preserved over the lifetime of our packet.
          * So we need to copy it. */
         memcpy(p->pkt, pktdata, ret);
-        //bcopy(pktdata, p->pkt, ret);
         p->pktlen = (size_t)ret;
     }
 /* XXX what if ret <= 0 ? */
@@ -230,7 +229,7 @@ int ReceiveNFQThreadInit(ThreadVars *tv, void **data) {
      * as we will need it in our cb function */
     ntv->tv = tv;
 
-    int r = NFQInitThread(ntv,receive_queue_num,0);
+    int r = NFQInitThread(ntv,receive_queue_num,MAX_PENDING);
     if (r < 0) {
         printf("NFQInitThread failed\n");
         //return -1;
@@ -277,6 +276,8 @@ void NFQRecvPkt(NFQThreadVars *t) {
             t->errs++;
 #endif /* COUNTERS */
         }
+    } else if(rv == 0) {
+        printf("NFQRecvPkt: rv = 0\n");
     } else {
 #ifdef DBG_PERF
         if (rv > t->dbg_maxreadsize)