diff options
Diffstat (limited to 'framework/src/suricata/src/flow-queue.c')
| -rw-r--r-- | framework/src/suricata/src/flow-queue.c | 168 |
1 files changed, 0 insertions, 168 deletions
diff --git a/framework/src/suricata/src/flow-queue.c b/framework/src/suricata/src/flow-queue.c deleted file mode 100644 index b6a1138d..00000000 --- a/framework/src/suricata/src/flow-queue.c +++ /dev/null @@ -1,168 +0,0 @@ -/* Copyright (C) 2007-2013 Open Information Security Foundation - * - * You can copy, redistribute or modify this Program under the terms of - * the GNU General Public License version 2 as published by the Free - * Software Foundation. - * - * This program is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the - * GNU General Public License for more details. - * - * You should have received a copy of the GNU General Public License - * version 2 along with this program; if not, write to the Free Software - * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA - * 02110-1301, USA. - */ - -/** - * \file - * - * \author Victor Julien <victor@inliniac.net> - * - * Flow queue handler functions - */ - -#include "suricata-common.h" -#include "threads.h" -#include "debug.h" -#include "flow-private.h" -#include "flow-queue.h" -#include "flow-util.h" -#include "util-error.h" -#include "util-debug.h" -#include "util-print.h" - -FlowQueue *FlowQueueNew() -{ - FlowQueue *q = (FlowQueue *)SCMalloc(sizeof(FlowQueue)); - if (q == NULL) { - SCLogError(SC_ERR_FATAL, "Fatal error encountered in FlowQueueNew. Exiting..."); - exit(EXIT_SUCCESS); - } - q = FlowQueueInit(q); - return q; -} - -FlowQueue *FlowQueueInit (FlowQueue *q) -{ - if (q != NULL) { - memset(q, 0, sizeof(FlowQueue)); - FQLOCK_INIT(q); - } - return q; -} - -/** - * \brief Destroy a flow queue - * - * \param q the flow queue to destroy - */ -void FlowQueueDestroy (FlowQueue *q) -{ - FQLOCK_DESTROY(q); -} - -/** - * \brief add a flow to a queue - * - * \param q queue - * \param f flow - */ -void FlowEnqueue (FlowQueue *q, Flow *f) -{ -#ifdef DEBUG - BUG_ON(q == NULL || f == NULL); -#endif - - FQLOCK_LOCK(q); - - /* more flows in queue */ - if (q->top != NULL) { - f->lnext = q->top; - q->top->lprev = f; - q->top = f; - /* only flow */ - } else { - q->top = f; - q->bot = f; - } - q->len++; -#ifdef DBG_PERF - if (q->len > q->dbg_maxlen) - q->dbg_maxlen = q->len; -#endif /* DBG_PERF */ - FQLOCK_UNLOCK(q); -} - -/** - * \brief remove a flow from the queue - * - * \param q queue - * - * \retval f flow or NULL if empty list. - */ -Flow *FlowDequeue (FlowQueue *q) -{ - FQLOCK_LOCK(q); - - Flow *f = q->bot; - if (f == NULL) { - FQLOCK_UNLOCK(q); - return NULL; - } - - /* more packets in queue */ - if (q->bot->lprev != NULL) { - q->bot = q->bot->lprev; - q->bot->lnext = NULL; - /* just the one we remove, so now empty */ - } else { - q->top = NULL; - q->bot = NULL; - } - -#ifdef DEBUG - BUG_ON(q->len == 0); -#endif - if (q->len > 0) - q->len--; - - f->lnext = NULL; - f->lprev = NULL; - - FQLOCK_UNLOCK(q); - return f; -} - -/** - * \brief Transfer a flow from a queue to the spare queue - * - * \param f the flow to be transfered - * \param q the source queue, where the flow will be removed. This queue is locked. - * - * \note spare queue needs locking - */ -void FlowMoveToSpare(Flow *f) -{ - /* now put it in spare */ - FQLOCK_LOCK(&flow_spare_q); - - /* add to new queue (append) */ - f->lprev = flow_spare_q.bot; - if (f->lprev != NULL) - f->lprev->lnext = f; - f->lnext = NULL; - flow_spare_q.bot = f; - if (flow_spare_q.top == NULL) - flow_spare_q.top = f; - - flow_spare_q.len++; -#ifdef DBG_PERF - if (flow_spare_q.len > flow_spare_q.dbg_maxlen) - flow_spare_q.dbg_maxlen = flow_spare_q.len; -#endif /* DBG_PERF */ - - FQLOCK_UNLOCK(&flow_spare_q); -} - |