test_diskq.c File Reference

#include <criterion/criterion.h>
#include <criterion/parameterized.h>
#include "libtest/queue_utils_lib.h"
#include "test_diskq_tools.h"
#include "logqueue.h"
#include "logqueue-fifo.h"
#include "logqueue-disk.h"
#include "logqueue-disk-reliable.h"
#include "logqueue-disk-non-reliable.h"
#include "stats/stats-cluster-single.h"
#include "diskq.h"
#include "logpipe.h"
#include "apphook.h"
#include "plugin.h"
#include "mainloop.h"
#include "mainloop-call.h"
#include "mainloop-io-worker.h"
#include "tls-support.h"
#include "timeutils/misc.h"
#include <stdlib.h>
#include <string.h>
#include <iv.h>
#include <iv_thread.h>
#include <sys/stat.h>

Include dependency graph for test_diskq.c:

Classes
struct	restart_test_parameters
struct	diskq_tester_parameters_t

Macros
#define	OVERFLOW_SIZE   10000
#define	PATH_QDISK   "./"
#define	FEEDERS   1
#define	MESSAGES_PER_FEEDER   10000
#define	MESSAGES_SUM   (FEEDERS * MESSAGES_PER_FEEDER)
#define	TEST_RUNS   10

Functions
	Test (diskq, testcase_zero_diskbuf_and_normal_acks)
	Test (diskq, testcase_zero_diskbuf_alternating_send_acks)
	Test (diskq, testcase_ack_and_rewind_messages)
	Test (diskq, testcase_with_threads)
	ParameterizedTestParameters (diskq, testcase_diskbuffer_restart_corrupted)
	ParameterizedTest (restart_test_parameters *test_case, diskq, testcase_diskbuffer_restart_corrupted)
	ParameterizedTestParameters (diskq, test_diskq_statistics)
	ParameterizedTest (diskq_tester_parameters_t *parameters, diskq, test_diskq_statistics)
gchar *	qdisk_get_next_filename (const gchar *dir, gboolean reliable)
	Test (diskq, test_no_next_filename_in_acquire)
	TestSuite (diskq,.init=setup,.fini=teardown)

Variables
GMutex	tlock
glong	sum_time

Macro Definition Documentation

FEEDERS

#define FEEDERS   1

MESSAGES_PER_FEEDER

#define MESSAGES_PER_FEEDER   10000

MESSAGES_SUM

#define MESSAGES_SUM   (FEEDERS * MESSAGES_PER_FEEDER)

OVERFLOW_SIZE

#define OVERFLOW_SIZE   10000

PATH_QDISK

#define PATH_QDISK   "./"

TEST_RUNS

#define TEST_RUNS   10

Function Documentation

ParameterizedTest() [1/2]

ParameterizedTest	(	diskq_tester_parameters_t *	parameters,
		diskq	,
		test_diskq_statistics
	)

ParameterizedTest() [2/2]

ParameterizedTest	(	restart_test_parameters *	test_case,
		diskq	,
		testcase_diskbuffer_restart_corrupted
	)

ParameterizedTestParameters() [1/2]

ParameterizedTestParameters	(	diskq	,
		test_diskq_statistics
	)

ParameterizedTestParameters() [2/2]

ParameterizedTestParameters	(	diskq	,
		testcase_diskbuffer_restart_corrupted
	)

qdisk_get_next_filename()

gchar* qdisk_get_next_filename	(	const gchar *	dir,
		gboolean	reliable
	)

Test() [1/5]

Test	(	diskq	,
		test_no_next_filename_in_acquire
	)

Test() [2/5]

Test	(	diskq	,
		testcase_ack_and_rewind_messages
	)

Test() [3/5]

Test	(	diskq	,
		testcase_with_threads
	)

Test() [4/5]

Test	(	diskq	,
		testcase_zero_diskbuf_alternating_send_acks
	)

Test() [5/5]

Test	(	diskq	,
		testcase_zero_diskbuf_and_normal_acks
	)

TestSuite()

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

Variable Documentation

sum_time

glong sum_time

tlock

GMutex tlock