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

Commit 54cbf4c

Browse files
knizhnikkelvich
authored andcommitted
Ignore messages from dead nodes
1 parent 37a9a6e commit 54cbf4c

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

arbiter.c

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -759,6 +759,11 @@ static void MtmTransReceiver(Datum arg)
759759
MTM_LOG3("Receive HEARTBEAT from node %d at %ld", msg->node, USEC_TO_MSEC(MtmGetSystemTime()));
760760
continue;
761761
}
762+
if (BIT_CHECK(msg->disabledNodeMask, msg->node-1)) {
763+
elog(WARNING, "Ignore message from dead node %d\n", msg->node);
764+
continue;
765+
}
766+
762767
ts = (MtmTransState*)hash_search(MtmXid2State, &msg->dxid, HASH_FIND, NULL);
763768
Assert(ts != NULL);
764769

0 commit comments

Comments
 (0)