test_qdisk.c File Reference

#include <criterion/criterion.h>
#include "syslog-ng.h"
#include "apphook.h"
#include "qdisk.h"
#include "scratch-buffers.h"
#include <unistd.h>
#include <sys/stat.h>
#include <errno.h>

Include dependency graph for test_qdisk.c:

Macros
#define	FRAME_LENGTH   4
#define	DUMMY_RECORD_PATTERN   ('z')
#define	MiB(x)   (x * 1024 * 1024)

Enumerations
enum	TestDiskQType { TDISKQ_NON_RELIABLE = 0 , TDISKQ_RELIABLE = 1 }

Functions
gboolean	generate_dummy_payload (SerializeArchive *sa, gpointer user_data)
gboolean	push_dummy_record (QDisk *qdisk, guint record_size)
void	assert_dummy_record (const GString *record, guint expected_size)
gboolean	reliable_pop_record_without_backlog (QDisk *qdisk, GString *record)
	Test (qdisk, test_qdisk_started)
	Test (qdisk, qdisk_basic_push_pop)
	Test (qdisk, qdisk_is_space_avail)
	Test (qdisk, qdisk_remove_head)
	Test (qdisk, qdisk_basic_ack_rewind)
	Test (qdisk, qdisk_empty_backlog)
	Test (qdisk, allow_writing_more_than_max_size_when_last_message_does_not_fit)
	Test (qdisk, do_not_allow_diskq_to_exceed_max_size_if_last_message_fits)
	Test (qdisk, completely_full_and_then_emptied_qdisk_should_update_positions_properly)
	Test (qdisk, prealloc)
	Test (qdisk, get_empty_space_non_wrapped)
	Test (qdisk, get_empty_space_wrapped)
	TestSuite (qdisk,.init=setup,.fini=teardown)

Macro Definition Documentation

DUMMY_RECORD_PATTERN

#define DUMMY_RECORD_PATTERN   ('z')

FRAME_LENGTH

#define FRAME_LENGTH   4

MiB

#define MiB

(

x

)

(x * 1024 * 1024)

Enumeration Type Documentation

TestDiskQType

enum TestDiskQType

Enumerator
TDISKQ_NON_RELIABLE
TDISKQ_RELIABLE

Function Documentation

assert_dummy_record()

void assert_dummy_record	(	const GString *	record,
		guint	expected_size
	)

generate_dummy_payload()

gboolean generate_dummy_payload	(	SerializeArchive *	sa,
		gpointer	user_data
	)

push_dummy_record()

gboolean push_dummy_record	(	QDisk *	qdisk,
		guint	record_size
	)

reliable_pop_record_without_backlog()

gboolean reliable_pop_record_without_backlog	(	QDisk *	qdisk,
		GString *	record
	)

Test() [1/12]

Test	(	qdisk	,
		allow_writing_more_than_max_size_when_last_message_does_not_fit
	)

Test() [2/12]

Test	(	qdisk	,
		completely_full_and_then_emptied_qdisk_should_update_positions_properly
	)

Test() [3/12]

Test	(	qdisk	,
		do_not_allow_diskq_to_exceed_max_size_if_last_message_fits
	)

Test() [4/12]

Test	(	qdisk	,
		get_empty_space_non_wrapped
	)

Test() [5/12]

Test	(	qdisk	,
		get_empty_space_wrapped
	)

Test() [6/12]

Test	(	qdisk	,
		prealloc
	)

Test() [7/12]

Test	(	qdisk	,
		qdisk_basic_ack_rewind
	)

Test() [8/12]

Test	(	qdisk	,
		qdisk_basic_push_pop
	)

Test() [9/12]

Test	(	qdisk	,
		qdisk_empty_backlog
	)

Test() [10/12]

Test	(	qdisk	,
		qdisk_is_space_avail
	)

Test() [11/12]

Test	(	qdisk	,
		qdisk_remove_head
	)

Test() [12/12]

Test	(	qdisk	,
		test_qdisk_started
	)

TestSuite()

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