diff --git a/rbf/db.go b/rbf/db.go index e807956ec..737d7793b 100644 --- a/rbf/db.go +++ b/rbf/db.go @@ -250,7 +250,7 @@ func (db *DB) checkpoint(exclusive bool, mu sync.Locker) error { // Loop over pages in the transaction. for ; walID <= metaWALID; walID++ { - canCheckpoint := exclusive || minActiveWALID == 0 || walID <= minActiveWALID + canCheckpoint := exclusive || minActiveWALID == 0 || walID < minActiveWALID page, err := readWALPage(segments, walID) if err != nil {