message.c File Reference

#include "postgres.h"
#include "access/xact.h"
#include "access/xloginsert.h"
#include "miscadmin.h"
#include "replication/message.h"

Include dependency graph for message.c:

Go to the source code of this file.

Functions
XLogRecPtr	LogLogicalMessage (const char *prefix, const char *message, size_t size, bool transactional, bool flush)
void	logicalmsg_redo (XLogReaderState *record)

Function Documentation

logicalmsg_redo()

void logicalmsg_redo

(

XLogReaderState *

record

)

Definition at line 87 of file message.c.

{
    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. */
}

References elog, PANIC, XLOG_LOGICAL_MESSAGE, and XLogRecGetInfo.

LogLogicalMessage()

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

Definition at line 43 of file message.c.

{
    xl_logical_message xlrec;
    XLogRecPtr  lsn;
 
    /*
     * Force xid to be allocated if we're emitting a transactional message.
     */
    if (transactional)
    {
        Assert(IsTransactionState());
        GetCurrentTransactionId();
    }
 
    xlrec.dbId = MyDatabaseId;
    xlrec.transactional = transactional;
    /* trailing zero is critical; see logicalmsg_desc */
    xlrec.prefix_size = strlen(prefix) + 1;
    xlrec.message_size = size;
 
    XLogBeginInsert();
    XLogRegisterData(&xlrec, SizeOfLogicalMessage);
    XLogRegisterData(prefix, xlrec.prefix_size);
    XLogRegisterData(message, size);
 
    /* allow origin filtering */
    XLogSetRecordFlags(XLOG_INCLUDE_ORIGIN);
 
    lsn = XLogInsert(RM_LOGICALMSG_ID, XLOG_LOGICAL_MESSAGE);
 
    /*
     * Make sure that the message hits disk before leaving if emitting a
     * non-transactional message when flush is requested.
     */
    if (!transactional && flush)
        XLogFlush(lsn);
    return lsn;
}

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(), XLogFlush(), XLogInsert(), XLogRegisterData(), and XLogSetRecordFlags().

Referenced by pg_logical_emit_message_bytea().