#include "postgres.h"
#include <limits.h>
#include "access/multixact.h"
#include "access/transam.h"
#include "access/xact.h"
#include "libpq/pqformat.h"
#include "utils/builtins.h"
#include "utils/xid8.h"

Include dependency graph for xid.c:

Macros
#define	PG_GETARG_COMMANDID(n) DatumGetCommandId(PG_GETARG_DATUM(n))

#define	PG_RETURN_COMMANDID(x) return CommandIdGetDatum(x)

Functions
Datum	xidin (PG_FUNCTION_ARGS)

Datum	xidout (PG_FUNCTION_ARGS)

Datum	xidrecv (PG_FUNCTION_ARGS)

Datum	xidsend (PG_FUNCTION_ARGS)

Datum	xideq (PG_FUNCTION_ARGS)

Datum	xidneq (PG_FUNCTION_ARGS)

Datum	xid_age (PG_FUNCTION_ARGS)

Datum	mxid_age (PG_FUNCTION_ARGS)

int	xidComparator (const void arg1, const void arg2)

Datum	xid8toxid (PG_FUNCTION_ARGS)

Datum	xid8in (PG_FUNCTION_ARGS)

Datum	xid8out (PG_FUNCTION_ARGS)

Datum	xid8recv (PG_FUNCTION_ARGS)

Datum	xid8send (PG_FUNCTION_ARGS)

Datum	xid8eq (PG_FUNCTION_ARGS)

Datum	xid8ne (PG_FUNCTION_ARGS)

Datum	xid8lt (PG_FUNCTION_ARGS)

Datum	xid8gt (PG_FUNCTION_ARGS)

Datum	xid8le (PG_FUNCTION_ARGS)

Datum	xid8ge (PG_FUNCTION_ARGS)

Datum	xid8cmp (PG_FUNCTION_ARGS)

Datum	cidin (PG_FUNCTION_ARGS)

Datum	cidout (PG_FUNCTION_ARGS)

Datum	cidrecv (PG_FUNCTION_ARGS)

Datum	cidsend (PG_FUNCTION_ARGS)

Datum	cideq (PG_FUNCTION_ARGS)

Macro Definition Documentation

◆ PG_GETARG_COMMANDID

#define PG_GETARG_COMMANDID ( n ) DatumGetCommandId(PG_GETARG_DATUM(n))

Definition at line 26 of file xid.c.

Referenced by cideq(), cidout(), and cidsend().

◆ PG_RETURN_COMMANDID

#define PG_RETURN_COMMANDID ( x ) return CommandIdGetDatum(x)

Definition at line 27 of file xid.c.

Referenced by cidin(), and cidrecv().

Function Documentation

◆ cideq()

Datum cideq ( PG_FUNCTION_ARGS )

Definition at line 317 of file xid.c.

References PG_GETARG_COMMANDID, and PG_RETURN_BOOL.

 {
     CommandId   arg1 = PG_GETARG_COMMANDID(0);
     CommandId   arg2 = PG_GETARG_COMMANDID(1);
 
     PG_RETURN_BOOL(arg1 == arg2);
 }

◆ cidin()

Datum cidin ( PG_FUNCTION_ARGS )

Definition at line 271 of file xid.c.

References PG_GETARG_CSTRING, PG_RETURN_COMMANDID, and generate_unaccent_rules::str.

 {
     char       *str = PG_GETARG_CSTRING(0);
 
     PG_RETURN_COMMANDID((CommandId) strtoul(str, NULL, 0));
 }

◆ cidout()

Datum cidout ( PG_FUNCTION_ARGS )

Definition at line 282 of file xid.c.

References palloc(), PG_GETARG_COMMANDID, PG_RETURN_CSTRING, and snprintf.

 {
     CommandId   c = PG_GETARG_COMMANDID(0);
     char       *result = (char *) palloc(16);
 
     snprintf(result, 16, "%lu", (unsigned long) c);
     PG_RETURN_CSTRING(result);
 }

◆ cidrecv()

Datum cidrecv ( PG_FUNCTION_ARGS )

Definition at line 295 of file xid.c.

