greenplumn fsync_helper 源码

2022-08-18
浏览 (495)

greenplumn fsync_helper 代码

文件路径：/src/test/fsync/fsync_helper.c

#include "postgres.h"
#include "funcapi.h"
#include "nodes/pg_list.h"
#include "storage/buf_internals.h"

#ifdef PG_MODULE_MAGIC
PG_MODULE_MAGIC;
#endif

Datum dirty_buffers(PG_FUNCTION_ARGS);

PG_FUNCTION_INFO_V1(dirty_buffers);
Datum
dirty_buffers(PG_FUNCTION_ARGS)
{
	FuncCallContext    *funcctx;
	MemoryContext		oldcontext;
	List               *dirty_tags;
	BufferTag          *tag;
	AttrNumber          attno;
#define natts 4 /* (RelFileNode, segno) */

	if (SRF_IS_FIRSTCALL())
	{
		TupleDesc	tupdesc;
		int i;

		funcctx = SRF_FIRSTCALL_INIT();
		oldcontext = MemoryContextSwitchTo(funcctx->multi_call_memory_ctx);
		tupdesc = CreateTemplateTupleDesc(natts);
		attno = 1;
		TupleDescInitEntry(tupdesc, attno++, "tablespace", OIDOID, -1, 0);
		TupleDescInitEntry(tupdesc, attno++, "database", OIDOID, -1, 0);
		TupleDescInitEntry(tupdesc, attno++, "relfilenode", OIDOID, -1, 0);
		TupleDescInitEntry(tupdesc, attno++, "block", INT4OID, -1, 0);
		funcctx->tuple_desc = BlessTupleDesc(tupdesc);

		dirty_tags = NIL;
		for (i = 0; i < NBuffers; i++)
		{
			BufferDesc *bufHdr = GetBufferDescriptor(i);

			if ((pg_atomic_read_u32(&bufHdr->state) & (BM_DIRTY | BM_JUST_DIRTIED)) != 0)
			{
				tag = (BufferTag *) palloc(sizeof(BufferTag));
				/*
				 * XXX: this reads the tag without a lock. That's not cool, but it
				 * works enough for our test.
				 */
				*tag = bufHdr->tag;
				dirty_tags = lappend(dirty_tags, tag);
			}
		}

		funcctx->user_fctx = (void *) dirty_tags;
		MemoryContextSwitchTo(oldcontext);
	}

	funcctx = SRF_PERCALL_SETUP();
	dirty_tags = (List *) funcctx->user_fctx;
	if (list_length(dirty_tags) > 0)
	{
		Datum            result;
		Datum            values[natts];
		bool             nulls[natts];
		HeapTuple        tuple;

		tag = (BufferTag *) linitial(dirty_tags);
		attno = 0;
		values[attno++] = tag->rnode.spcNode;
		values[attno++] = tag->rnode.dbNode;
		values[attno++] = tag->rnode.relNode;
		values[attno++] = tag->blockNum;
		memset(nulls, 0, natts * sizeof(bool));
		tuple = heap_form_tuple(funcctx->tuple_desc, values, nulls);
		result = HeapTupleGetDatum(tuple);
		dirty_tags = list_delete(dirty_tags, (void *)tag);
		funcctx->user_fctx = (void *) dirty_tags;
		SRF_RETURN_NEXT(funcctx, result);
	}
	SRF_RETURN_DONE(funcctx);
}

相关信息

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/a1d757d84618486c88e923f4cc7a9596

热门推荐

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

Loading...