From 1f18f0ba77e6abb9224e506a8d823815b151a2ea Mon Sep 17 00:00:00 2001 From: Mubelotix Date: Wed, 23 Jul 2025 14:33:58 +0200 Subject: [PATCH] Update little tiny comments --- .../src/scheduler/process_snapshot_creation.rs | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/crates/index-scheduler/src/scheduler/process_snapshot_creation.rs b/crates/index-scheduler/src/scheduler/process_snapshot_creation.rs index 3b46d0359..4a7a9e074 100644 --- a/crates/index-scheduler/src/scheduler/process_snapshot_creation.rs +++ b/crates/index-scheduler/src/scheduler/process_snapshot_creation.rs @@ -15,7 +15,7 @@ use crate::{Error, IndexScheduler, Result}; /// # Safety /// /// See [`EnvOpenOptions::open`]. -unsafe fn mark_tasks_as_succeeded( +unsafe fn remove_tasks( tasks: &[Task], dst: &std::path::Path, index_base_map_size: usize, @@ -112,7 +112,7 @@ impl IndexScheduler { }; self.env.copy_to_path(dst.join("data.mdb"), compaction_option)?; - // 2.2 Mark the current snapshot tasks as succeeded in the newly created env + // 2.2 Remove the current snapshot tasks // // This is done to ensure that the tasks are not processed again when the snapshot is imported // @@ -121,7 +121,7 @@ impl IndexScheduler { // This is safe because we open the env file we just created in a temporary directory. // We are sure it's not being used by any other process nor thread. unsafe { - mark_tasks_as_succeeded(&tasks, &dst, self.index_mapper.index_base_map_size)?; + remove_tasks(&tasks, &dst, self.index_mapper.index_base_map_size)?; } // 2.3 Create a read transaction on the index-scheduler