Commit6c5f328

committed

do not drop fresh slot

1 parent6ca55e7 commit6c5f328Copy full SHA for 6c5f328

File tree

-1

lines changed

-1

lines changed

Lines changed: 2 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -1895,7 +1895,8 @@ MtmCheckSlots()`
`1895`	`1895`	`if (slot->in_use`
`1896`	`1896`	`&&sscanf(slot->data.name.data,MULTIMASTER_SLOT_PATTERN,&nodeId)==1`
`1897`	`1897`	`&&BIT_CHECK(Mtm->disabledNodeMask,nodeId-1)`
`1898`		`-&&slot->data.confirmed_flush+MtmMaxRecoveryLag<GetXLogInsertRecPtr())`
	`1898`	`+&&slot->data.confirmed_flush+MtmMaxRecoveryLag<GetXLogInsertRecPtr()`
	`1899`	`+&&slot->data.confirmed_flush!=0)`
`1899`	`1900`	`{`
`1900`	`1901`	`elog(WARNING,"Drop slot for node %d which lag %lld is larger than threshold %d",`
`1901`	`1902`	`nodeId,`

Comments

(0)