xid.c File Reference

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

Include dependency graph for xid.c:

Go to the source code of this file.

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	hashxid (PG_FUNCTION_ARGS)
Datum	hashxidextended (PG_FUNCTION_ARGS)
Datum	xid_age (PG_FUNCTION_ARGS)
Datum	mxid_age (PG_FUNCTION_ARGS)
int	xidComparator (const void *arg1, const void *arg2)
int	xidLogicalComparator (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	hashxid8 (PG_FUNCTION_ARGS)
Datum	hashxid8extended (PG_FUNCTION_ARGS)
Datum	xid8_larger (PG_FUNCTION_ARGS)
Datum	xid8_smaller (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)
Datum	hashcid (PG_FUNCTION_ARGS)
Datum	hashcidextended (PG_FUNCTION_ARGS)

Macro Definition Documentation

PG_GETARG_COMMANDID

#define PG_GETARG_COMMANDID

(

n

)

DatumGetCommandId(PG_GETARG_DATUM(n))

Definition at line 28 of file xid.c.

PG_RETURN_COMMANDID

#define PG_RETURN_COMMANDID

(

x

)

return CommandIdGetDatum(x)

Definition at line 29 of file xid.c.

Function Documentation

cideq()

Datum cideq

(

PG_FUNCTION_ARGS

)

Definition at line 395 of file xid.c.

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

References PG_GETARG_COMMANDID, and PG_RETURN_BOOL.

cidin()

Datum cidin

(

PG_FUNCTION_ARGS

)

Definition at line 347 of file xid.c.

{
    char       *str = PG_GETARG_CSTRING(0);
    CommandId   result;
 
    result = uint32in_subr(str, NULL, "cid", fcinfo->context);
    PG_RETURN_COMMANDID(result);
}

References PG_GETARG_CSTRING, PG_RETURN_COMMANDID, str, and uint32in_subr().

cidout()

Datum cidout

(

PG_FUNCTION_ARGS

)

Definition at line 360 of file xid.c.

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

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

cidrecv()

Datum cidrecv

(

PG_FUNCTION_ARGS

)

Definition at line 373 of file xid.c.

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

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

cidsend()

Datum cidsend

(

PG_FUNCTION_ARGS

)

Definition at line 384 of file xid.c.

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

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

hashcid()

Datum hashcid

(

PG_FUNCTION_ARGS

)

Definition at line 404 of file xid.c.

{
    return hash_uint32(PG_GETARG_COMMANDID(0));
}

References hash_uint32(), and PG_GETARG_COMMANDID.

hashcidextended()

Datum hashcidextended

(

PG_FUNCTION_ARGS

)

Definition at line 410 of file xid.c.

{
    return hash_uint32_extended(PG_GETARG_COMMANDID(0), PG_GETARG_INT64(1));
}

References hash_uint32_extended(), PG_GETARG_COMMANDID, and PG_GETARG_INT64.

hashxid()

Datum hashxid

(

PG_FUNCTION_ARGS

)

Definition at line 102 of file xid.c.

{
    return hash_uint32(PG_GETARG_TRANSACTIONID(0));
}

References hash_uint32(), and PG_GETARG_TRANSACTIONID.

hashxid8()

Datum hashxid8

(

PG_FUNCTION_ARGS

)

Definition at line 304 of file xid.c.

{
    return hashint8(fcinfo);
}

References hashint8().

hashxid8extended()

Datum hashxid8extended

(

PG_FUNCTION_ARGS

)

Definition at line 310 of file xid.c.

{
    return hashint8extended(fcinfo);
}

References hashint8extended().

hashxidextended()

Datum hashxidextended

(

PG_FUNCTION_ARGS

)

Definition at line 108 of file xid.c.

{
    return hash_uint32_extended(PG_GETARG_TRANSACTIONID(0), PG_GETARG_INT64(1));
}

References hash_uint32_extended(), PG_GETARG_INT64, and PG_GETARG_TRANSACTIONID.

mxid_age()

Datum mxid_age

(

PG_FUNCTION_ARGS

)

Definition at line 133 of file xid.c.

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

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

xid8_larger()

Datum xid8_larger

(

PG_FUNCTION_ARGS

)

Definition at line 316 of file xid.c.

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

References FullTransactionIdFollows, PG_GETARG_FULLTRANSACTIONID, and PG_RETURN_FULLTRANSACTIONID.

xid8_smaller()

Datum xid8_smaller

(

PG_FUNCTION_ARGS

)

Definition at line 328 of file xid.c.

{
    FullTransactionId fxid1 = PG_GETARG_FULLTRANSACTIONID(0);
    FullTransactionId fxid2 = PG_GETARG_FULLTRANSACTIONID(1);
 
    if (FullTransactionIdPrecedes(fxid1, fxid2))
        PG_RETURN_FULLTRANSACTIONID(fxid1);
    else
        PG_RETURN_FULLTRANSACTIONID(fxid2);
}

References FullTransactionIdPrecedes, PG_GETARG_FULLTRANSACTIONID, and PG_RETURN_FULLTRANSACTIONID.

xid8cmp()

Datum xid8cmp

(

PG_FUNCTION_ARGS

)

Definition at line 290 of file xid.c.

{
    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);
}