References buf, PG_GETARG_POINTER, PG_RETURN_COMMANDID, and pq_getmsgint().

 {
     StringInfo  buf = (StringInfo) PG_GETARG_POINTER(0);
 
     PG_RETURN_COMMANDID((CommandId) pq_getmsgint(buf, sizeof(CommandId)));
 }

◆ cidsend()

Datum cidsend ( PG_FUNCTION_ARGS )

Definition at line 306 of file xid.c.

References buf, PG_GETARG_COMMANDID, PG_RETURN_BYTEA_P, pq_begintypsend(), pq_endtypsend(), and pq_sendint32().

 {
     CommandId   arg1 = PG_GETARG_COMMANDID(0);
     StringInfoData buf;
 
     pq_begintypsend(&buf);
     pq_sendint32(&buf, arg1);
     PG_RETURN_BYTEA_P(pq_endtypsend(&buf));
 }

◆ mxid_age()

Datum mxid_age ( PG_FUNCTION_ARGS )

Definition at line 117 of file xid.c.

References MultiXactIdIsValid, now(), PG_GETARG_TRANSACTIONID, PG_RETURN_INT32, and ReadNextMultiXactId().

 {
     TransactionId xid = PG_GETARG_TRANSACTIONID(0);
     MultiXactId now = ReadNextMultiXactId();
 
     if (!MultiXactIdIsValid(xid))
         PG_RETURN_INT32(INT_MAX);
 
     PG_RETURN_INT32((int32) (now - xid));
 }

◆ xid8cmp()

Datum xid8cmp ( PG_FUNCTION_ARGS )

Definition at line 250 of file xid.c.

References FullTransactionIdEquals, FullTransactionIdFollows, PG_GETARG_FULLTRANSACTIONID, and PG_RETURN_INT32.

 {
     FullTransactionId fxid1 = PG_GETARG_FULLTRANSACTIONID(0);
     FullTransactionId fxid2 = PG_GETARG_FULLTRANSACTIONID(1);
 
     if (FullTransactionIdFollows(fxid1, fxid2))
         PG_RETURN_INT32(1);
     else if (FullTransactionIdEquals(fxid1, fxid2))
         PG_RETURN_INT32(0);
     else
         PG_RETURN_INT32(-1);
 }

◆ xid8eq()

Datum xid8eq ( PG_FUNCTION_ARGS )

Definition at line 196 of file xid.c.

References FullTransactionIdEquals, PG_GETARG_FULLTRANSACTIONID, and PG_RETURN_BOOL.

 {
     FullTransactionId fxid1 = PG_GETARG_FULLTRANSACTIONID(0);
     FullTransactionId fxid2 = PG_GETARG_FULLTRANSACTIONID(1);
 
     PG_RETURN_BOOL(FullTransactionIdEquals(fxid1, fxid2));
 }

◆ xid8ge()

Datum xid8ge ( PG_FUNCTION_ARGS )

Definition at line 241 of file xid.c.

References FullTransactionIdFollowsOrEquals, PG_GETARG_FULLTRANSACTIONID, and PG_RETURN_BOOL.

 {
     FullTransactionId fxid1 = PG_GETARG_FULLTRANSACTIONID(0);
     FullTransactionId fxid2 = PG_GETARG_FULLTRANSACTIONID(1);
 
     PG_RETURN_BOOL(FullTransactionIdFollowsOrEquals(fxid1, fxid2));
 }

◆ xid8gt()

Datum xid8gt ( PG_FUNCTION_ARGS )

Definition at line 223 of file xid.c.

References FullTransactionIdFollows, PG_GETARG_FULLTRANSACTIONID, and PG_RETURN_BOOL.

 {
     FullTransactionId fxid1 = PG_GETARG_FULLTRANSACTIONID(0);
     FullTransactionId fxid2 = PG_GETARG_FULLTRANSACTIONID(1);
 
     PG_RETURN_BOOL(FullTransactionIdFollows(fxid1, fxid2));
 }

◆ xid8in()

Datum xid8in ( PG_FUNCTION_ARGS )

Definition at line 157 of file xid.c.

References FullTransactionIdFromU64(), PG_GETARG_CSTRING, PG_RETURN_FULLTRANSACTIONID, pg_strtouint64(), and generate_unaccent_rules::str.

 {
     char       *str = PG_GETARG_CSTRING(0);
 
     PG_RETURN_FULLTRANSACTIONID(FullTransactionIdFromU64(pg_strtouint64(str, NULL, 0)));
 }

