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.
#define Assert(condition)
#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, |
|
|
bool |
flush |
|
) |
| |
Definition at line 43 of file message.c.
78 if (!transactional && flush)
#define SizeOfLogicalMessage
static pg_noinline void Size size
bool IsTransactionState(void)
TransactionId GetCurrentTransactionId(void)
void XLogFlush(XLogRecPtr record)
#define XLOG_INCLUDE_ORIGIN
XLogRecPtr XLogInsert(RmgrId rmid, uint8 info)
void XLogSetRecordFlags(uint8 flags)
void XLogRegisterData(const char *data, uint32 len)
void XLogBeginInsert(void)
References Assert, xl_logical_message::dbId, GetCurrentTransactionId(), IsTransactionState(), xl_logical_message::message_size, MyDatabaseId, xl_logical_message::prefix_size, 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().