Commit54cbf4c

authored and

committed

Ignore messages from dead nodes

1 parent37a9a6e commit54cbf4cCopy full SHA for 54cbf4c

File tree

-0

lines changed

-0

lines changed

Lines changed: 5 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -759,6 +759,11 @@ static void MtmTransReceiver(Datum arg)`
`759`	`759`	`MTM_LOG3("Receive HEARTBEAT from node %d at %ld",msg->node,USEC_TO_MSEC(MtmGetSystemTime()));`
`760`	`760`	`continue;`
`761`	`761`	`}`
	`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`	`+`
`762`	`767`	`ts= (MtmTransState*)hash_search(MtmXid2State,&msg->dxid,HASH_FIND,NULL);`
`763`	`768`	`Assert(ts!=NULL);`
`764`	`769`

Comments

(0)