fix integer overflow in slot lag calculation =(

kelvich · kelvich · commit a422a23996b7 · 2017-11-13T02:23:42.000+03:00
diff --git a/multimaster.c b/multimaster.c
@@ -2036,7 +2036,7 @@ MtmCheckSlots()
 			if (slot->in_use
 				&& sscanf(slot->data.name.data, MULTIMASTER_SLOT_PATTERN, &nodeId) == 1
 				&& BIT_CHECK(Mtm->disabledNodeMask, nodeId-1)
-				&& slot->data.confirmed_flush + MtmMaxRecoveryLag * 1024 < GetXLogInsertRecPtr()
+				&& slot->data.confirmed_flush + (long64) MtmMaxRecoveryLag * 1024 < GetXLogInsertRecPtr()
 				&& slot->data.confirmed_flush != 0)
 			{
 				MTM_ELOG(WARNING, "Drop slot for node %d which lag %lld B is larger than threshold %d kB",

Original file line number	Diff line number	Diff line change
`@@ -2036,7 +2036,7 @@ MtmCheckSlots()`
`2036`	`2036`	`if (slot->in_use`
`2037`	`2037`	`&& sscanf(slot->data.name.data, MULTIMASTER_SLOT_PATTERN, &nodeId) == 1`
`2038`	`2038`	`&& BIT_CHECK(Mtm->disabledNodeMask, nodeId-1)`
`2039`		`- && slot->data.confirmed_flush + MtmMaxRecoveryLag * 1024 < GetXLogInsertRecPtr()`
	`2039`	`+ && slot->data.confirmed_flush + (long64) MtmMaxRecoveryLag * 1024 < GetXLogInsertRecPtr()`
`2040`	`2040`	`&& slot->data.confirmed_flush != 0)`
`2041`	`2041`	`{`
`2042`	`2042`	`MTM_ELOG(WARNING, "Drop slot for node %d which lag %lld B is larger than threshold %d kB",`