From 9ed92642598cb5e6a6fc4bfaa6980f0e3f61ef5d Mon Sep 17 00:00:00 2001 From: bsbds <69835502+bsbds@users.noreply.github.com> Date: Tue, 20 Aug 2024 09:26:53 +0800 Subject: [PATCH] chore: remove unecessary txn usage Signed-off-by: bsbds <69835502+bsbds@users.noreply.github.com> --- crates/xline/src/storage/kv_store.rs | 9 +++------ 1 file changed, 3 insertions(+), 6 deletions(-) diff --git a/crates/xline/src/storage/kv_store.rs b/crates/xline/src/storage/kv_store.rs index e69a7d709..0832b7832 100644 --- a/crates/xline/src/storage/kv_store.rs +++ b/crates/xline/src/storage/kv_store.rs @@ -149,11 +149,9 @@ impl KvStoreInner { /// Get previous `KeyValue` of a `KeyValue` pub(crate) fn get_prev_kv(&self, kv: &KeyValue) -> Option { - let txn_db = self.db.transaction(); - let index = self.index.state(); Self::get_range( - &txn_db, - &index, + self.db.as_ref(), + self.index.as_ref(), &kv.key, &[], kv.mod_revision.overflow_sub(1), @@ -168,11 +166,10 @@ impl KvStoreInner { key_range: KeyRange, revision: i64, ) -> Result, ExecuteError> { - let txn = self.db.transaction(); let revisions = self.index .get_from_rev(key_range.range_start(), key_range.range_end(), revision); - let events = Self::get_values(&txn, &revisions)? + let events = Self::get_values(self.db.as_ref(), &revisions)? .into_iter() .map(|kv| { // Delete