Skip to content

Commit 5b3fc9c

Browse files
committed
Fix problem with worker name
1 parent 42ae5c4 commit 5b3fc9c

File tree

3 files changed

+5
-4
lines changed

3 files changed

+5
-4
lines changed

contrib/multimaster/multimaster.h

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2,8 +2,8 @@
22
#define __MULTIMASTER_H__
33

44
#define XTM_TRACE(fmt, ...)
5-
#define XTM_INFO(fmt, ...) fprintf(stderr, fmt, ## __VA_ARGS__)
6-
//#define XTM_INFO(fmt, ...)
5+
//#define XTM_INFO(fmt, ...) fprintf(stderr, fmt, ## __VA_ARGS__)
6+
#define XTM_INFO(fmt, ...)
77

88
extern int MMStartReceivers(char* nodes, int node_id);
99
extern void MMBeginTransaction(void);

contrib/multimaster/receiver_raw.c

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -52,6 +52,7 @@ static int receiver_idle_time = 1;
5252
static bool receiver_sync_mode = true;
5353

5454
/* Worker name */
55+
static char *worker_name = "multimaster";
5556
char worker_proc[16];
5657

5758
/* Lastly written positions */
@@ -239,7 +240,7 @@ receiver_raw_main(Datum main_arg)
239240

240241
query = createPQExpBuffer();
241242

242-
appendPQExpBuffer(query, "CREATE_REPLICATION_SLOT \"%s\" LOGICAL \"%s\"", args->receiver_slot, worker_proc);
243+
appendPQExpBuffer(query, "CREATE_REPLICATION_SLOT \"%s\" LOGICAL \"%s\"", args->receiver_slot, worker_name);
243244
res = PQexec(conn, query->data);
244245
if (PQresultStatus(res) != PGRES_TUPLES_OK)
245246
{

contrib/multimaster/tests/dtmbench.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -253,7 +253,7 @@ int main (int argc, char* argv[])
253253
cfg.nReaders,
254254
cfg.nWriters,
255255
nAborts,
256-
(int)(nAborts*100/cfg.nWriters),
256+
(int)(nAborts*100/cfg.nIterations),
257257
cfg.nAccounts,
258258
cfg.nIterations,
259259
cfg.connections.size()

0 commit comments

Comments
 (0)