PostgreSQL Source Code  git master
Macros | Functions
xid.c File Reference
#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 dependency graph for xid.c:

Go to the source code of this file.

Macros

#define PG_GETARG_TRANSACTIONID(n)   DatumGetTransactionId(PG_GETARG_DATUM(n))
 
#define PG_RETURN_TRANSACTIONID(x)   return TransactionIdGetDatum(x)
 
#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 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 28 of file xid.c.

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

◆ PG_GETARG_TRANSACTIONID

#define PG_GETARG_TRANSACTIONID (   n)    DatumGetTransactionId(PG_GETARG_DATUM(n))

Definition at line 25 of file xid.c.

Referenced by mxid_age(), xid_age(), xideq(), xidneq(), xidout(), and xidsend().

◆ PG_RETURN_COMMANDID

#define PG_RETURN_COMMANDID (   x)    return CommandIdGetDatum(x)

Definition at line 29 of file xid.c.

Referenced by cidin(), and cidrecv().

◆ PG_RETURN_TRANSACTIONID

#define PG_RETURN_TRANSACTIONID (   x)    return TransactionIdGetDatum(x)

Definition at line 26 of file xid.c.

Referenced by xidin(), and xidrecv().

Function Documentation

◆ cideq()

Datum cideq ( PG_FUNCTION_ARGS  )

Definition at line 204 of file xid.c.

References PG_GETARG_COMMANDID, and PG_RETURN_BOOL.

205 {
206  CommandId arg1 = PG_GETARG_COMMANDID(0);
207  CommandId arg2 = PG_GETARG_COMMANDID(1);
208 
209  PG_RETURN_BOOL(arg1 == arg2);
210 }
CommandId
uint32 CommandId
Definition: c.h:488
PG_GETARG_COMMANDID
#define PG_GETARG_COMMANDID(n)
Definition: xid.c:28
PG_RETURN_BOOL
#define PG_RETURN_BOOL(x)
Definition: fmgr.h:324

◆ cidin()

Datum cidin ( PG_FUNCTION_ARGS  )

Definition at line 158 of file xid.c.

References PG_GETARG_CSTRING, PG_RETURN_COMMANDID, and generate_unaccent_rules::str.

159 {
160  char *str = PG_GETARG_CSTRING(0);
161 
162  PG_RETURN_COMMANDID((CommandId) strtoul(str, NULL, 0));
163 }
CommandId
uint32 CommandId
Definition: c.h:488
PG_RETURN_COMMANDID
#define PG_RETURN_COMMANDID(x)
Definition: xid.c:29
generate_unaccent_rules.str
str
Definition: generate_unaccent_rules.py:207
PG_GETARG_CSTRING
#define PG_GETARG_CSTRING(n)
Definition: fmgr.h:247

◆ cidout()

Datum cidout ( PG_FUNCTION_ARGS  )

Definition at line 169 of file xid.c.

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

