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

Commit 4eacfee

Browse files
committed
Set MtmReplicationNode in pglogical_receiver
1 parent 96222ee commit 4eacfee

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

contrib/mmts/pglogical_receiver.c

+1
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)