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

Commit 824cbc3

Browse files
knizhnikkelvich
authored andcommitted
Set MtmReplicationNode in pglogical_receiver
1 parent 9377027 commit 824cbc3

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

pglogical_receiver.c

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -238,6 +238,7 @@ pglogical_receiver_main(Datum main_arg)
238238

239239
Mtm->nodes[nodeId-1].receiverPid = MyProcPid;
240240
Mtm->nodes[nodeId-1].receiverStartTime = MtmGetSystemTime();
241+
MtmReplicationNodeId = nodeId;
241242

242243
sprintf(worker_proc, "mtm_pglogical_receiver_%d_%d", MtmNodeId, nodeId);
243244

0 commit comments

Comments
 (0)