greenplumn checkpointer_test 源码

2022-08-18
浏览 (234)

greenplumn checkpointer_test 代码

文件路径：/src/backend/postmaster/test/checkpointer_test.c

#include <stdarg.h>
#include <stddef.h>
#include <setjmp.h>
#include "cmockery.h"

#include "c.h"
#include "../checkpointer.c"
#include "postgres.h"

#define MAX_BGW_REQUESTS 5

static void
init_request_queue(void)
{
	size_t size = sizeof(CheckpointerShmemStruct) + sizeof(CheckpointerRequest)*MAX_BGW_REQUESTS;
	CheckpointerShmem = (CheckpointerShmemStruct *) malloc(size);
	memset(CheckpointerShmem, 0, size);
	CheckpointerShmem->checkpointer_pid = 1234;
	CheckpointerShmem->max_requests = MAX_BGW_REQUESTS;
	IsUnderPostmaster = true;
	ProcGlobal = (PROC_HDR *) malloc(sizeof(PROC_HDR));
	ProcGlobal->checkpointerLatch = NULL;
}

/*
 * Basic enqueue tests, including compaction upon enqueuing into a
 * full queue.
 */
static void
test__ForwardSyncRequest_enqueue(void **state)
{
	bool ret;
	int i;
	FileTag dummy_tag = {1, MAIN_FORKNUM, {1, 1, 1}, 1};
	init_request_queue();
	ProcGlobal->checkpointerLatch = NULL;
	expect_value(LWLockAcquire, lock, CheckpointerCommLock);
	expect_value(LWLockAcquire, mode, LW_EXCLUSIVE);
	will_return(LWLockAcquire, true);
	expect_value(LWLockRelease, lock, CheckpointerCommLock);
	will_be_called(LWLockRelease);
	/* basic enqueue */
	ret = ForwardSyncRequest(&dummy_tag, SYNC_REQUEST);
	assert_true(ret);
	assert_true(CheckpointerShmem->num_requests == 1);
	/* fill up the queue */
	for (i=2; i<=MAX_BGW_REQUESTS; i++)
	{
		expect_value(LWLockAcquire, lock, CheckpointerCommLock);
		expect_value(LWLockAcquire, mode, LW_EXCLUSIVE);
		will_return(LWLockAcquire, true);
		expect_value(LWLockRelease, lock, CheckpointerCommLock);
		will_be_called(LWLockRelease);
		dummy_tag.segno = i;
		ret = ForwardSyncRequest(&dummy_tag, SYNC_REQUEST);
		assert_true(ret);
	}
	expect_value(LWLockAcquire, lock, CheckpointerCommLock);
	expect_value(LWLockAcquire, mode, LW_EXCLUSIVE);
	will_return(LWLockAcquire, true);
	expect_value(LWLockRelease, lock, CheckpointerCommLock);
	will_be_called(LWLockRelease);
#ifdef USE_ASSERT_CHECKING
	expect_value(LWLockHeldByMe, l, CheckpointerCommLock);
	will_return(LWLockHeldByMe, true);
#endif
	/*
	 * This enqueue request should trigger compaction but no
	 * duplicates are in the queue.  So the queue should remain
	 * full.
	 */
	ret = ForwardSyncRequest(&dummy_tag, SYNC_REQUEST);
	assert_false(ret);
	assert_true(CheckpointerShmem->num_requests == CheckpointerShmem->max_requests);
	free(CheckpointerShmem);
}

int
main(int argc, char* argv[]) {
	cmockery_parse_arguments(argc, argv);
	MemoryContextInit();
	const UnitTest tests[] = {
		unit_test(test__ForwardSyncRequest_enqueue)
	};
	return run_tests(tests);
}

相关信息

greenplumn 源码目录

相关文章

greenplumn adminpack 源码

greenplumn verify_nbtree 源码

greenplumn auth_delay 源码

greenplumn auto_explain 源码

greenplumn blcost 源码

greenplumn blinsert 源码

greenplumn bloom 源码

greenplumn blscan 源码

greenplumn blutils 源码

greenplumn blvacuum 源码

0 赞

所属分类： 大数据
本文标签： greenplum
版权声明： 原创文章如转载，请注明本文链接: https://www.seaxiang.com/blog/c694014d228f4259bdc0afece93efee7

热门推荐

1、直接访问google.com
2、 - 优质文章
3、 gate.io
4、 harmony 鸿蒙hdc使用指导
5、 harmony 鸿蒙ArkUI组件（ArkTS）开发常见问题
6、 harmony 鸿蒙初识ArkTS语言
7、 flink kafka connector scan.startup.mode 的几个选项
8、 golang
9、 openharmony
10、 Vue中input框自动聚焦

Loading...