PostgreSQL Source Code git master
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:", (int) 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:500
SHORTALIGN
#define SHORTALIGN(LEN)
Definition: c.h:778
uint16
uint16_t uint16
Definition: c.h:501
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
ItemPointerData
struct ItemPointerData ItemPointerData
buf
static char * buf
Definition: pg_test_fsync.c:72
appendStringInfo
void appendStringInfo(StringInfo str, const char *fmt,...)
Definition: stringinfo.c:145

References appendStringInfo(), buf, GIN_SEGMENT_ADDITEMS, GIN_SEGMENT_DELETE, GIN_SEGMENT_INSERT, GIN_SEGMENT_REPLACE, i, ginxlogRecompressDataLeaf::nactions, 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 if (XLogRecBlockImageApply(record, 0))
105 appendStringInfoString(buf, " (full page image)");
106 else
107 appendStringInfoString(buf, " (full page image, for WAL verification)");
108 }
109 else
110 {
111 char *payload = XLogRecGetBlockData(record, 0, NULL);
112
113 if (!(xlrec->flags & GIN_INSERT_ISDATA))
114 appendStringInfo(buf, " isdelete: %c",
115 (((ginxlogInsertEntry *) payload)->isDelete) ? 'T' : 'F');
116 else if (xlrec->flags & GIN_INSERT_ISLEAF)
117 desc_recompress_leaf(buf, (ginxlogRecompressDataLeaf *) payload);
118 else
119 {
120 ginxlogInsertDataInternal *insertData =
121 (ginxlogInsertDataInternal *) payload;
122
123 appendStringInfo(buf, " pitem: %u-%u/%u",
124 PostingItemGetBlockNumber(&insertData->newitem),
125 ItemPointerGetBlockNumber(&insertData->newitem.key),
126 ItemPointerGetOffsetNumber(&insertData->newitem.key));
127 }
128 }
129 }
130 break;
131 case XLOG_GIN_SPLIT:
132 {
133 ginxlogSplit *xlrec = (ginxlogSplit *) rec;
134
135 appendStringInfo(buf, "isrootsplit: %c",
136 (((ginxlogSplit *) rec)->flags & GIN_SPLIT_ROOT) ? 'T' : 'F');
137 appendStringInfo(buf, " isdata: %c isleaf: %c",
138 (xlrec->flags & GIN_INSERT_ISDATA) ? 'T' : 'F',
139 (xlrec->flags & GIN_INSERT_ISLEAF) ? 'T' : 'F');
140 }
141 break;
142 case XLOG_GIN_VACUUM_PAGE:
143 /* no further information */
144 break;
145 case XLOG_GIN_VACUUM_DATA_LEAF_PAGE:
146 {
147 if (XLogRecHasBlockImage(record, 0))
148 {
149 if (XLogRecBlockImageApply(record, 0))
150 appendStringInfoString(buf, " (full page image)");
151 else
152 appendStringInfoString(buf, " (full page image, for WAL verification)");
153 }
154 else
155 {
156 ginxlogVacuumDataLeafPage *xlrec =
157 (ginxlogVacuumDataLeafPage *) XLogRecGetBlockData(record, 0, NULL);
158
159 desc_recompress_leaf(buf, &xlrec->data);
160 }
161 }
162 break;
163 case XLOG_GIN_DELETE_PAGE:
164 /* no further information */
165 break;
166 case XLOG_GIN_UPDATE_META_PAGE:
167 /* no further information */
168 break;
169 case XLOG_GIN_INSERT_LISTPAGE:
170 /* no further information */
171 break;
172 case XLOG_GIN_DELETE_LISTPAGE:
173 appendStringInfo(buf, "ndeleted: %d",
174 ((ginxlogDeleteListPages *) rec)->ndeleted);
175 break;
176 }
177}
BlockNumber
uint32 BlockNumber
Definition: block.h:31
BlockIdData
struct BlockIdData BlockIdData
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:194
ItemPointerGetOffsetNumber
static OffsetNumber ItemPointerGetOffsetNumber(const ItemPointerData *pointer)
Definition: itemptr.h:124
ItemPointerGetBlockNumber
static BlockNumber ItemPointerGetBlockNumber(const ItemPointerData *pointer)
Definition: itemptr.h:103
appendStringInfoString
void appendStringInfoString(StringInfo str, const char *s)
Definition: stringinfo.c:230
PostingItem::key
ItemPointerData key
Definition: ginblock.h:186
ginxlogInsert::flags
uint16 flags
Definition: ginxlog.h:39
ginxlogSplit::flags
uint16 flags
Definition: ginxlog.h:118
ginxlogVacuumDataLeafPage::data
ginxlogRecompressDataLeaf data
Definition: ginxlog.h:145
XLogRecGetBlockData
char * XLogRecGetBlockData(XLogReaderState *record, uint8 block_id, Size *len)
Definition: xlogreader.c:2035
XLogRecGetInfo
#define XLogRecGetInfo(decoder)
Definition: xlogreader.h:410
XLogRecBlockImageApply
#define XLogRecBlockImageApply(decoder, block_id)
Definition: xlogreader.h:425
XLogRecGetData
#define XLogRecGetData(decoder)
Definition: xlogreader.h:415
XLogRecHasBlockImage
#define XLogRecHasBlockImage(decoder, block_id)
Definition: xlogreader.h:423

References appendStringInfo(), appendStringInfoString(), BlockIdGetBlockNumber(), buf, ginxlogVacuumDataLeafPage::data, desc_recompress_leaf(), ginxlogInsert::flags, ginxlogSplit::flags, GIN_INSERT_ISDATA, GIN_INSERT_ISLEAF, GIN_SPLIT_ROOT, ItemPointerGetBlockNumber(), ItemPointerGetOffsetNumber(), PostingItem::key, ginxlogInsertDataInternal::newitem, 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, XLogRecBlockImageApply, XLogRecGetBlockData(), XLogRecGetData, XLogRecGetInfo, and XLogRecHasBlockImage.

◆ gin_identify()

const char * gin_identify ( uint8  info)

Definition at line 180 of file gindesc.c.

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

References 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.