test_logqueue.c File Reference

#include <criterion/criterion.h>
#include "libtest/msg_parse_lib.h"
#include "libtest/queue_utils_lib.h"
#include "logqueue.h"
#include "logqueue-fifo.h"
#include "logpipe.h"
#include "apphook.h"
#include "plugin.h"
#include "mainloop.h"
#include "mainloop-io-worker.h"
#include "timeutils/misc.h"
#include "stats/stats-cluster-single.h"
#include <stdlib.h>
#include <string.h>
#include <iv.h>
#include <iv_list.h>
#include <iv_thread.h>

Include dependency graph for test_logqueue.c:

Macros
#define	OVERFLOW_SIZE   10000
#define	FEEDERS   1
#define	MESSAGES_PER_FEEDER   30000
#define	MESSAGES_SUM   (FEEDERS * MESSAGES_PER_FEEDER)
#define	TEST_RUNS   10

Functions
void	setup (void)
void	teardown (void)
	TestSuite (logqueue,.init=setup,.fini=teardown)
	Test (logqueue, test_zero_diskbuf_and_normal_acks)
	Test (logqueue, test_zero_diskbuf_alternating_send_acks)
	Test (logqueue, test_with_threads)
	Test (logqueue, log_queue_fifo_rewind_all_and_memory_usage)
	Test (logqueue, log_queue_fifo_should_drop_only_non_flow_controlled_messages,.description="Flow-controlled messages should never be dropped")
	Test (logqueue, log_queue_fifo_should_drop_only_non_flow_controlled_messages_threaded,.description="Flow-controlled messages should never be dropped (using input queues with threads")
	Test (logqueue, log_queue_fifo_multiple_queues)

Variables
GMutex	tlock
glong	sum_time

Macro Definition Documentation

FEEDERS

#define FEEDERS   1

MESSAGES_PER_FEEDER

#define MESSAGES_PER_FEEDER   30000

MESSAGES_SUM

#define MESSAGES_SUM   (FEEDERS * MESSAGES_PER_FEEDER)

OVERFLOW_SIZE

#define OVERFLOW_SIZE   10000

TEST_RUNS

#define TEST_RUNS   10

Function Documentation

setup()

void setup

(

void

)

teardown()

void teardown

(

void

)

Test() [1/7]

Test	(	logqueue	,
		log_queue_fifo_multiple_queues
	)

Test() [2/7]

Test	(	logqueue	,
		log_queue_fifo_rewind_all_and_memory_usage
	)

Test() [3/7]

Test	(	logqueue	,
		log_queue_fifo_should_drop_only_non_flow_controlled_messages	,
		.	description = "Flow-controlled messages should never be dropped"
	)

Test() [4/7]

Test	(	logqueue	,
		log_queue_fifo_should_drop_only_non_flow_controlled_messages_threaded	,
		.	description = "Flow-controlled messages should never be dropped (using input queues with threads"
	)

Test() [5/7]

Test	(	logqueue	,
		test_with_threads
	)

Test() [6/7]

Test	(	logqueue	,
		test_zero_diskbuf_alternating_send_acks
	)

Test() [7/7]

Test	(	logqueue	,
		test_zero_diskbuf_and_normal_acks
	)

TestSuite()

TestSuite	(	logqueue	,
		.	init = setup,
		.	fini = teardown
	)

Variable Documentation

sum_time

glong sum_time

tlock

GMutex tlock