diff options
| author | Jan Tuomi <jan@jantuomi.fi> | 2025-01-07 00:43:08 +0200 |
|---|---|---|
| committer | Jan Tuomi <jan@jantuomi.fi> | 2025-01-07 00:43:08 +0200 |
| commit | bb64bc35beea7e0c46407b42a6240f084ccd137a (patch) | |
| tree | d938950a895e0b1707c6a14d0f04f0ec675ab848 /log_db/src/lib.rs | |
| parent | 3e1d169fe822f711bd96278e13cd89e2800c8927 (diff) | |
Move refresh_indexes out of do_maintenance_tasks, fix benches
Diffstat (limited to 'log_db/src/lib.rs')
| -rw-r--r-- | log_db/src/lib.rs | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/log_db/src/lib.rs b/log_db/src/lib.rs index e9a25c1..4d9b82f 100644 --- a/log_db/src/lib.rs +++ b/log_db/src/lib.rs @@ -247,7 +247,9 @@ impl<R: Recordable> DB<R> { Ok(db) } - fn refresh_indexes(&mut self) -> Result<(), DBError> { + /// Refresh the in-memory indexes from the log files. + /// This needs to only be called if the read consistency is set to `ReadConsistency::Eventual`. + pub fn refresh_indexes(&mut self) -> Result<(), DBError> { let active_symlink_path = self.data_dir.join(ACTIVE_SYMLINK_FILENAME); let active_target = fs::read_link(active_symlink_path)?; let active_metadata_path = self.data_dir.join(active_target); @@ -796,8 +798,6 @@ impl<R: Recordable> DB<R> { self.active_metadata_file.unlock()?; - self.refresh_indexes()?; - Ok(()) } |
