PostgreSQL Source Code git master
Loading...
Searching...
No Matches
Functions
gindesc.c File Reference
#include "postgres.h"
#include "access/ginxlog.h"
#include "lib/stringinfo.h"
Include dependency graph for gindesc.c:

Go to the source code of this file.

Functions

static void desc_recompress_leaf (StringInfo buf, ginxlogRecompressDataLeaf *insertData)
 
void gin_desc (StringInfo buf, XLogReaderState *record)
 
const char * gin_identify (uint8 info)
 

Function Documentation

◆ desc_recompress_leaf()

static void desc_recompress_leaf ( StringInfo  buf,
ginxlogRecompressDataLeaf *  insertData 
)
static

Definition at line 21 of file gindesc.c.

22{
23 int i;
24 char *walbuf = ((char *) insertData) + sizeof(ginxlogRecompressDataLeaf);
25
26 appendStringInfo(buf, " %d segments:", insertData->nactions);
27
28 for (i = 0; i < insertData->nactions; i++)
29 {
30 uint8 a_segno = *((uint8 *) (walbuf++));
31 uint8 a_action = *((uint8 *) (walbuf++));
32 uint16 nitems = 0;
33 int newsegsize = 0;
34
35 if (a_action == GIN_SEGMENT_INSERT ||
36 a_action == GIN_SEGMENT_REPLACE)
37 {
38 newsegsize = SizeOfGinPostingList((GinPostingList *) walbuf);
39 walbuf += SHORTALIGN(newsegsize);
40 }
41
42 if (a_action == GIN_SEGMENT_ADDITEMS)
43 {
44 memcpy(&nitems, walbuf, sizeof(uint16));
45 walbuf += sizeof(uint16);
46 walbuf += nitems * sizeof(ItemPointerData);
47 }
48
49 switch (a_action)
50 {
51 case GIN_SEGMENT_ADDITEMS:
52 appendStringInfo(buf, " %d (add %d items)", a_segno, nitems);
53 break;
54 case GIN_SEGMENT_DELETE:
55 appendStringInfo(buf, " %d (delete)", a_segno);
56 break;
57 case GIN_SEGMENT_INSERT:
58 appendStringInfo(buf, " %d (insert)", a_segno);
59 break;
60 case GIN_SEGMENT_REPLACE:
61 appendStringInfo(buf, " %d (replace)", a_segno);
62 break;
63 default:
64 appendStringInfo(buf, " %d unknown action %d ???", a_segno, a_action);
65 /* cannot decode unrecognized actions further */
66 return;
67 }
68 }
69}
uint8
uint8_t uint8
Definition c.h:544
SHORTALIGN
#define SHORTALIGN(LEN)
Definition c.h:822
uint16
uint16_t uint16
Definition c.h:545
SizeOfGinPostingList
#define SizeOfGinPostingList(plist)
Definition ginblock.h:342
GIN_SEGMENT_ADDITEMS
#define GIN_SEGMENT_ADDITEMS
Definition ginxlog.h:95
GIN_SEGMENT_DELETE
#define GIN_SEGMENT_DELETE
Definition ginxlog.h:92
GIN_SEGMENT_INSERT
#define GIN_SEGMENT_INSERT
Definition ginxlog.h:93
GIN_SEGMENT_REPLACE
#define GIN_SEGMENT_REPLACE
Definition ginxlog.h:94
nitems
#define nitems(x)
Definition indent.h:31
i
int i
Definition isn.c:77
buf
static char buf[DEFAULT_XLOG_SEG_SIZE]
Definition pg_test_fsync.c:71
fb
static int fb(int x)
Definition preproc-init.c:92
appendStringInfo
void appendStringInfo(StringInfo str, const char *fmt,...)
Definition stringinfo.c:145

References appendStringInfo(), buf, fb(), GIN_SEGMENT_ADDITEMS, GIN_SEGMENT_DELETE, GIN_SEGMENT_INSERT, GIN_SEGMENT_REPLACE, i, nitems, SHORTALIGN, and SizeOfGinPostingList.

Referenced by gin_desc().

◆ gin_desc()

void gin_desc ( StringInfo  buf,
XLogReaderState *  record 
)

Definition at line 72 of file gindesc.c.

