PostgreSQL Source Code: src/backend/replication/logical/message.c Source File (original) (raw)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
33
38
39
40
41
44 bool transactional, bool flush)
45{
48
49
50
51
52 if (transactional)
53 {
56 }
57
60
63
68
69
71
73
74
75
76
77
78 if (!transactional && flush)
80 return lsn;
81}
82
83
84
85
86void
88{
90
92 elog(PANIC, "logicalmsg_redo: unknown op code %u", info);
93
94
95}
Assert(PointerIsAligned(start, uint64))
XLogRecPtr LogLogicalMessage(const char *prefix, const char *message, size_t size, bool transactional, bool flush)
void logicalmsg_redo(XLogReaderState *record)
#define SizeOfLogicalMessage
#define XLOG_LOGICAL_MESSAGE
bool IsTransactionState(void)
TransactionId GetCurrentTransactionId(void)
void XLogFlush(XLogRecPtr record)
#define XLOG_INCLUDE_ORIGIN
XLogRecPtr XLogInsert(RmgrId rmid, uint8 info)
void XLogRegisterData(const void *data, uint32 len)
void XLogSetRecordFlags(uint8 flags)
void XLogBeginInsert(void)
#define XLogRecGetInfo(decoder)