References FullTransactionIdEquals, FullTransactionIdFollows, PG_GETARG_FULLTRANSACTIONID, and PG_RETURN_INT32.

xid8eq()

Datum xid8eq

(

PG_FUNCTION_ARGS

)

Definition at line 236 of file xid.c.

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

References FullTransactionIdEquals, PG_GETARG_FULLTRANSACTIONID, and PG_RETURN_BOOL.

xid8ge()

Datum xid8ge

(

PG_FUNCTION_ARGS

)

Definition at line 281 of file xid.c.

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

References FullTransactionIdFollowsOrEquals, PG_GETARG_FULLTRANSACTIONID, and PG_RETURN_BOOL.

xid8gt()

Datum xid8gt

(

PG_FUNCTION_ARGS

)

Definition at line 263 of file xid.c.

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

References FullTransactionIdFollows, PG_GETARG_FULLTRANSACTIONID, and PG_RETURN_BOOL.

xid8in()

Datum xid8in

(

PG_FUNCTION_ARGS

)

Definition at line 195 of file xid.c.

{
    char       *str = PG_GETARG_CSTRING(0);
    uint64      result;
 
    result = uint64in_subr(str, NULL, "xid8", fcinfo->context);
    PG_RETURN_FULLTRANSACTIONID(FullTransactionIdFromU64(result));
}

References FullTransactionIdFromU64(), PG_GETARG_CSTRING, PG_RETURN_FULLTRANSACTIONID, str, and uint64in_subr().

xid8le()

Datum xid8le

(

PG_FUNCTION_ARGS

)

Definition at line 272 of file xid.c.

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

References FullTransactionIdPrecedesOrEquals, PG_GETARG_FULLTRANSACTIONID, and PG_RETURN_BOOL.

xid8lt()

Datum xid8lt

(

PG_FUNCTION_ARGS

)

Definition at line 254 of file xid.c.

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

References FullTransactionIdPrecedes, PG_GETARG_FULLTRANSACTIONID, and PG_RETURN_BOOL.

xid8ne()

Datum xid8ne

(

PG_FUNCTION_ARGS

)

Definition at line 245 of file xid.c.

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

References FullTransactionIdEquals, PG_GETARG_FULLTRANSACTIONID, and PG_RETURN_BOOL.

xid8out()

Datum xid8out

(

PG_FUNCTION_ARGS

)

Definition at line 205 of file xid.c.

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

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

xid8recv()

Datum xid8recv

(

PG_FUNCTION_ARGS

)

Definition at line 215 of file xid.c.

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

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

xid8send()

Datum xid8send

(

PG_FUNCTION_ARGS

)

Definition at line 225 of file xid.c.

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

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

xid8toxid()

Datum xid8toxid

(

PG_FUNCTION_ARGS

)

Definition at line 187 of file xid.c.

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

References PG_GETARG_FULLTRANSACTIONID, PG_RETURN_TRANSACTIONID, and XidFromFullTransactionId.

xid_age()

Datum xid_age

(

PG_FUNCTION_ARGS

)

Definition at line 117 of file xid.c.

{
    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));
}

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

xidComparator()

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

Definition at line 152 of file xid.c.

{
    TransactionId xid1 = *(const TransactionId *) arg1;
    TransactionId xid2 = *(const TransactionId *) arg2;
 
    return pg_cmp_u32(xid1, xid2);
}

References pg_cmp_u32().

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

xideq()

Datum xideq

(

PG_FUNCTION_ARGS

)

Definition at line 81 of file xid.c.

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

References PG_GETARG_TRANSACTIONID, PG_RETURN_BOOL, and TransactionIdEquals.

xidin()

Datum xidin

(

PG_FUNCTION_ARGS

)

Definition at line 33 of file xid.c.

{
    char       *str = PG_GETARG_CSTRING(0);
    TransactionId result;
 
    result = uint32in_subr(str, NULL, "xid", fcinfo->context);
    PG_RETURN_TRANSACTIONID(result);
}

References PG_GETARG_CSTRING, PG_RETURN_TRANSACTIONID, str, and uint32in_subr().

xidLogicalComparator()

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

Definition at line 169 of file xid.c.

{
    TransactionId xid1 = *(const TransactionId *) arg1;
    TransactionId xid2 = *(const TransactionId *) arg2;
 
    Assert(TransactionIdIsNormal(xid1));
    Assert(TransactionIdIsNormal(xid2));
 
    if (TransactionIdPrecedes(xid1, xid2))
        return -1;
 
    if (TransactionIdPrecedes(xid2, xid1))
        return 1;
 
    return 0;
}

References Assert, TransactionIdIsNormal, and TransactionIdPrecedes().

Referenced by ProcArrayApplyRecoveryInfo().

xidneq()

Datum xidneq

(

PG_FUNCTION_ARGS

)

Definition at line 93 of file xid.c.

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

References PG_GETARG_TRANSACTIONID, PG_RETURN_BOOL, and TransactionIdEquals.

xidout()

Datum xidout

(

PG_FUNCTION_ARGS

)

Definition at line 43 of file xid.c.

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

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

xidrecv()

Datum xidrecv

(

PG_FUNCTION_ARGS

)

Definition at line 56 of file xid.c.

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

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

xidsend()

Datum xidsend

(

PG_FUNCTION_ARGS

)

Definition at line 67 of file xid.c.

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

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