PostgreSQL Source Code  git master
logicalmsgdesc.c
Go to the documentation of this file.
1 /*-------------------------------------------------------------------------
2  *
3  * logicalmsgdesc.c
4  * rmgr descriptor routines for replication/logical/message.c
5  *
6  * Portions Copyright (c) 2015-2024, PostgreSQL Global Development Group
7  *
8  *
9  * IDENTIFICATION
10  * src/backend/access/rmgrdesc/logicalmsgdesc.c
11  *
12  *-------------------------------------------------------------------------
13  */
14 #include "postgres.h"
15 
16 #include "replication/message.h"
17 
18 void
20 {
21  char *rec = XLogRecGetData(record);
22  uint8 info = XLogRecGetInfo(record) & ~XLR_INFO_MASK;
23 
24  if (info == XLOG_LOGICAL_MESSAGE)
25  {
26  xl_logical_message *xlrec = (xl_logical_message *) rec;
27  char *prefix = xlrec->message;
28  char *message = xlrec->message + xlrec->prefix_size;
29  char *sep = "";
30 
31  Assert(prefix[xlrec->prefix_size - 1] == '\0');
32 
33  appendStringInfo(buf, "%s, prefix \"%s\"; payload (%zu bytes): ",
34  xlrec->transactional ? "transactional" : "non-transactional",
35  prefix, xlrec->message_size);
36  /* Write message payload as a series of hex bytes */
37  for (int cnt = 0; cnt < xlrec->message_size; cnt++)
38  {
39  appendStringInfo(buf, "%s%02X", sep, (unsigned char) message[cnt]);
40  sep = " ";
41  }
42  }
43 }
44 
45 const char *
47 {
48  if ((info & ~XLR_INFO_MASK) == XLOG_LOGICAL_MESSAGE)
49  return "MESSAGE";
50 
51  return NULL;
52 }
unsigned char uint8
Definition: c.h:491
Assert(fmt[strlen(fmt) - 1] !='\n')
void logicalmsg_desc(StringInfo buf, XLogReaderState *record)
const char * logicalmsg_identify(uint8 info)
#define XLOG_LOGICAL_MESSAGE
Definition: message.h:37
static char * buf
Definition: pg_test_fsync.c:73
void appendStringInfo(StringInfo str, const char *fmt,...)
Definition: stringinfo.c:97
bool transactional
Definition: message.h:23
char message[FLEXIBLE_ARRAY_MEMBER]
Definition: message.h:27
#define XLogRecGetInfo(decoder)
Definition: xlogreader.h:410
#define XLogRecGetData(decoder)
Definition: xlogreader.h:415
#define XLR_INFO_MASK
Definition: xlogrecord.h:62