-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathpg_decode_infomask.c
127 lines (101 loc) · 5.07 KB
/
pg_decode_infomask.c
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
#include "postgres.h"
#include "catalog/pg_type.h"
#include "funcapi.h"
#include "miscadmin.h"
#include "access/htup_details.h"
#define PG_GET_XACT_INFOMASK_DETAILS_COLS 5
#define PG_GET_LOCK_INFOMASK_DETAILS_COLS 9
#define PG_GET_INFOMASK2_DETAILS_COLS 4
PG_MODULE_MAGIC;
Datum pg_get_xact_infomask_details(PG_FUNCTION_ARGS);
Datum pg_get_lock_infomask_details(PG_FUNCTION_ARGS);
Datum pg_get_infomask2_details(PG_FUNCTION_ARGS);
PG_FUNCTION_INFO_V1(pg_get_xact_infomask_details);
PG_FUNCTION_INFO_V1(pg_get_lock_infomask_details);
PG_FUNCTION_INFO_V1(pg_get_infomask2_details);
Datum
pg_get_xact_infomask_details(PG_FUNCTION_ARGS)
{
TupleDesc tupdesc;
Datum values[PG_GET_XACT_INFOMASK_DETAILS_COLS];
bool nulls[PG_GET_XACT_INFOMASK_DETAILS_COLS];
int i = 0;
int32 infomask = PG_GETARG_INT32(0);
if (get_call_result_type(fcinfo, NULL, &tupdesc) != TYPEFUNC_COMPOSITE)
elog(ERROR, "return type must be a row type");
tupdesc = CreateTemplateTupleDesc(PG_GET_XACT_INFOMASK_DETAILS_COLS, false);
TupleDescInitEntry(tupdesc, ++i, "xmin_committed", BOOLOID, -1, 0);
TupleDescInitEntry(tupdesc, ++i, "xmin_invalid", BOOLOID, -1, 0);
TupleDescInitEntry(tupdesc, ++i, "xmin_frozen", BOOLOID, -1, 0);
TupleDescInitEntry(tupdesc, ++i, "xmax_committed", BOOLOID, -1, 0);
TupleDescInitEntry(tupdesc, ++i, "xmax_invalid", BOOLOID, -1, 0);
BlessTupleDesc(tupdesc);
MemSet(nulls, 0, sizeof(nulls));
values[0] = BoolGetDatum((infomask & HEAP_XMIN_COMMITTED) != 0);
values[1] = BoolGetDatum(((infomask & (HEAP_XMIN_INVALID | HEAP_XMIN_COMMITTED)) == HEAP_XMIN_INVALID));
values[2] = BoolGetDatum((infomask & HEAP_XMIN_FROZEN) == HEAP_XMIN_FROZEN);
values[3] = BoolGetDatum((infomask & HEAP_XMAX_COMMITTED) != 0);
values[4] = BoolGetDatum((infomask & HEAP_XMAX_INVALID) != 0);
/* Returns the record as Datum */
PG_RETURN_DATUM(HeapTupleGetDatum(heap_form_tuple(tupdesc, values, nulls)));
}
Datum
pg_get_lock_infomask_details(PG_FUNCTION_ARGS)
{
TupleDesc tupdesc;
Datum values[PG_GET_LOCK_INFOMASK_DETAILS_COLS];
bool nulls[PG_GET_LOCK_INFOMASK_DETAILS_COLS];
int i = 0;
int32 infomask = PG_GETARG_INT32(0);
if (get_call_result_type(fcinfo, NULL, &tupdesc) != TYPEFUNC_COMPOSITE)
elog(ERROR, "return type must be a row type");
tupdesc = CreateTemplateTupleDesc(PG_GET_LOCK_INFOMASK_DETAILS_COLS, false);
TupleDescInitEntry(tupdesc, ++i, "is_locked_only", BOOLOID, -1, 0);
TupleDescInitEntry(tupdesc, ++i, "is_locked_upgraded", BOOLOID, -1, 0);
TupleDescInitEntry(tupdesc, ++i, "is_shr_locked", BOOLOID, -1, 0);
TupleDescInitEntry(tupdesc, ++i, "is_excl_locked", BOOLOID, -1, 0);
TupleDescInitEntry(tupdesc, ++i, "is_keyshr_locked", BOOLOID, -1, 0);
TupleDescInitEntry(tupdesc, ++i, "xmax_keyshr_lock", BOOLOID, -1, 0);
TupleDescInitEntry(tupdesc, ++i, "xmax_excl_lock", BOOLOID, -1, 0);
TupleDescInitEntry(tupdesc, ++i, "xmax_lock_only", BOOLOID, -1, 0);
TupleDescInitEntry(tupdesc, ++i, "xmax_is_multi", BOOLOID, -1, 0);
BlessTupleDesc(tupdesc);
MemSet(nulls, 0, sizeof(nulls));
i = 0;
values[i++] = BoolGetDatum(HEAP_XMAX_IS_LOCKED_ONLY(infomask));
values[i++] = BoolGetDatum(HEAP_LOCKED_UPGRADED(infomask));
values[i++] = BoolGetDatum(HEAP_XMAX_IS_SHR_LOCKED(infomask));
values[i++] = BoolGetDatum(HEAP_XMAX_IS_EXCL_LOCKED(infomask));
values[i++] = BoolGetDatum(HEAP_XMAX_IS_KEYSHR_LOCKED(infomask));
values[i++] = BoolGetDatum((infomask & HEAP_XMAX_KEYSHR_LOCK) != 0);
values[i++] = BoolGetDatum((infomask & HEAP_XMAX_EXCL_LOCK) != 0);
values[i++] = BoolGetDatum((infomask & HEAP_XMAX_LOCK_ONLY) != 0);
values[i++] = BoolGetDatum((infomask & HEAP_XMAX_IS_MULTI) != 0);
/* Returns the record as Datum */
PG_RETURN_DATUM(HeapTupleGetDatum(heap_form_tuple(tupdesc, values, nulls)));
}
Datum
pg_get_infomask2_details(PG_FUNCTION_ARGS)
{
TupleDesc tupdesc;
Datum values[PG_GET_INFOMASK2_DETAILS_COLS];
bool nulls[PG_GET_INFOMASK2_DETAILS_COLS];
int i = 0;
int32 infomask2 = PG_GETARG_INT32(0);
if (get_call_result_type(fcinfo, NULL, &tupdesc) != TYPEFUNC_COMPOSITE)
elog(ERROR, "return type must be a row type");
tupdesc = CreateTemplateTupleDesc(PG_GET_INFOMASK2_DETAILS_COLS, false);
TupleDescInitEntry(tupdesc, ++i, "natts", INT4OID, -1, 0);
TupleDescInitEntry(tupdesc, ++i, "keys_updated", BOOLOID, -1, 0);
TupleDescInitEntry(tupdesc, ++i, "hot_updated", BOOLOID, -1, 0);
TupleDescInitEntry(tupdesc, ++i, "heap_only_tuple", BOOLOID, -1, 0);
BlessTupleDesc(tupdesc);
MemSet(nulls, 0, sizeof(nulls));
i = 0;
values[i++] = Int32GetDatum((infomask2 & HEAP_NATTS_MASK));
values[i++] = BoolGetDatum((infomask2 & HEAP_KEYS_UPDATED) != 0);
values[i++] = BoolGetDatum((infomask2 & HEAP_HOT_UPDATED) != 0);
values[i++] = BoolGetDatum((infomask2 & HEAP_ONLY_TUPLE) != 0);
/* Returns the record as Datum */
PG_RETURN_DATUM(HeapTupleGetDatum(heap_form_tuple(tupdesc, values, nulls)));
}