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
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
|
/*-------------------------------------------------------------------------
*
* pglogical.h
* pglogical replication plugin
*
* Copyright (c) 2015, PostgreSQL Global Development Group
*
* IDENTIFICATION
* pglogical.h
*
*-------------------------------------------------------------------------
*/
#ifndef PGLOGICAL_H
#define PGLOGICAL_H
#include "storage/s_lock.h"
#include "postmaster/bgworker.h"
#include "utils/array.h"
#include "access/xlogdefs.h"
#include "executor/executor.h"
#include "miscadmin.h"
#include "libpq-fe.h"
#include "pglogical_fe.h"
#include "pglogical_node.h"
#include "pglogical_compat.h"
#define PGLOGICAL_VERSION "2.4.6"
#define PGLOGICAL_VERSION_NUM 20406
#define PGLOGICAL_MIN_PROTO_VERSION_NUM 1
#define PGLOGICAL_MAX_PROTO_VERSION_NUM 1
#define EXTENSION_NAME "pglogical"
#define REPLICATION_ORIGIN_ALL "all"
#if PG_VERSION_NUM >= 90500
#define HAVE_REPLICATION_ORIGINS
#endif
extern bool pglogical_synchronous_commit;
extern char *pglogical_temp_directory;
extern bool pglogical_use_spi;
extern bool pglogical_batch_inserts;
extern char *pglogical_extra_connection_options;
#if PG_VERSION_NUM >= 150000
extern shmem_request_hook_type prev_shmem_request_hook;
#endif
extern char *shorten_hash(const char *str, int maxlen);
extern List *textarray_to_list(ArrayType *textarray);
extern bool parsePGArray(const char *atext, char ***itemarray, int *nitems);
extern Oid get_pglogical_table_oid(const char *table);
extern void pglogical_execute_sql_command(char *cmdstr, char *role,
bool isTopLevel);
extern PGconn *pglogical_connect(const char *connstring, const char *connname,
const char *suffix);
extern PGconn *pglogical_connect_replica(const char *connstring,
const char *connname,
const char *suffix);
extern void pglogical_identify_system(PGconn *streamConn, uint64* sysid,
TimeLineID *timeline, XLogRecPtr *xlogpos,
Name *dbname);
extern void pglogical_start_replication(PGconn *streamConn,
const char *slot_name,
XLogRecPtr start_pos,
const char *forward_origins,
const char *replication_sets,
const char *replicate_only_table,
bool force_text_transfer);
extern void pglogical_manage_extension(void);
extern void apply_work(PGconn *streamConn);
extern bool synchronize_sequences(void);
extern void synchronize_sequence(Oid seqoid);
extern void pglogical_create_sequence_state_record(Oid seqoid);
extern void pglogical_drop_sequence_state_record(Oid seqoid);
extern int64 sequence_get_last_value(Oid seqoid);
extern bool in_pglogical_replicate_ddl_command;
#include "utils/memdebug.h"
/*
* PostgreSQL exposes stubs for some Valgrind macros, but there are some
* others we use that aren't supported by Pg proper yet.
*/
#ifndef USE_VALGRIND
#define VALGRIND_CHECK_VALUE_IS_DEFINED(v) do{} while(0)
#define VALGRIND_DO_LEAK_CHECK do{} while(0)
#define VALGRIND_DO_ADDED_LEAK_CHECK do{} while(0)
#define VALGRIND_DO_CHANGED_LEAK_CHECK do{} while(0)
#define VALGRIND_DO_QUICK_LEAK_CHECK do{} while(0)
#define VALGRIND_DISABLE_ERROR_REPORTING do {} while (0)
#define VALGRIND_ENABLE_ERROR_REPORTING do {} while (0)
/*
* Gives us some error checking when no-op'd. pglogical uses this to report
* the worker type, etc, prefixed by PGLOGICAL:, in the Valgrind logs. We
* need to stub it out if we aren't using valgrind.
*/
pg_attribute_printf(1, 2) pg_attribute_unused() static inline void VALGRIND_PRINTF(const char *format, ...) {}
#endif
#endif /* PGLOGICAL_H */
|