◆ xid8le()

Datum xid8le ( PG_FUNCTION_ARGS )

Definition at line 232 of file xid.c.

References FullTransactionIdPrecedesOrEquals, PG_GETARG_FULLTRANSACTIONID, and PG_RETURN_BOOL.

 {
     FullTransactionId fxid1 = PG_GETARG_FULLTRANSACTIONID(0);
     FullTransactionId fxid2 = PG_GETARG_FULLTRANSACTIONID(1);
 
     PG_RETURN_BOOL(FullTransactionIdPrecedesOrEquals(fxid1, fxid2));
 }

◆ xid8lt()

Datum xid8lt ( PG_FUNCTION_ARGS )

Definition at line 214 of file xid.c.

References FullTransactionIdPrecedes, PG_GETARG_FULLTRANSACTIONID, and PG_RETURN_BOOL.

 {
     FullTransactionId fxid1 = PG_GETARG_FULLTRANSACTIONID(0);
     FullTransactionId fxid2 = PG_GETARG_FULLTRANSACTIONID(1);
 
     PG_RETURN_BOOL(FullTransactionIdPrecedes(fxid1, fxid2));
 }

◆ xid8ne()

Datum xid8ne ( PG_FUNCTION_ARGS )

Definition at line 205 of file xid.c.

References FullTransactionIdEquals, PG_GETARG_FULLTRANSACTIONID, and PG_RETURN_BOOL.

 {
     FullTransactionId fxid1 = PG_GETARG_FULLTRANSACTIONID(0);
     FullTransactionId fxid2 = PG_GETARG_FULLTRANSACTIONID(1);
 
     PG_RETURN_BOOL(!FullTransactionIdEquals(fxid1, fxid2));
 }

◆ xid8out()

Datum xid8out ( PG_FUNCTION_ARGS )

Definition at line 165 of file xid.c.

References palloc(), PG_GETARG_FULLTRANSACTIONID, PG_RETURN_CSTRING, snprintf, U64FromFullTransactionId, and UINT64_FORMAT.

 {
     FullTransactionId fxid = PG_GETARG_FULLTRANSACTIONID(0);
     char       *result = (char *) palloc(21);
 
     snprintf(result, 21, UINT64_FORMAT, U64FromFullTransactionId(fxid));
     PG_RETURN_CSTRING(result);
 }

◆ xid8recv()

Datum xid8recv ( PG_FUNCTION_ARGS )

Definition at line 175 of file xid.c.

References buf, FullTransactionIdFromU64(), PG_GETARG_POINTER, PG_RETURN_FULLTRANSACTIONID, pq_getmsgint64(), and value.

 {
     StringInfo  buf = (StringInfo) PG_GETARG_POINTER(0);
     uint64      value;
 
     value = (uint64) pq_getmsgint64(buf);
     PG_RETURN_FULLTRANSACTIONID(FullTransactionIdFromU64(value));
 }

◆ xid8send()

Datum xid8send ( PG_FUNCTION_ARGS )

Definition at line 185 of file xid.c.

References buf, PG_GETARG_FULLTRANSACTIONID, PG_RETURN_BYTEA_P, pq_begintypsend(), pq_endtypsend(), pq_sendint64(), and U64FromFullTransactionId.

 {
     FullTransactionId arg1 = PG_GETARG_FULLTRANSACTIONID(0);
     StringInfoData buf;
 
     pq_begintypsend(&buf);
     pq_sendint64(&buf, (uint64) U64FromFullTransactionId(arg1));
     PG_RETURN_BYTEA_P(pq_endtypsend(&buf));
 }

◆ xid8toxid()

Datum xid8toxid ( PG_FUNCTION_ARGS )

Definition at line 149 of file xid.c.

References PG_GETARG_FULLTRANSACTIONID, PG_RETURN_TRANSACTIONID, and XidFromFullTransactionId.

 {
     FullTransactionId fxid = PG_GETARG_FULLTRANSACTIONID(0);
 
     PG_RETURN_TRANSACTIONID(XidFromFullTransactionId(fxid));
 }

◆ xid_age()

