Go to the source code of this file.
◆ SizeOfLogicalMessage
◆ XLOG_LOGICAL_MESSAGE
#define XLOG_LOGICAL_MESSAGE 0x00 |
◆ xl_logical_message
◆ logicalmsg_desc()
Definition at line 19 of file logicalmsgdesc.c.
Assert(fmt[strlen(fmt) - 1] !='\n')
#define XLOG_LOGICAL_MESSAGE
void appendStringInfo(StringInfo str, const char *fmt,...)
char message[FLEXIBLE_ARRAY_MEMBER]
#define XLogRecGetInfo(decoder)
#define XLogRecGetData(decoder)
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 | ) |
|
◆ logicalmsg_redo()
◆ LogLogicalMessage()
XLogRecPtr LogLogicalMessage |
( |
const char * |
prefix, |
|
|
const char * |
message, |
|
|
size_t |
size, |
|
|
bool |
transactional |
|
) |
| |
Definition at line 46 of file message.c.
#define unconstify(underlying_type, expr)
#define SizeOfLogicalMessage
bool IsTransactionState(void)
TransactionId GetCurrentTransactionId(void)
#define XLOG_INCLUDE_ORIGIN
void XLogRegisterData(char *data, uint32 len)
XLogRecPtr XLogInsert(RmgrId rmid, uint8 info)
void XLogSetRecordFlags(uint8 flags)
void XLogBeginInsert(void)
References Assert(), xl_logical_message::dbId, GetCurrentTransactionId(), IsTransactionState(), xl_logical_message::message_size, MyDatabaseId, xl_logical_message::prefix_size, SizeOfLogicalMessage, xl_logical_message::transactional, unconstify, XLOG_INCLUDE_ORIGIN, XLOG_LOGICAL_MESSAGE, XLogBeginInsert(), XLogInsert(), XLogRegisterData(), and XLogSetRecordFlags().
Referenced by pg_logical_emit_message_bytea().