PostgreSQL Source Code  git master
Functions
gindesc.c File Reference
#include "postgres.h"
#include "access/ginxlog.h"
#include "access/xlogutils.h"
#include "lib/stringinfo.h"
#include "storage/relfilelocator.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 23 of file gindesc.c.

24 {
25  int i;
26  char *walbuf = ((char *) insertData) + sizeof(ginxlogRecompressDataLeaf);
27 
28  appendStringInfo(buf, " %d segments:", (int) insertData->nactions);
29 
30  for (i = 0; i < insertData->nactions; i++)
31  {
32  uint8 a_segno = *((uint8 *) (walbuf++));
33  uint8 a_action = *((uint8 *) (walbuf++));
34  uint16 nitems = 0;
35  int newsegsize = 0;
36 
37  if (a_action == GIN_SEGMENT_INSERT ||
38  a_action == GIN_SEGMENT_REPLACE)
39  {
40  newsegsize = SizeOfGinPostingList((GinPostingList *) walbuf);
41  walbuf += SHORTALIGN(newsegsize);
42  }
43 
44  if (a_action == GIN_SEGMENT_ADDITEMS)
45  {
46  memcpy(&nitems, walbuf, sizeof(uint16));
47  walbuf += sizeof(uint16);
48  walbuf += nitems * sizeof(ItemPointerData);
49  }
50 
51  switch (a_action)
52  {
53  case GIN_SEGMENT_ADDITEMS:
54  appendStringInfo(buf, " %d (add %d items)", a_segno, nitems);
55  break;
56  case GIN_SEGMENT_DELETE:
57  appendStringInfo(buf, " %d (delete)", a_segno);
58  break;
59  case GIN_SEGMENT_INSERT:
60  appendStringInfo(buf, " %d (insert)", a_segno);
61  break;
62  case GIN_SEGMENT_REPLACE:
63  appendStringInfo(buf, " %d (replace)", a_segno);
64  break;
65  default:
66  appendStringInfo(buf, " %d unknown action %d ???", a_segno, a_action);
67  /* cannot decode unrecognized actions further */
68  return;
69  }
70  }
71 }
uint16
unsigned short uint16
Definition: c.h:494
SHORTALIGN
#define SHORTALIGN(LEN)
Definition: c.h:796
uint8
unsigned char uint8
Definition: c.h:493
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:73
ItemPointerData
struct ItemPointerData ItemPointerData
buf
static char * buf
Definition: pg_test_fsync.c:67
appendStringInfo
void appendStringInfo(StringInfo str, const char *fmt,...)
Definition: stringinfo.c:91

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 74 of file gindesc.c.

75 {
76  char *rec = XLogRecGetData(record);
77  uint8 info = XLogRecGetInfo(record) & ~XLR_INFO_MASK;
78 
79  switch (info)
80  {
81  case XLOG_GIN_CREATE_PTREE:
82  /* no further information */
83  break;
84  case XLOG_GIN_INSERT:
85  {
86  ginxlogInsert *xlrec = (ginxlogInsert *) rec;
87 
88  appendStringInfo(buf, "isdata: %c isleaf: %c",
89  (xlrec->flags & GIN_INSERT_ISDATA) ? 'T' : 'F',
90  (xlrec->flags & GIN_INSERT_ISLEAF) ? 'T' : 'F');
91  if (!(xlrec->flags & GIN_INSERT_ISLEAF))
92  {
93  char *payload = rec + sizeof(ginxlogInsert);
94  BlockNumber leftChildBlkno;
95  BlockNumber rightChildBlkno;
96 
97  leftChildBlkno = BlockIdGetBlockNumber((BlockId) payload);
98  payload += sizeof(BlockIdData);
99  rightChildBlkno = BlockIdGetBlockNumber((BlockId) payload);
100  payload += sizeof(BlockNumber);
101  appendStringInfo(buf, " children: %u/%u",
102  leftChildBlkno, rightChildBlkno);
103  }
104  if (XLogRecHasBlockImage(record, 0))
105  {
106  if (XLogRecBlockImageApply(record, 0))
107  appendStringInfoString(buf, " (full page image)");
108  else
109  appendStringInfoString(buf, " (full page image, for WAL verification)");
110  }
111  else
112  {
113  char *payload = XLogRecGetBlockData(record, 0, NULL);
114 
115  if (!(xlrec->flags & GIN_INSERT_ISDATA))
116  appendStringInfo(buf, " isdelete: %c",
117  (((ginxlogInsertEntry *) payload)->isDelete) ? 'T' : 'F');
118  else if (xlrec->flags & GIN_INSERT_ISLEAF)
119  desc_recompress_leaf(buf, (ginxlogRecompressDataLeaf *) payload);
120  else
121  {
122  ginxlogInsertDataInternal *insertData =
123  (ginxlogInsertDataInternal *) payload;
124 
125  appendStringInfo(buf, " pitem: %u-%u/%u",
126  PostingItemGetBlockNumber(&insertData->newitem),
127  ItemPointerGetBlockNumber(&insertData->newitem.key),
128  ItemPointerGetOffsetNumber(&insertData->newitem.key));
129  }
130  }
131  }
132  break;
133  case XLOG_GIN_SPLIT:
134  {
135  ginxlogSplit *xlrec = (ginxlogSplit *) rec;
136 
137  appendStringInfo(buf, "isrootsplit: %c",
138  (((ginxlogSplit *) rec)->flags & GIN_SPLIT_ROOT) ? 'T' : 'F');
139  appendStringInfo(buf, " isdata: %c isleaf: %c",
140  (xlrec->flags & GIN_INSERT_ISDATA) ? 'T' : 'F',
141  (xlrec->flags & GIN_INSERT_ISLEAF) ? 'T' : 'F');
142  }
143  break;
144  case XLOG_GIN_VACUUM_PAGE:
145  /* no further information */
146  break;
147  case XLOG_GIN_VACUUM_DATA_LEAF_PAGE:
148  {
149  if (XLogRecHasBlockImage(record, 0))
150  {
151  if (XLogRecBlockImageApply(record, 0))
152  appendStringInfoString(buf, " (full page image)");
153  else
154  appendStringInfoString(buf, " (full page image, for WAL verification)");
155  }
156  else
157  {
158  ginxlogVacuumDataLeafPage *xlrec =
159  (ginxlogVacuumDataLeafPage *) XLogRecGetBlockData(record, 0, NULL);
160 
161  desc_recompress_leaf(buf, &xlrec->data);
162  }
163  }
164  break;
165  case XLOG_GIN_DELETE_PAGE:
166  /* no further information */
167  break;
168  case XLOG_GIN_UPDATE_META_PAGE:
169  /* no further information */
170  break;
171  case XLOG_GIN_INSERT_LISTPAGE:
172  /* no further information */
173  break;
174  case XLOG_GIN_DELETE_LISTPAGE:
175  appendStringInfo(buf, "ndeleted: %d",
176  ((ginxlogDeleteListPages *) rec)->ndeleted);
177  break;
178  }
179 }
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:23
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:176
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:2033
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
XLR_INFO_MASK
#define XLR_INFO_MASK
Definition: xlogrecord.h:62

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, XLogRecHasBlockImage, and XLR_INFO_MASK.

◆ gin_identify()

const char* gin_identify ( uint8  info)

Definition at line 182 of file gindesc.c.

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

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.