suricata
|
#include "suricata.h"
#include "packet-queue.h"
#include "decode.h"
#include "threads.h"
#include "threadvars.h"
#include "tm-queuehandlers.h"
#include "tmqh-simple.h"
Go to the source code of this file.
Functions | |
Packet * | TmqhInputSimple (ThreadVars *t) |
void | TmqhOutputSimple (ThreadVars *t, Packet *p) |
void | TmqhInputSimpleShutdownHandler (ThreadVars *) |
void | TmqhSimpleRegister (void) |
Simple queue handler
Definition in file tmqh-simple.c.
Packet * TmqhInputSimple | ( | ThreadVars * | t | ) |
Definition at line 47 of file tmqh-simple.c.
References PacketQueue_::cond_q, ThreadVars_::inq, PacketQueue_::len, PacketQueue_::mutex_q, PacketDequeue(), Tmq_::pq, SCCondWait, SCMutexLock, SCMutexUnlock, and StatsSyncCountersIfSignalled().
Referenced by TmqhSimpleRegister().
void TmqhInputSimpleShutdownHandler | ( | ThreadVars * | tv | ) |
Definition at line 71 of file tmqh-simple.c.
References PacketQueue_::cond_q, ThreadVars_::inq, PacketQueue_::mutex_q, Tmq_::pq, Tmq_::reader_cnt, SCCondSignal, SCMutexLock, SCMutexUnlock, tv, and Tmq_::writer_cnt.
Referenced by TmqhSimpleRegister().
void TmqhOutputSimple | ( | ThreadVars * | t, |
Packet * | p | ||
) |
Definition at line 86 of file tmqh-simple.c.
References BOOL2STR, PacketQueue_::cond_q, PacketQueue_::mutex_q, ThreadVars_::outq, PacketEnqueue(), Packet_::pool, Tmq_::pq, Packet_::root, SCCondSignal, SCLogDebug, SCMutexLock, and SCMutexUnlock.
Referenced by TmqhSimpleRegister().
void TmqhSimpleRegister | ( | void | ) |
Definition at line 39 of file tmqh-simple.c.
References Tmqh_::InHandler, Tmqh_::InShutdownHandler, Tmqh_::name, Tmqh_::OutHandler, TMQH_SIMPLE, tmqh_table, TmqhInputSimple(), TmqhInputSimpleShutdownHandler(), and TmqhOutputSimple().
Referenced by TmqhSetup().