More robust KeepLogSeg() coding

diff --git a/src/backend/access/transam/xlog.c b/src/backend/access/transam/xlog.c
index a77ff5fe5e9aade1f949fecfa8091f5718bb8258..ee1c0a31130da42a70e61ef9c241d470935f2833 100644 (file)
--- a/src/backend/access/transam/xlog.c
+++ b/src/backend/access/transam/xlog.c
@@ -9000,7 +9000,7 @@ CreateRestartPoint(int flags)
 static void
 KeepLogSeg(XLogRecPtr recptr, XLogSegNo *logSegNo)
 {
-       XLogSegNo       segno, slotSegNo;
+       XLogSegNo       segno;
        XLogRecPtr      keep;
 
        XLByteToSeg(recptr, segno);
@@ -9019,9 +9019,13 @@ KeepLogSeg(XLogRecPtr recptr, XLogSegNo *logSegNo)
        /* then check whether slots limit removal further */
        if (max_replication_slots > 0 && keep != InvalidXLogRecPtr)
        {
-               XLByteToPrevSeg(keep, slotSegNo);
+               XLogRecPtr slotSegNo;
+
+               XLByteToSeg(keep, slotSegNo);
 
-               if (slotSegNo < segno)
+               if (slotSegNo <= 0)
+                       segno = 1;
+               else if (slotSegNo < segno)
                        segno = slotSegNo;
        }