message.h File Reference

#include "access/xlog.h"
#include "access/xlogdefs.h"
#include "access/xlogreader.h"

Include dependency graph for message.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Data Structures
struct	xl_logical_message

Macros
#define	SizeOfLogicalMessage   (offsetof(xl_logical_message, message))
#define	XLOG_LOGICAL_MESSAGE   0x00

Typedefs
typedef struct xl_logical_message	xl_logical_message

Functions
XLogRecPtr	LogLogicalMessage (const char *prefix, const char *message, size_t size, bool transactional)
void	logicalmsg_redo (XLogReaderState *record)
void	logicalmsg_desc (StringInfo buf, XLogReaderState *record)
const char *	logicalmsg_identify (uint8 info)

Macro Definition Documentation

#define SizeOfLogicalMessage   (offsetof(xl_logical_message, message))

Definition at line 31 of file message.h.

Referenced by LogLogicalMessage().

#define XLOG_LOGICAL_MESSAGE   0x00

Definition at line 37 of file message.h.

Referenced by DecodeLogicalMsgOp(), logicalmsg_desc(), logicalmsg_identify(), logicalmsg_redo(), and LogLogicalMessage().

Typedef Documentation

typedef struct xl_logical_message xl_logical_message

Function Documentation

void logicalmsg_desc	(	StringInfo	buf,
		XLogReaderState *	record
	)

Definition at line 19 of file logicalmsgdesc.c.

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

{
    char       *rec = XLogRecGetData(record);
    uint8       info = XLogRecGetInfo(record) & ~XLR_INFO_MASK;

    if (info == XLOG_LOGICAL_MESSAGE)
    {
        xl_logical_message *xlrec = (xl_logical_message *) rec;

        appendStringInfo(buf, "%s message size %zu bytes",
                         xlrec->transactional ? "transactional" : "nontransactional",
                         xlrec->message_size);
    }
}

const char* logicalmsg_identify

(

uint8

info

)

Definition at line 35 of file logicalmsgdesc.c.

References NULL, XLOG_LOGICAL_MESSAGE, and XLR_INFO_MASK.

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

    return NULL;
}

void logicalmsg_redo

(

XLogReaderState *

record

)

Definition at line 85 of file message.c.

References elog, PANIC, XLOG_LOGICAL_MESSAGE, XLogRecGetInfo, and XLR_INFO_MASK.

{
    uint8       info = XLogRecGetInfo(record) & ~XLR_INFO_MASK;

    if (info != XLOG_LOGICAL_MESSAGE)
        elog(PANIC, "logicalmsg_redo: unknown op code %u", info);

    /* This is only interesting for logical decoding, see decode.c. */
}

XLogRecPtr LogLogicalMessage	(	const char *	prefix,
		const char *	message,
		size_t	size,
		bool	transactional
	)

Definition at line 51 of file message.c.

References Assert, xl_logical_message::dbId, GetCurrentTransactionId(), IsTransactionState(), xl_logical_message::message_size, MyDatabaseId, xl_logical_message::prefix_size, SizeOfLogicalMessage, xl_logical_message::transactional, XLOG_INCLUDE_ORIGIN, XLOG_LOGICAL_MESSAGE, XLogBeginInsert(), XLogInsert(), XLogRegisterData(), and XLogSetRecordFlags().

Referenced by pg_logical_emit_message_bytea().

{
    xl_logical_message xlrec;

    /*
     * Force xid to be allocated if we're emitting a transactional message.
     */
    if (transactional)
    {
        Assert(IsTransactionState());
        GetCurrentTransactionId();
    }

    xlrec.dbId = MyDatabaseId;
    xlrec.transactional = transactional;
    xlrec.prefix_size = strlen(prefix) + 1;
    xlrec.message_size = size;

    XLogBeginInsert();
    XLogRegisterData((char *) &xlrec, SizeOfLogicalMessage);
    XLogRegisterData((char *) prefix, xlrec.prefix_size);
    XLogRegisterData((char *) message, size);

    /* allow origin filtering */
    XLogSetRecordFlags(XLOG_INCLUDE_ORIGIN);

    return XLogInsert(RM_LOGICALMSG_ID, XLOG_LOGICAL_MESSAGE);
}