73{
74 char *rec = XLogRecGetData(record);
75 uint8 info = XLogRecGetInfo(record) & ~XLR_INFO_MASK;
76
77 switch (info)
78 {
79 case XLOG_GIN_CREATE_PTREE:
80 /* no further information */
81 break;
82 case XLOG_GIN_INSERT:
83 {
84 ginxlogInsert *xlrec = (ginxlogInsert *) rec;
85
86 appendStringInfo(buf, "isdata: %c isleaf: %c",
87 (xlrec->flags & GIN_INSERT_ISDATA) ? 'T' : 'F',
88 (xlrec->flags & GIN_INSERT_ISLEAF) ? 'T' : 'F');
89 if (!(xlrec->flags & GIN_INSERT_ISLEAF))
90 {
91 char *payload = rec + sizeof(ginxlogInsert);
92 BlockNumber leftChildBlkno;
93 BlockNumber rightChildBlkno;
94
95 leftChildBlkno = BlockIdGetBlockNumber((BlockId) payload);
96 payload += sizeof(BlockIdData);
97 rightChildBlkno = BlockIdGetBlockNumber((BlockId) payload);
98 payload += sizeof(BlockNumber);
99 appendStringInfo(buf, " children: %u/%u",
100 leftChildBlkno, rightChildBlkno);
101 }
102 if (!XLogRecHasBlockImage(record, 0))
103 {
104 char *payload = XLogRecGetBlockData(record, 0, NULL);
105
106 if (!(xlrec->flags & GIN_INSERT_ISDATA))
107 appendStringInfo(buf, " isdelete: %c",
108 (((ginxlogInsertEntry *) payload)->isDelete) ? 'T' : 'F');
109 else if (xlrec->flags & GIN_INSERT_ISLEAF)
110 desc_recompress_leaf(buf, (ginxlogRecompressDataLeaf *) payload);
111 else
112 {
113 ginxlogInsertDataInternal *insertData =
114 (ginxlogInsertDataInternal *) payload;
115
116 appendStringInfo(buf, " pitem: %u-%u/%u",
117 PostingItemGetBlockNumber(&insertData->newitem),
118 ItemPointerGetBlockNumber(&insertData->newitem.key),
119 ItemPointerGetOffsetNumber(&insertData->newitem.key));
120 }
121 }
122 }
123 break;
124 case XLOG_GIN_SPLIT:
125 {
126 ginxlogSplit *xlrec = (ginxlogSplit *) rec;
127
128 appendStringInfo(buf, "isrootsplit: %c",
129 (((ginxlogSplit *) rec)->flags & GIN_SPLIT_ROOT) ? 'T' : 'F');
130 appendStringInfo(buf, " isdata: %c isleaf: %c",
131 (xlrec->flags & GIN_INSERT_ISDATA) ? 'T' : 'F',
132 (xlrec->flags & GIN_INSERT_ISLEAF) ? 'T' : 'F');
133 if (xlrec->leftChildBlkno != InvalidBlockNumber)
134 appendStringInfo(buf, " children: %u/%u",
135 xlrec->leftChildBlkno, xlrec->rightChildBlkno);
136 }
137 break;
138 case XLOG_GIN_VACUUM_PAGE:
139 /* no further information */
140 break;
141 case XLOG_GIN_VACUUM_DATA_LEAF_PAGE:
142 {
143 if (!XLogRecHasBlockImage(record, 0))
144 {
145 ginxlogVacuumDataLeafPage *xlrec =
146 (ginxlogVacuumDataLeafPage *) XLogRecGetBlockData(record, 0, NULL);
147
148 desc_recompress_leaf(buf, &xlrec->data);
149 }
150 }
151 break;
152 case XLOG_GIN_DELETE_PAGE:
153 /* no further information */
154 break;
155 case XLOG_GIN_UPDATE_META_PAGE:
156 {
157 ginxlogUpdateMeta *xlrec = (ginxlogUpdateMeta *) rec;
158
159 appendStringInfo(buf, "ntuples: %d", xlrec->ntuples);
160 if (xlrec->prevTail != InvalidBlockNumber)
161 appendStringInfo(buf, " prevTail: %u",
162 xlrec->prevTail);
163 if (xlrec->newRightlink != InvalidBlockNumber)
164 appendStringInfo(buf, " newRightlink: %u",
165 xlrec->newRightlink);
166 }
167 break;
168 case XLOG_GIN_INSERT_LISTPAGE:
169 {
170 ginxlogInsertListPage *xlrec = (ginxlogInsertListPage *) rec;
171
172 appendStringInfo(buf, "ntuples: %d", xlrec->ntuples);
173 if (xlrec->rightlink != InvalidBlockNumber)
174 appendStringInfo(buf, " rightlink: %u",
175 xlrec->rightlink);
176 }
177 break;
178 case XLOG_GIN_DELETE_LISTPAGE:
179 appendStringInfo(buf, "ndeleted: %d",
180 ((ginxlogDeleteListPages *) rec)->ndeleted);
181 break;
182 }
183}
BlockNumber
uint32 BlockNumber
Definition block.h:31
InvalidBlockNumber
#define InvalidBlockNumber
Definition block.h:33
BlockIdGetBlockNumber
static BlockNumber BlockIdGetBlockNumber(const BlockIdData *blockId)
Definition block.h:103
PostingItemGetBlockNumber
#define PostingItemGetBlockNumber(pointer)
Definition ginblock.h:189
desc_recompress_leaf
static void desc_recompress_leaf(StringInfo buf, ginxlogRecompressDataLeaf *insertData)
Definition gindesc.c:21
GIN_INSERT_ISDATA
#define GIN_INSERT_ISDATA
Definition ginxlog.h:124
GIN_INSERT_ISLEAF
#define GIN_INSERT_ISLEAF
Definition ginxlog.h:125
XLOG_GIN_UPDATE_META_PAGE
#define XLOG_GIN_UPDATE_META_PAGE
Definition ginxlog.h:162
GIN_SPLIT_ROOT
#define GIN_SPLIT_ROOT
Definition ginxlog.h:126
XLOG_GIN_INSERT
#define XLOG_GIN_INSERT
Definition ginxlog.h:35
XLOG_GIN_CREATE_PTREE
#define XLOG_GIN_CREATE_PTREE
Definition ginxlog.h:19
XLOG_GIN_VACUUM_PAGE
#define XLOG_GIN_VACUUM_PAGE
Definition ginxlog.h:135
XLOG_GIN_DELETE_PAGE
#define XLOG_GIN_DELETE_PAGE
Definition ginxlog.h:153
XLOG_GIN_INSERT_LISTPAGE
#define XLOG_GIN_INSERT_LISTPAGE
Definition ginxlog.h:180
XLOG_GIN_VACUUM_DATA_LEAF_PAGE
#define XLOG_GIN_VACUUM_DATA_LEAF_PAGE
Definition ginxlog.h:141
XLOG_GIN_SPLIT
#define XLOG_GIN_SPLIT
Definition ginxlog.h:109
XLOG_GIN_DELETE_LISTPAGE
#define XLOG_GIN_DELETE_LISTPAGE
Definition ginxlog.h:197
ItemPointerGetOffsetNumber
static OffsetNumber ItemPointerGetOffsetNumber(const ItemPointerData *pointer)
Definition itemptr.h:124
ItemPointerGetBlockNumber
static BlockNumber ItemPointerGetBlockNumber(const ItemPointerData *pointer)
Definition itemptr.h:103
XLogRecGetBlockData
char * XLogRecGetBlockData(XLogReaderState *record, uint8 block_id, Size *len)
Definition xlogreader.c:2045
XLogRecGetInfo
#define XLogRecGetInfo(decoder)
Definition xlogreader.h:409
XLogRecGetData
#define XLogRecGetData(decoder)
Definition xlogreader.h:414
XLogRecHasBlockImage
#define XLogRecHasBlockImage(decoder, block_id)
Definition xlogreader.h:422

