Location via proxy:   [ UP ]  
[Report a bug]   [Manage cookies]                
Skip to content

Commit 753a875

Browse files
knizhnikkelvich
authored andcommitted
Add MtmUseRaftable config parameter
1 parent 98eb87d commit 753a875

File tree

3 files changed

+4
-3
lines changed

3 files changed

+4
-3
lines changed

Makefile

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,12 +1,12 @@
11
MODULE_big = multimaster
2-
OBJS = multimaster.o arbiter.o bytebuf.o bgwpool.o pglogical_output.o pglogical_proto.o pglogical_receiver.o pglogical_apply.o pglogical_hooks.o pglogical_config.o ddd.o bkb.o
2+
OBJS = multimaster.o raftable.o arbiter.o bytebuf.o bgwpool.o pglogical_output.o pglogical_proto.o pglogical_receiver.o pglogical_apply.o pglogical_hooks.o pglogical_config.o ddd.o bkb.o
33

44
EXTENSION = multimaster
55
DATA = multimaster--1.0.sql
66

77
.PHONY: all
88

9-
all: multimaster.o multimaster.so
9+
all: multimaster.so
1010

1111
PG_CPPFLAGS = -I$(libpq_srcdir) -DUSE_PGLOGICAL_OUTPUT
1212
SHLIB_LINK = $(libpq)

multimaster.c

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -170,6 +170,7 @@ int MtmConnectAttempts;
170170
int MtmConnectTimeout;
171171
int MtmKeepaliveTimeout;
172172
int MtmReconnectAttempts;
173+
bool MtmUseRaftable;
173174
MtmConnectionInfo* MtmConnections;
174175

175176
static char* MtmConnStrs;
@@ -178,7 +179,6 @@ static int MtmWorkers;
178179
static int MtmVacuumDelay;
179180
static int MtmMinRecoveryLag;
180181
static int MtmMaxRecoveryLag;
181-
static bool MtmUseRaftable;
182182

183183
static ExecutorFinish_hook_type PreviousExecutorFinishHook;
184184
static ProcessUtility_hook_type PreviousProcessUtilityHook;

raftable.h

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -33,5 +33,6 @@ extern bool RaftableCAS(char const* key, char const* value, bool nowait);
3333
typedef void* (*raftable_get_t)(char const* key, int* size, int timeout);
3434
typedef void (*raftable_set_t)(char const* key, void const* value, int size, int timeout);
3535

36+
extern bool MtmUseRaftable;
3637

3738
#endif

0 commit comments

Comments
 (0)