Datum xid_age ( PG_FUNCTION_ARGS )

Definition at line 101 of file xid.c.

References GetStableLatestTransactionId(), now(), PG_GETARG_TRANSACTIONID, PG_RETURN_INT32, and TransactionIdIsNormal.

 {
     TransactionId xid = PG_GETARG_TRANSACTIONID(0);
     TransactionId now = GetStableLatestTransactionId();
 
     /* Permanent XIDs are always infinitely old */
     if (!TransactionIdIsNormal(xid))
         PG_RETURN_INT32(INT_MAX);
 
     PG_RETURN_INT32((int32) (now - xid));
 }

◆ xidComparator()

int xidComparator	(	const void *	arg1,
		const void *	arg2
	)

Definition at line 136 of file xid.c.

Referenced by ProcArrayApplyRecoveryInfo(), ReorderBufferCopySnap(), SerializeTransactionState(), SnapBuildBuildSnapshot(), SnapBuildInitialSnapshot(), and TransactionIdInArray().

 {
     TransactionId xid1 = *(const TransactionId *) arg1;
     TransactionId xid2 = *(const TransactionId *) arg2;
 
     if (xid1 > xid2)
         return 1;
     if (xid1 < xid2)
         return -1;
     return 0;
 }

◆ xideq()

Datum xideq ( PG_FUNCTION_ARGS )

Definition at line 77 of file xid.c.

References PG_GETARG_TRANSACTIONID, PG_RETURN_BOOL, and TransactionIdEquals.

 {
     TransactionId xid1 = PG_GETARG_TRANSACTIONID(0);
     TransactionId xid2 = PG_GETARG_TRANSACTIONID(1);
 
     PG_RETURN_BOOL(TransactionIdEquals(xid1, xid2));
 }

◆ xidin()

Datum xidin ( PG_FUNCTION_ARGS )

Definition at line 31 of file xid.c.

References PG_GETARG_CSTRING, PG_RETURN_TRANSACTIONID, and generate_unaccent_rules::str.

 {
     char       *str = PG_GETARG_CSTRING(0);
 
     PG_RETURN_TRANSACTIONID((TransactionId) strtoul(str, NULL, 0));
 }

◆ xidneq()

Datum xidneq ( PG_FUNCTION_ARGS )

Definition at line 89 of file xid.c.

References PG_GETARG_TRANSACTIONID, PG_RETURN_BOOL, and TransactionIdEquals.

 {
     TransactionId xid1 = PG_GETARG_TRANSACTIONID(0);
     TransactionId xid2 = PG_GETARG_TRANSACTIONID(1);
 
     PG_RETURN_BOOL(!TransactionIdEquals(xid1, xid2));
 }

◆ xidout()

Datum xidout ( PG_FUNCTION_ARGS )

Definition at line 39 of file xid.c.

References palloc(), PG_GETARG_TRANSACTIONID, PG_RETURN_CSTRING, and snprintf.

 {
     TransactionId transactionId = PG_GETARG_TRANSACTIONID(0);
     char       *result = (char *) palloc(16);
 
     snprintf(result, 16, "%lu", (unsigned long) transactionId);
     PG_RETURN_CSTRING(result);
 }

◆ xidrecv()

Datum xidrecv ( PG_FUNCTION_ARGS )

Definition at line 52 of file xid.c.

References buf, PG_GETARG_POINTER, PG_RETURN_TRANSACTIONID, and pq_getmsgint().

 {
     StringInfo  buf = (StringInfo) PG_GETARG_POINTER(0);
 
     PG_RETURN_TRANSACTIONID((TransactionId) pq_getmsgint(buf, sizeof(TransactionId)));
 }

◆ xidsend()

Datum xidsend ( PG_FUNCTION_ARGS )

Definition at line 63 of file xid.c.

References buf, PG_GETARG_TRANSACTIONID, PG_RETURN_BYTEA_P, pq_begintypsend(), pq_endtypsend(), and pq_sendint32().

 {
     TransactionId arg1 = PG_GETARG_TRANSACTIONID(0);
     StringInfoData buf;
 
     pq_begintypsend(&buf);
     pq_sendint32(&buf, arg1);
     PG_RETURN_BYTEA_P(pq_endtypsend(&buf));
 }

Macros

Functions