References appendStringInfo(), BlockIdGetBlockNumber(), buf, desc_recompress_leaf(), fb(), GIN_INSERT_ISDATA, GIN_INSERT_ISLEAF, GIN_SPLIT_ROOT, InvalidBlockNumber, ItemPointerGetBlockNumber(), ItemPointerGetOffsetNumber(), PostingItemGetBlockNumber, XLOG_GIN_CREATE_PTREE, XLOG_GIN_DELETE_LISTPAGE, XLOG_GIN_DELETE_PAGE, XLOG_GIN_INSERT, XLOG_GIN_INSERT_LISTPAGE, XLOG_GIN_SPLIT, XLOG_GIN_UPDATE_META_PAGE, XLOG_GIN_VACUUM_DATA_LEAF_PAGE, XLOG_GIN_VACUUM_PAGE, XLogRecGetBlockData(), XLogRecGetData, XLogRecGetInfo, and XLogRecHasBlockImage.

◆ gin_identify()

const char * gin_identify ( uint8  info)

Definition at line 186 of file gindesc.c.

187{
188 const char *id = NULL;
189
190 switch (info & ~XLR_INFO_MASK)
191 {
192 case XLOG_GIN_CREATE_PTREE:
193 id = "CREATE_PTREE";
194 break;
195 case XLOG_GIN_INSERT:
196 id = "INSERT";
197 break;
198 case XLOG_GIN_SPLIT:
199 id = "SPLIT";
200 break;
201 case XLOG_GIN_VACUUM_PAGE:
202 id = "VACUUM_PAGE";
203 break;
204 case XLOG_GIN_VACUUM_DATA_LEAF_PAGE:
205 id = "VACUUM_DATA_LEAF_PAGE";
206 break;
207 case XLOG_GIN_DELETE_PAGE:
208 id = "DELETE_PAGE";
209 break;
210 case XLOG_GIN_UPDATE_META_PAGE:
211 id = "UPDATE_META_PAGE";
212 break;
213 case XLOG_GIN_INSERT_LISTPAGE:
214 id = "INSERT_LISTPAGE";
215 break;
216 case XLOG_GIN_DELETE_LISTPAGE:
217 id = "DELETE_LISTPAGE";
218 break;
219 }
220
221 return id;
222}
XLR_INFO_MASK
#define XLR_INFO_MASK
Definition xlogrecord.h:62

References fb(), XLOG_GIN_CREATE_PTREE, XLOG_GIN_DELETE_LISTPAGE, XLOG_GIN_DELETE_PAGE, XLOG_GIN_INSERT, XLOG_GIN_INSERT_LISTPAGE, XLOG_GIN_SPLIT, XLOG_GIN_UPDATE_META_PAGE, XLOG_GIN_VACUUM_DATA_LEAF_PAGE, XLOG_GIN_VACUUM_PAGE, and XLR_INFO_MASK.