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

Commit ed3caee

Browse files
committed
do not drop fresh slot
1 parent fc42dcb commit ed3caee

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

multimaster.c

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1895,7 +1895,8 @@ MtmCheckSlots()
18951895
if (slot->in_use
18961896
&& sscanf(slot->data.name.data, MULTIMASTER_SLOT_PATTERN, &nodeId) == 1
18971897
&& 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)
18991900
{
19001901
elog(WARNING, "Drop slot for node %d which lag %lld is larger than threshold %d",
19011902
nodeId,

0 commit comments

Comments
 (0)