test_reliable_backlog.c File Reference

#include <criterion/criterion.h>
#include "libtest/queue_utils_lib.h"
#include "test_diskq_tools.h"
#include "qdisk.c"
#include "logqueue-disk-reliable.h"
#include "apphook.h"
#include "plugin.h"
#include <sys/types.h>
#include <sys/stat.h>
#include <unistd.h>

Include dependency graph for test_reliable_backlog.c:

Macros
#define	TEST_DISKQ_SIZE   QDISK_RESERVED_SPACE + 1000 /* 4096 + 1000 */
#define	NUMBER_MESSAGES_IN_QUEUE(n)   (n * 3)

Functions
	Test (diskq_reliable, test_over_EOF)
void	_prepare_rewind_backlog_test (LogQueueDiskReliable *dq, gint64 *start_pos)
void	test_rewind_backlog_without_using_backlog (LogQueueDiskReliable *dq, gint64 old_read_pos)
void	test_rewind_backlog_partially_used_backlog (LogQueueDiskReliable *dq, gint64 old_read_pos)
void	test_rewind_backlog_use_whole_backlog (LogQueueDiskReliable *dq)
	Test (diskq_reliable, test_rewind_backlog)
	TestSuite (diskq_reliable,.init=setup,.fini=teardown)

Variables
DiskQueueOptions	options

Macro Definition Documentation

NUMBER_MESSAGES_IN_QUEUE

#define NUMBER_MESSAGES_IN_QUEUE

(

n

)

(n * 3)

TEST_DISKQ_SIZE

#define TEST_DISKQ_SIZE   QDISK_RESERVED_SPACE + 1000 /* 4096 + 1000 */

Function Documentation

_prepare_rewind_backlog_test()

void _prepare_rewind_backlog_test	(	LogQueueDiskReliable *	dq,
		gint64 *	start_pos
	)

Test() [1/2]

Test	(	diskq_reliable	,
		test_over_EOF
	)

Test() [2/2]

Test	(	diskq_reliable	,
		test_rewind_backlog
	)

test_rewind_backlog_partially_used_backlog()

void test_rewind_backlog_partially_used_backlog	(	LogQueueDiskReliable *	dq,
		gint64	old_read_pos
	)

test_rewind_backlog_use_whole_backlog()

void test_rewind_backlog_use_whole_backlog

(

LogQueueDiskReliable *

dq

)

test_rewind_backlog_without_using_backlog()

void test_rewind_backlog_without_using_backlog	(	LogQueueDiskReliable *	dq,
		gint64	old_read_pos
	)

TestSuite()

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

Variable Documentation

options

DiskQueueOptions options