pebble range fix

ucwong · ucwong · commit 335caddbf525 · 2023-02-16T04:23:59.000+08:00
diff --git a/pebble/pebble.go b/pebble/pebble.go
@@ -139,7 +139,11 @@ func (peb *Pebble) Range(start, limit []byte) (res [][]byte) {
 	iter := peb.engine.NewIter(nil)
 	defer iter.Close()
 	for iter.SeekGEWithLimit(start, limit); iter.Valid(); iter.Next() {
-		res = append(res, common.SafeCopy(nil, iter.Value()))
+		if bytes.Compare(limit, iter.Key()) > 0 {
+			res = append(res, common.SafeCopy(nil, iter.Value()))
+		} else {
+			break
+		}
 	}
 	return
 }

Original file line number	Diff line number	Diff line change
`@@ -139,7 +139,11 @@ func (peb *Pebble) Range(start, limit []byte) (res [][]byte) {`
`139`	`139`	`iter := peb.engine.NewIter(nil)`
`140`	`140`	`defer iter.Close()`
`141`	`141`	`for iter.SeekGEWithLimit(start, limit); iter.Valid(); iter.Next() {`
`142`		`- res = append(res, common.SafeCopy(nil, iter.Value()))`
	`142`	`+ if bytes.Compare(limit, iter.Key()) > 0 {`
	`143`	`+ res = append(res, common.SafeCopy(nil, iter.Value()))`
	`144`	`+ } else {`
	`145`	`+ break`
	`146`	`+ }`
`143`	`147`	`}`
`144`	`148`	`return`
`145`	`149`	`}`