aboutsummaryrefslogtreecommitdiffstats
path: root/framework/src/suricata/src/tmqh-ringbuffer.c
diff options
context:
space:
mode:
Diffstat (limited to 'framework/src/suricata/src/tmqh-ringbuffer.c')
-rw-r--r--framework/src/suricata/src/tmqh-ringbuffer.c151
1 files changed, 0 insertions, 151 deletions
diff --git a/framework/src/suricata/src/tmqh-ringbuffer.c b/framework/src/suricata/src/tmqh-ringbuffer.c
deleted file mode 100644
index 29228e1a..00000000
--- a/framework/src/suricata/src/tmqh-ringbuffer.c
+++ /dev/null
@@ -1,151 +0,0 @@
-/* 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 <victor@inliniac.net>
- *
- * RingBuffer queue handler
- */
-
-#include "suricata.h"
-#include "packet-queue.h"
-#include "decode.h"
-#include "threads.h"
-#include "threadvars.h"
-
-#include "tm-queuehandlers.h"
-
-#include "util-ringbuffer.h"
-
-static RingBuffer8 *ringbuffers[256];
-
-Packet *TmqhInputRingBufferMrSw(ThreadVars *t);
-void TmqhOutputRingBufferMrSw(ThreadVars *t, Packet *p);
-Packet *TmqhInputRingBufferSrSw(ThreadVars *t);
-void TmqhOutputRingBufferSrSw(ThreadVars *t, Packet *p);
-Packet *TmqhInputRingBufferSrMw(ThreadVars *t);
-void TmqhOutputRingBufferSrMw(ThreadVars *t, Packet *p);
-void TmqhInputRingBufferShutdownHandler(ThreadVars *);
-
-/**
- * \brief TmqhRingBufferRegister
- * \initonly
- */
-void TmqhRingBufferRegister (void)
-{
- tmqh_table[TMQH_RINGBUFFER_MRSW].name = "ringbuffer_mrsw";
- tmqh_table[TMQH_RINGBUFFER_MRSW].InHandler = TmqhInputRingBufferMrSw;
- tmqh_table[TMQH_RINGBUFFER_MRSW].InShutdownHandler = TmqhInputRingBufferShutdownHandler;
- tmqh_table[TMQH_RINGBUFFER_MRSW].OutHandler = TmqhOutputRingBufferMrSw;
-
- tmqh_table[TMQH_RINGBUFFER_SRSW].name = "ringbuffer_srsw";
- tmqh_table[TMQH_RINGBUFFER_SRSW].InHandler = TmqhInputRingBufferSrSw;
- tmqh_table[TMQH_RINGBUFFER_SRSW].InShutdownHandler = TmqhInputRingBufferShutdownHandler;
- tmqh_table[TMQH_RINGBUFFER_SRSW].OutHandler = TmqhOutputRingBufferSrSw;
-
- tmqh_table[TMQH_RINGBUFFER_SRMW].name = "ringbuffer_srmw";
- tmqh_table[TMQH_RINGBUFFER_SRMW].InHandler = TmqhInputRingBufferSrMw;
- tmqh_table[TMQH_RINGBUFFER_SRMW].InShutdownHandler = TmqhInputRingBufferShutdownHandler;
- tmqh_table[TMQH_RINGBUFFER_SRMW].OutHandler = TmqhOutputRingBufferSrMw;
-
- memset(ringbuffers, 0, sizeof(ringbuffers));
-
- int i = 0;
- for (i = 0; i < 256; i++) {
- ringbuffers[i] = RingBuffer8Init();
- if (ringbuffers[i] == NULL) {
- SCLogError(SC_ERR_FATAL, "Error allocating memory to register Ringbuffers. Exiting...");
- exit(EXIT_FAILURE);
- }
- }
-}
-
-void TmqhRingBufferDestroy (void)
-{
- int i = 0;
- for (i = 0; i < 256; i++) {
- RingBuffer8Destroy(ringbuffers[i]);
- }
-}
-
-void TmqhInputRingBufferShutdownHandler(ThreadVars *tv)
-{
- if (tv == NULL || tv->inq == NULL) {
- return;
- }
-
- RingBuffer8 *rb = ringbuffers[tv->inq->id];
- if (rb == NULL) {
- return;
- }
-
- RingBuffer8Shutdown(rb);
-}
-
-Packet *TmqhInputRingBufferMrSw(ThreadVars *t)
-{
- RingBuffer8 *rb = ringbuffers[t->inq->id];
-
- Packet *p = (Packet *)RingBufferMrSw8Get(rb);
-
- StatsSyncCountersIfSignalled(t);
-
- return p;
-}
-
-void TmqhOutputRingBufferMrSw(ThreadVars *t, Packet *p)
-{
- RingBuffer8 *rb = ringbuffers[t->outq->id];
- RingBufferMrSw8Put(rb, (void *)p);
-}
-
-Packet *TmqhInputRingBufferSrSw(ThreadVars *t)
-{
- RingBuffer8 *rb = ringbuffers[t->inq->id];
-
- Packet *p = (Packet *)RingBufferSrSw8Get(rb);
-
- StatsSyncCountersIfSignalled(t);
-
- return p;
-}
-
-void TmqhOutputRingBufferSrSw(ThreadVars *t, Packet *p)
-{
- RingBuffer8 *rb = ringbuffers[t->outq->id];
- RingBufferSrSw8Put(rb, (void *)p);
-}
-
-Packet *TmqhInputRingBufferSrMw(ThreadVars *t)
-{
- RingBuffer8 *rb = ringbuffers[t->inq->id];
-
- Packet *p = (Packet *)RingBufferSrMw8Get(rb);
-
- StatsSyncCountersIfSignalled(t);
-
- return p;
-}
-
-void TmqhOutputRingBufferSrMw(ThreadVars *t, Packet *p)
-{
- RingBuffer8 *rb = ringbuffers[t->outq->id];
- RingBufferSrMw8Put(rb, (void *)p);
-}
-