Go to the documentation of this file.
33 static uint16_t tmq_id = 0;
55 SCLogDebug(
"created queue \'%s\', %p", name, q);
63 if (strcmp(tmq->
name, name) == 0)
75 printf(
"TmqDebugList: id %" PRIu32
", name \'%s\', len %" PRIu32
"\n", tmq->
id, tmq->
name, tmq->
pq->
len);
109 SCLogError(
"queue \"%s\" doesn't have a reader (id %d max %u)", tmq->
name, tmq->
id,
113 SCLogError(
"queue \"%s\" doesn't have a writer (id %d, max %u)", tmq->
name, tmq->
id,
126 FatalError(
"fatal error during threading setup");
struct HtpBodyChunk_ * next
#define TAILQ_FOREACH(var, head, field)
void TmValidateQueueState(void)
Checks if all the queues allocated so far have at least one reader and writer.
#define TAILQ_HEAD_INITIALIZER(head)
#define TAILQ_REMOVE(head, elm, field)
#define TAILQ_FIRST(head)
#define SCMutexUnlock(mut)
Tmq * TmqGetQueueByName(const char *name)
#define SCLogError(...)
Macro used to log ERROR messages.
Tmq * TmqCreateQueue(const char *name)
PacketQueue * PacketQueueAlloc(void)
void PacketQueueFree(PacketQueue *pq)
#define TAILQ_HEAD(name, type)
#define TAILQ_INSERT_HEAD(head, elm, field)
void TmqResetQueues(void)