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.

{
    char       *rec = XLogRecGetData(record);
    uint8       info = XLogRecGetInfo(record) & ~XLR_INFO_MASK;
 
    if (info == XLOG_LOGICAL_MESSAGE)
    {
        xl_logical_message *xlrec = (xl_logical_message *) rec;
        char       *prefix = xlrec->message;
        char       *message = xlrec->message + xlrec->prefix_size;
        char       *sep = "";
 
        Assert(prefix[xlrec->prefix_size - 1] == '\0');
 
        appendStringInfo(buf, "%s, prefix \"%s\"; payload (%zu bytes): ",
                         xlrec->transactional ? "transactional" : "non-transactional",
                         prefix, xlrec->message_size);
        /* Write message payload as a series of hex bytes */
        for (int cnt = 0; cnt < xlrec->message_size; cnt++)
        {
            appendStringInfo(buf, "%s%02X", sep, (unsigned char) message[cnt]);
            sep = " ";
        }
    }
}

References appendStringInfo(), Assert, buf, 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.

logicalmsg_identify()

const char* logicalmsg_identify

(

uint8

info

)

Definition at line 46 of file logicalmsgdesc.c.

{
    if ((info & ~XLR_INFO_MASK) == XLOG_LOGICAL_MESSAGE)
        return "MESSAGE";
 
    return NULL;
}

References XLOG_LOGICAL_MESSAGE, and XLR_INFO_MASK.