[フレーム]

test_multixact.c File Reference

#include "postgres.h"
#include "access/multixact.h"
#include "access/xact.h"
#include "fmgr.h"
#include "utils/injection_point.h"

Include dependency graph for test_multixact.c:

Go to the source code of this file.

Functions

PG_FUNCTION_INFO_V1 (test_create_multixact)

PG_FUNCTION_INFO_V1 (test_read_multixact)

Datum test_create_multixact (PG_FUNCTION_ARGS)

Datum test_read_multixact (PG_FUNCTION_ARGS)

Function Documentation

◆ PG_FUNCTION_INFO_V1() [1/2]

PG_FUNCTION_INFO_V1 ( test_create_multixact )

◆ PG_FUNCTION_INFO_V1() [2/2]

PG_FUNCTION_INFO_V1 ( test_read_multixact )

◆ test_create_multixact()

Datum test_create_multixact ( PG_FUNCTION_ARGS )

Definition at line 29 of file test_multixact.c.

30{

31 MultiXactId id;

32

33 MultiXactIdSetOldestMember();

34 id = MultiXactIdCreate(GetCurrentTransactionId(), MultiXactStatusUpdate,

35 GetCurrentTransactionId(), MultiXactStatusForShare);

36 PG_RETURN_TRANSACTIONID(id);

37}

MultiXactId

TransactionId MultiXactId

Definition: c.h:667

PG_RETURN_TRANSACTIONID

#define PG_RETURN_TRANSACTIONID(x)

Definition: fmgr.h:364

MultiXactIdSetOldestMember

void MultiXactIdSetOldestMember(void)

Definition: multixact.c:664

MultiXactIdCreate

MultiXactId MultiXactIdCreate(TransactionId xid1, MultiXactStatus status1, TransactionId xid2, MultiXactStatus status2)

Definition: multixact.c:425

MultiXactStatusForShare

@ MultiXactStatusForShare

Definition: multixact.h:41

MultiXactStatusUpdate

@ MultiXactStatusUpdate

Definition: multixact.h:47

GetCurrentTransactionId

TransactionId GetCurrentTransactionId(void)

Definition: xact.c:454

References GetCurrentTransactionId(), MultiXactIdCreate(), MultiXactIdSetOldestMember(), MultiXactStatusForShare, MultiXactStatusUpdate, and PG_RETURN_TRANSACTIONID.

◆ test_read_multixact()

Datum test_read_multixact ( PG_FUNCTION_ARGS )

Definition at line 44 of file test_multixact.c.

45{

46 MultiXactId id = PG_GETARG_TRANSACTIONID(0);

47 MultiXactMember *members;

48

49 INJECTION_POINT("test-multixact-read", NULL);

50 /* discard caches */

51 AtEOXact_MultiXact();

52

53 if (GetMultiXactIdMembers(id, &members, false, false) == -1)

54 elog(ERROR, "MultiXactId not found");

55

56 PG_RETURN_VOID();

57}

ERROR

#define ERROR

Definition: elog.h:39

elog

#define elog(elevel,...)

Definition: elog.h:226

PG_RETURN_VOID

#define PG_RETURN_VOID()

Definition: fmgr.h:349

PG_GETARG_TRANSACTIONID

#define PG_GETARG_TRANSACTIONID(n)

Definition: fmgr.h:279

INJECTION_POINT

#define INJECTION_POINT(name, arg)

Definition: injection_point.h:37

AtEOXact_MultiXact

void AtEOXact_MultiXact(void)

Definition: multixact.c:1799

GetMultiXactIdMembers

int GetMultiXactIdMembers(MultiXactId multi, MultiXactMember **members, bool from_pgupgrade, bool isLockOnly)

Definition: multixact.c:1290

MultiXactMember

Definition: multixact.h:58

References AtEOXact_MultiXact(), elog, ERROR, GetMultiXactIdMembers(), INJECTION_POINT, PG_GETARG_TRANSACTIONID, and PG_RETURN_VOID.