PostgreSQL Source Code  git master
logicalmsgdesc.c File Reference
#include "postgres.h"
#include "replication/message.h"
Include dependency graph for logicalmsgdesc.c:

Go to the source code of this file.

Functions

void logicalmsg_desc (StringInfo buf, XLogReaderState *record)
 
const char * logicalmsg_identify (uint8 info)
 

Function Documentation

◆ logicalmsg_desc()

void logicalmsg_desc ( StringInfo  buf,
XLogReaderState record 
)

Definition at line 19 of file logicalmsgdesc.c.

References appendStringInfo(), Assert, xl_logical_message::message, xl_logical_message::message_size, xl_logical_message::prefix_size, xl_logical_message::transactional, XLOG_LOGICAL_MESSAGE, XLogRecGetData, XLogRecGetInfo, and XLR_INFO_MASK.

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] != '\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 }
unsigned char uint8
Definition: c.h:427
char message[FLEXIBLE_ARRAY_MEMBER]
Definition: message.h:27
#define XLogRecGetData(decoder)
Definition: xlogreader.h:310
void appendStringInfo(StringInfo str, const char *fmt,...)
Definition: stringinfo.c:91
#define XLogRecGetInfo(decoder)
Definition: xlogreader.h:305
bool transactional
Definition: message.h:23
#define Assert(condition)
Definition: c.h:800
#define XLR_INFO_MASK
Definition: xlogrecord.h:62
#define XLOG_LOGICAL_MESSAGE
Definition: message.h:36

◆ logicalmsg_identify()

const char* logicalmsg_identify ( uint8  info)

Definition at line 46 of file logicalmsgdesc.c.

References XLOG_LOGICAL_MESSAGE, and XLR_INFO_MASK.

47 {
48  if ((info & ~XLR_INFO_MASK) == XLOG_LOGICAL_MESSAGE)
49  return "MESSAGE";
50 
51  return NULL;
52 }
#define XLR_INFO_MASK
Definition: xlogrecord.h:62
#define XLOG_LOGICAL_MESSAGE
Definition: message.h:36