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)