170 {
171  CommandId c = PG_GETARG_COMMANDID(0);
172  char *result = (char *) palloc(16);
173 
174  snprintf(result, 16, "%lu", (unsigned long) c);
175  PG_RETURN_CSTRING(result);
176 }
CommandId
uint32 CommandId
Definition: c.h:488
PG_GETARG_COMMANDID
#define PG_GETARG_COMMANDID(n)
Definition: xid.c:28
snprintf
int snprintf(char *str, size_t count, const char *fmt,...) pg_attribute_printf(3
c
char * c
Definition: preproc-cursor.c:31
PG_RETURN_CSTRING
#define PG_RETURN_CSTRING(x)
Definition: fmgr.h:327
palloc
void * palloc(Size size)
Definition: mcxt.c:924

◆ cidrecv()

Datum cidrecv ( PG_FUNCTION_ARGS  )

Definition at line 182 of file xid.c.

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

183 {
184  StringInfo buf = (StringInfo) PG_GETARG_POINTER(0);
185 
186  PG_RETURN_COMMANDID((CommandId) pq_getmsgint(buf, sizeof(CommandId)));
187 }
CommandId
uint32 CommandId
Definition: c.h:488
StringInfo
StringInfoData * StringInfo
Definition: stringinfo.h:43
PG_GETARG_POINTER
#define PG_GETARG_POINTER(n)
Definition: fmgr.h:246
PG_RETURN_COMMANDID
#define PG_RETURN_COMMANDID(x)
Definition: xid.c:29
buf
static char * buf
Definition: pg_test_fsync.c:67
pq_getmsgint
unsigned int pq_getmsgint(StringInfo msg, int b)
Definition: pqformat.c:417

◆ cidsend()

Datum cidsend ( PG_FUNCTION_ARGS  )

Definition at line 193 of file xid.c.

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

194 {
195  CommandId arg1 = PG_GETARG_COMMANDID(0);
196  StringInfoData buf;
197 
198  pq_begintypsend(&buf);
199  pq_sendint32(&buf, arg1);
200  PG_RETURN_BYTEA_P(pq_endtypsend(&buf));
201 }
CommandId
uint32 CommandId
Definition: c.h:488
pq_sendint32
static void pq_sendint32(StringInfo buf, int32 i)
Definition: pqformat.h:148
pq_begintypsend
void pq_begintypsend(StringInfo buf)
Definition: pqformat.c:328
PG_GETARG_COMMANDID
#define PG_GETARG_COMMANDID(n)
Definition: xid.c:28
PG_RETURN_BYTEA_P
#define PG_RETURN_BYTEA_P(x)
Definition: fmgr.h:335
pq_endtypsend
bytea * pq_endtypsend(StringInfo buf)
Definition: pqformat.c:348
buf
static char * buf
Definition: pg_test_fsync.c:67

◆ mxid_age()

Datum mxid_age ( PG_FUNCTION_ARGS  )

Definition at line 119 of file xid.c.

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

120 {
121  TransactionId xid = PG_GETARG_TRANSACTIONID(0);
122  MultiXactId now = ReadNextMultiXactId();
123 
124  if (!MultiXactIdIsValid(xid))
125  PG_RETURN_INT32(INT_MAX);
126 
127  PG_RETURN_INT32((int32) (now - xid));
128 }
TransactionId
uint32 TransactionId
Definition: c.h:474
PG_RETURN_INT32
#define PG_RETURN_INT32(x)
Definition: fmgr.h:319
int32
signed int int32
Definition: c.h:313
MultiXactIdIsValid
#define MultiXactIdIsValid(multi)
Definition: multixact.h:27
MultiXactId
TransactionId MultiXactId
Definition: c.h:484
PG_GETARG_TRANSACTIONID
#define PG_GETARG_TRANSACTIONID(n)
Definition: xid.c:25
now
Datum now(PG_FUNCTION_ARGS)
Definition: timestamp.c:1534
ReadNextMultiXactId
MultiXactId ReadNextMultiXactId(void)
Definition: multixact.c:721

◆ xid_age()

Datum xid_age ( PG_FUNCTION_ARGS  )

Definition at line 103 of file xid.c.

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

104 {
105  TransactionId xid = PG_GETARG_TRANSACTIONID(0);
106  TransactionId now = GetStableLatestTransactionId();
107 
108  /* Permanent XIDs are always infinitely old */
109  if (!TransactionIdIsNormal(xid))
110  PG_RETURN_INT32(INT_MAX);
111 
112  PG_RETURN_INT32((int32) (now - xid));
113 }
TransactionId
uint32 TransactionId
Definition: c.h:474
PG_RETURN_INT32
#define PG_RETURN_INT32(x)
Definition: fmgr.h:319
int32
signed int int32
Definition: c.h:313
GetStableLatestTransactionId
TransactionId GetStableLatestTransactionId(void)
Definition: xact.c:461
PG_GETARG_TRANSACTIONID
#define PG_GETARG_TRANSACTIONID(n)
Definition: xid.c:25
TransactionIdIsNormal
#define TransactionIdIsNormal(xid)
Definition: transam.h:42
now
Datum now(PG_FUNCTION_ARGS)
Definition: timestamp.c:1534

◆ xidComparator()

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

Definition at line 138 of file xid.c.

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

139 {
140  TransactionId xid1 = *(const TransactionId *) arg1;
141  TransactionId xid2 = *(const TransactionId *) arg2;
142 
143  if (xid1 > xid2)
144  return 1;
145  if (xid1 < xid2)
146  return -1;
147  return 0;
148 }
TransactionId
uint32 TransactionId
Definition: c.h:474

◆ xideq()

Datum xideq ( PG_FUNCTION_ARGS  )

Definition at line 79 of file xid.c.

References PG_GETARG_TRANSACTIONID, PG_RETURN_BOOL, and TransactionIdEquals.

80 {
81  TransactionId xid1 = PG_GETARG_TRANSACTIONID(0);
82  TransactionId xid2 = PG_GETARG_TRANSACTIONID(1);
83 
84  PG_RETURN_BOOL(TransactionIdEquals(xid1, xid2));
85 }
TransactionIdEquals
#define TransactionIdEquals(id1, id2)
Definition: transam.h:43
TransactionId
uint32 TransactionId
Definition: c.h:474
PG_RETURN_BOOL
#define PG_RETURN_BOOL(x)
Definition: fmgr.h:324
PG_GETARG_TRANSACTIONID
#define PG_GETARG_TRANSACTIONID(n)
Definition: xid.c:25

◆ xidin()

Datum xidin ( PG_FUNCTION_ARGS  )

Definition at line 33 of file xid.c.

References PG_GETARG_CSTRING, PG_RETURN_TRANSACTIONID, and generate_unaccent_rules::str.

34 {
35  char *str = PG_GETARG_CSTRING(0);
36 
37  PG_RETURN_TRANSACTIONID((TransactionId) strtoul(str, NULL, 0));
38 }
TransactionId
uint32 TransactionId
Definition: c.h:474
generate_unaccent_rules.str
str
Definition: generate_unaccent_rules.py:207
PG_GETARG_CSTRING
#define PG_GETARG_CSTRING(n)
Definition: fmgr.h:247
PG_RETURN_TRANSACTIONID
#define PG_RETURN_TRANSACTIONID(x)
Definition: xid.c:26

◆ xidneq()

Datum xidneq ( PG_FUNCTION_ARGS  )

Definition at line 91 of file xid.c.

References PG_GETARG_TRANSACTIONID, PG_RETURN_BOOL, and TransactionIdEquals.

92 {
93  TransactionId xid1 = PG_GETARG_TRANSACTIONID(0);
94  TransactionId xid2 = PG_GETARG_TRANSACTIONID(1);
95 
96  PG_RETURN_BOOL(!TransactionIdEquals(xid1, xid2));
97 }
TransactionIdEquals
#define TransactionIdEquals(id1, id2)
Definition: transam.h:43
TransactionId
uint32 TransactionId
Definition: c.h:474
PG_RETURN_BOOL
#define PG_RETURN_BOOL(x)
Definition: fmgr.h:324
PG_GETARG_TRANSACTIONID
#define PG_GETARG_TRANSACTIONID(n)
Definition: xid.c:25

◆ xidout()

Datum xidout ( PG_FUNCTION_ARGS  )

Definition at line 41 of file xid.c.

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

42 {
43  TransactionId transactionId = PG_GETARG_TRANSACTIONID(0);
44  char *result = (char *) palloc(16);
45 
46  snprintf(result, 16, "%lu", (unsigned long) transactionId);
47  PG_RETURN_CSTRING(result);
48 }
TransactionId
uint32 TransactionId
Definition: c.h:474
snprintf
int snprintf(char *str, size_t count, const char *fmt,...) pg_attribute_printf(3
PG_RETURN_CSTRING
#define PG_RETURN_CSTRING(x)
Definition: fmgr.h:327
palloc
void * palloc(Size size)
Definition: mcxt.c:924
PG_GETARG_TRANSACTIONID
#define PG_GETARG_TRANSACTIONID(n)
Definition: xid.c:25

◆ xidrecv()

Datum xidrecv ( PG_FUNCTION_ARGS  )

Definition at line 54 of file xid.c.

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

55 {
56  StringInfo buf = (StringInfo) PG_GETARG_POINTER(0);
57 
58  PG_RETURN_TRANSACTIONID((TransactionId) pq_getmsgint(buf, sizeof(TransactionId)));
59 }
TransactionId
uint32 TransactionId
Definition: c.h:474
StringInfo
StringInfoData * StringInfo
Definition: stringinfo.h:43
PG_GETARG_POINTER
#define PG_GETARG_POINTER(n)
Definition: fmgr.h:246
buf
static char * buf
Definition: pg_test_fsync.c:67
pq_getmsgint
unsigned int pq_getmsgint(StringInfo msg, int b)
Definition: pqformat.c:417
PG_RETURN_TRANSACTIONID
#define PG_RETURN_TRANSACTIONID(x)
Definition: xid.c:26

◆ xidsend()

Datum xidsend ( PG_FUNCTION_ARGS  )

Definition at line 65 of file xid.c.

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

66 {
67  TransactionId arg1 = PG_GETARG_TRANSACTIONID(0);
68  StringInfoData buf;
69 
70  pq_begintypsend(&buf);
71  pq_sendint32(&buf, arg1);
72  PG_RETURN_BYTEA_P(pq_endtypsend(&buf));
73 }
TransactionId
uint32 TransactionId
Definition: c.h:474
pq_sendint32
static void pq_sendint32(StringInfo buf, int32 i)
Definition: pqformat.h:148
pq_begintypsend
void pq_begintypsend(StringInfo buf)
Definition: pqformat.c:328
PG_RETURN_BYTEA_P
#define PG_RETURN_BYTEA_P(x)
Definition: fmgr.h:335
pq_endtypsend
bytea * pq_endtypsend(StringInfo buf)
Definition: pqformat.c:348
buf
static char * buf
Definition: pg_test_fsync.c:67
PG_GETARG_TRANSACTIONID
#define PG_GETARG_TRANSACTIONID(n)
Definition: xid.c:25