nik/chorus
1
0
Fork 0
mirror of https://github.com/mikedilger/chorus.git synced 2026-03-04 06:36:27 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

FIX: was opening iterators on the wrong databases!

Browse Source
This commit is contained in:
Mike Dilger 2024-03-02 13:04:53 +13:00
parent acbe1132c7
commit 4d9bd321ac
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
chorus-lib/src/store/mod.rs
View File

@ -328,7 +328,7 @@ impl Store {
Bound::Excluded(&*end_prefix),
);
let txn = self.env.read_txn()?;
let iter = self.akci.range(&txn, &range)?;
let iter = self.atci.range(&txn, &range)?;
for result in iter {
// Stop if limited
if output.len() >= filter.limit() as usize {
@ -371,7 +371,7 @@ impl Store {
Bound::Excluded(&*end_prefix),
);
let txn = self.env.read_txn()?;
let iter = self.akci.range(&txn, &range)?;
let iter = self.ktci.range(&txn, &range)?;
for result in iter {
// Stop if limited
if output.len() >= filter.limit() as usize {
@ -605,7 +605,7 @@ impl Store {
Bound::Excluded(&*end_prefix),
);
let loop_txn = self.env.read_txn()?;
let iter = self.akci.range(&loop_txn, &range)?;
let iter = self.atci.range(&loop_txn, &range)?;
let mut first = true;
for result in iter {
// Keep the first result