/* Copyright (C) 2007-2010 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 */ #ifndef __FLOW_QUEUE_H__ #define __FLOW_QUEUE_H__ #include "suricata-common.h" #include "flow.h" /* Define a queue for storing flows */ typedef struct FlowQueue_ { Flow *top; Flow *bot; uint32_t len; SCMutex mutex_q; SCCondT cond_q; #ifdef DBG_PERF uint32_t dbg_maxlen; #endif /* DBG_PERF */ } FlowQueue; /* prototypes */ FlowQueue *FlowQueueNew(); FlowQueue *FlowQueueInit(FlowQueue *); void FlowQueueDestroy (FlowQueue *); void FlowEnqueue (FlowQueue *, Flow *); Flow *FlowDequeue (FlowQueue *); void FlowRequeue(Flow *, FlowQueue *, FlowQueue *, uint8_t); #endif /* __FLOW_QUEUE_H__ */