PostgreSQL Source Code git master
Functions
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.

88{
89 uint8 info = XLogRecGetInfo(record) & ~XLR_INFO_MASK;
90
91 if (info != XLOG_LOGICAL_MESSAGE)
92 elog(PANIC, "logicalmsg_redo: unknown op code %u", info);
93
94 /* This is only interesting for logical decoding, see decode.c. */
95}
uint8_t uint8
Definition: c.h:536
#define PANIC
Definition: elog.h:42
#define elog(elevel,...)
Definition: elog.h:226
#define XLOG_LOGICAL_MESSAGE
Definition: message.h:37
#define XLogRecGetInfo(decoder)
Definition: xlogreader.h:410

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.

45{
47 XLogRecPtr lsn;
48
49 /*
50 * Force xid to be allocated if we're emitting a transactional message.
51 */
52 if (transactional)
53 {
56 }
57
58 xlrec.dbId = MyDatabaseId;
59 xlrec.transactional = transactional;
60 /* trailing zero is critical; see logicalmsg_desc */
61 xlrec.prefix_size = strlen(prefix) + 1;
62 xlrec.message_size = size;
63
66 XLogRegisterData(prefix, xlrec.prefix_size);
67 XLogRegisterData(message, size);
68
69 /* allow origin filtering */
71
72 lsn = XLogInsert(RM_LOGICALMSG_ID, XLOG_LOGICAL_MESSAGE);
73
74 /*
75 * Make sure that the message hits disk before leaving if emitting a
76 * non-transactional message when flush is requested.
77 */
78 if (!transactional && flush)
79 XLogFlush(lsn);
80 return lsn;
81}
Oid MyDatabaseId
Definition: globals.c:94
Assert(PointerIsAligned(start, uint64))
#define SizeOfLogicalMessage
Definition: message.h:30
Definition: message.h:21
Size prefix_size
Definition: message.h:24
bool transactional
Definition: message.h:23
Oid dbId
Definition: message.h:22
Size message_size
Definition: message.h:25
bool IsTransactionState(void)
Definition: xact.c:387
TransactionId GetCurrentTransactionId(void)
Definition: xact.c:454
void XLogFlush(XLogRecPtr record)
Definition: xlog.c:2780
#define XLOG_INCLUDE_ORIGIN
Definition: xlog.h:154
uint64 XLogRecPtr
Definition: xlogdefs.h:21
XLogRecPtr XLogInsert(RmgrId rmid, uint8 info)
Definition: xloginsert.c:474
void XLogRegisterData(const void *data, uint32 len)
Definition: xloginsert.c:364
void XLogSetRecordFlags(uint8 flags)
Definition: xloginsert.c:456
void XLogBeginInsert(void)
Definition: xloginsert.c:149

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().

AltStyle によって変換されたページ (->オリジナル) /