23268535754

Committed 18 Mar 2026 09:42PM UTC coverage: 79.084% (-0.2%) from 79.297%

Build # 23268535754

Build Type

push

github

Committed by

jasonish

Commit Message

github-ci/builds: update ubuntu builds to rust 1.89

Coverage Stats

264897 of 334955 relevant lines covered (79.08%)

3068071.33 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

14.63

/src/tmqh-simple.c

/* 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>
 *
 * Simple queue handler
 */

#include "suricata.h"
#include "packet-queue.h"
#include "decode.h"
#include "threads.h"
#include "threadvars.h"

#include "tm-queuehandlers.h"
#include "tmqh-simple.h"

Packet *TmqhInputSimple(ThreadVars *t);
void TmqhOutputSimple(ThreadVars *t, Packet *p);
void TmqhInputSimpleShutdownHandler(ThreadVars *);

void TmqhSimpleRegister (void)
{
    tmqh_table[TMQH_SIMPLE].name = "simple";
    tmqh_table[TMQH_SIMPLE].InHandler = TmqhInputSimple;
    tmqh_table[TMQH_SIMPLE].InShutdownHandler = TmqhInputSimpleShutdownHandler;
    tmqh_table[TMQH_SIMPLE].OutHandler = TmqhOutputSimple;
}

Packet *TmqhInputSimple(ThreadVars *t)
{
    PacketQueue *q = t->inq->pq;

    StatsSyncCountersIfSignalled(&t->stats);

    SCMutexLock(&q->mutex_q);

    if (q->len == 0) {
        /* if we have no packets in queue, wait... */
        SCCondWait(&q->cond_q, &q->mutex_q);
    }

    if (q->len > 0) {
        Packet *p = PacketDequeue(q);
        SCMutexUnlock(&q->mutex_q);
        return p;
    } else {
        /* return NULL if we have no pkt. Should only happen on signals. */
        SCMutexUnlock(&q->mutex_q);
        return NULL;
    }
}

void TmqhInputSimpleShutdownHandler(ThreadVars *tv)
{
    int i;

    if (tv == NULL || tv->inq == NULL) {
        return;
    }

    for (i = 0; i < (tv->inq->reader_cnt + tv->inq->writer_cnt); i++) {
        SCMutexLock(&tv->inq->pq->mutex_q);
        SCCondSignal(&tv->inq->pq->cond_q);
        SCMutexUnlock(&tv->inq->pq->mutex_q);
    }
}

void TmqhOutputSimple(ThreadVars *t, Packet *p)
{
    SCLogDebug("Packet %p, p->root %p, alloced %s", p, p->root, BOOL2STR(p->pool == NULL));

    PacketQueue *q = t->outq->pq;

    SCMutexLock(&q->mutex_q);
    PacketEnqueue(q, p);
    SCCondSignal(&q->cond_q);
    SCMutexUnlock(&q->mutex_q);
}


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
35	Packet TmqhInputSimple(ThreadVars t);
36	void TmqhOutputSimple(ThreadVars t, Packet p);
37	void TmqhInputSimpleShutdownHandler(ThreadVars *);
38
39	void TmqhSimpleRegister (void)
40	{	2,216✔
41	tmqh_table[TMQH_SIMPLE].name = "simple";	2,216✔
42	tmqh_table[TMQH_SIMPLE].InHandler = TmqhInputSimple;	2,216✔
43	tmqh_table[TMQH_SIMPLE].InShutdownHandler = TmqhInputSimpleShutdownHandler;	2,216✔
44	tmqh_table[TMQH_SIMPLE].OutHandler = TmqhOutputSimple;	2,216✔
45	}	2,216✔
46
47	Packet TmqhInputSimple(ThreadVars t)
48	{	×
49	PacketQueue *q = t->inq->pq;	×
50
51	StatsSyncCountersIfSignalled(&t->stats);	×
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);	×
62	SCMutexUnlock(&q->mutex_q);	×
63	return p;	×
64	} else {	×
65	/* return NULL if we have no pkt. Should only happen on signals. */
66	SCMutexUnlock(&q->mutex_q);	×
67	return NULL;	×
68	}	×
69	}	×
70
71	void TmqhInputSimpleShutdownHandler(ThreadVars *tv)
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++) {	×
80	SCMutexLock(&tv->inq->pq->mutex_q);	×
81	SCCondSignal(&tv->inq->pq->cond_q);	×
82	SCMutexUnlock(&tv->inq->pq->mutex_q);	×
83	}	×
84	}	×
85
86	void TmqhOutputSimple(ThreadVars t, Packet p)
87	{	×
88	SCLogDebug("Packet %p, p->root %p, alloced %s", p, p->root, BOOL2STR(p->pool == NULL));	×
89
90	PacketQueue *q = t->outq->pq;	×
91
92	SCMutexLock(&q->mutex_q);	×
93	PacketEnqueue(q, p);	×
94	SCCondSignal(&q->cond_q);	×
95	SCMutexUnlock(&q->mutex_q);	×
96	}	×
97

jasonish / suricata / 23268535754

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous