suricata
tmqh-simple.c
Go to the documentation of this file.
1 /* Copyright (C) 2007-2013 Open Information Security Foundation
2  *
3  * You can copy, redistribute or modify this Program under the terms of
4  * the GNU General Public License version 2 as published by the Free
5  * Software Foundation.
6  *
7  * This program is distributed in the hope that it will be useful,
8  * but WITHOUT ANY WARRANTY; without even the implied warranty of
9  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
10  * GNU General Public License for more details.
11  *
12  * You should have received a copy of the GNU General Public License
13  * version 2 along with this program; if not, write to the Free Software
14  * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
15  * 02110-1301, USA.
16  */
17 
18 /**
19  * \file
20  *
21  * \author Victor Julien <victor@inliniac.net>
22  *
23  * Simple queue handler
24  */
25 
26 #include "suricata.h"
27 #include "packet-queue.h"
28 #include "decode.h"
29 #include "threads.h"
30 #include "threadvars.h"
31 
32 #include "tm-queuehandlers.h"
33 #include "tmqh-simple.h"
34 
38 
39 void TmqhSimpleRegister (void)
40 {
41  tmqh_table[TMQH_SIMPLE].name = "simple";
45 }
46 
48 {
49  PacketQueue *q = &trans_q[t->inq->id];
50 
52 
53  SCMutexLock(&q->mutex_q);
54 
55  if (q->len == 0) {
56  /* if we have no packets in queue, wait... */
57  SCCondWait(&q->cond_q, &q->mutex_q);
58  }
59 
60  if (q->len > 0) {
61  Packet *p = PacketDequeue(q);
63  return p;
64  } else {
65  /* return NULL if we have no pkt. Should only happen on signals. */
67  return NULL;
68  }
69 }
70 
72 {
73  int i;
74 
75  if (tv == NULL || tv->inq == NULL) {
76  return;
77  }
78 
79  for (i = 0; i < (tv->inq->reader_cnt + tv->inq->writer_cnt); i++)
81 }
82 
84 {
85  SCLogDebug("Packet %p, p->root %p, alloced %s", p, p->root, p->flags & PKT_ALLOC ? "true":"false");
86 
87  PacketQueue *q = &trans_q[t->outq->id];
88 
89  SCMutexLock(&q->mutex_q);
90  PacketEnqueue(q, p);
91  SCCondSignal(&q->cond_q);
93 }
94 
Packet *(* InHandler)(ThreadVars *)
const char * name
Tmqh tmqh_table[TMQH_SIZE]
#define SCLogDebug(...)
Definition: util-debug.h:335
SCCondT cond_q
Definition: decode.h:628
uint16_t writer_cnt
Definition: tm-queues.h:31
#define PKT_ALLOC
Definition: decode.h:1088
uint16_t id
Definition: tm-queues.h:29
#define SCCondWait
#define SCMutexLock(mut)
#define SCMutexUnlock(mut)
uint32_t len
Definition: decode.h:623
void TmqhOutputSimple(ThreadVars *t, Packet *p)
Definition: tmqh-simple.c:83
Tmq * outq
Definition: threadvars.h:73
void(* OutHandler)(ThreadVars *, Packet *)
uint16_t reader_cnt
Definition: tm-queues.h:30
void TmqhSimpleRegister(void)
Definition: tmqh-simple.c:39
#define SCCondSignal
PacketQueue trans_q[256]
Definition: suricata.h:132
#define StatsSyncCountersIfSignalled(tv)
Definition: counters.h:137
void(* InShutdownHandler)(ThreadVars *)
Packet * PacketDequeue(PacketQueue *q)
Definition: packet-queue.c:167
void TmqhInputSimpleShutdownHandler(ThreadVars *)
Definition: tmqh-simple.c:71
Per thread variable structure.
Definition: threadvars.h:57
uint32_t flags
Definition: decode.h:443
Tmq * inq
Definition: threadvars.h:72
void PacketEnqueue(PacketQueue *q, Packet *p)
Definition: packet-queue.c:139
SCMutex mutex_q
Definition: decode.h:627
Packet * TmqhInputSimple(ThreadVars *t)
Definition: tmqh-simple.c:47
struct Packet_ * root
Definition: decode.h:577