Movatterモバイル変換


[0]ホーム

URL:


Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

Sign up
Appearance settings

Commit5b3fc9c

Browse files
committed
Fix problem with worker name
1 parent42ae5c4 commit5b3fc9c

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
#defineXTM_TRACE(fmt, ...)
5-
#defineXTM_INFO(fmt, ...) fprintf(stderr, fmt, ## __VA_ARGS__)
6-
//#define XTM_INFO(fmt, ...)
5+
//#define XTM_INFO(fmt, ...) fprintf(stderr, fmt, ## __VA_ARGS__)
6+
#defineXTM_INFO(fmt, ...)
77

88
externintMMStartReceivers(char*nodes,intnode_id);
99
externvoidMMBeginTransaction(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
staticboolreceiver_sync_mode= true;
5353

5454
/* Worker name */
55+
staticchar*worker_name="multimaster";
5556
charworker_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)

[8]ページ先頭

©2009-2025 Movatter.jp