mirror of
https://github.com/qdrant/qdrant.git
synced 2026-08-06 10:00:58 -05:00
log mutable id tracker mapping updates (#7894)
* add log for persisting id-tracker changes * trace log flush topology * fmt * make trace
This commit is contained in:
@@ -468,6 +468,8 @@ fn store_mapping_changes(
|
||||
|
||||
let mut writer = BufWriter::new(file);
|
||||
|
||||
log::trace!("writing mapping changes to {mappings_path:?}: {changes:?}");
|
||||
|
||||
write_mapping_changes(&mut writer, changes).map_err(|err| {
|
||||
OperationError::service_error(format!(
|
||||
"Failed to persist ID tracker point mappings ({}): {err}",
|
||||
|
||||
@@ -3,6 +3,7 @@ use std::sync::atomic::Ordering;
|
||||
use std::thread::JoinHandle;
|
||||
|
||||
use common::sort_utils::sort_permutation;
|
||||
use log::trace;
|
||||
use parking_lot::{RwLock, RwLockReadGuard};
|
||||
use segment::common::operation_error::{OperationError, OperationResult};
|
||||
use segment::entry::SegmentEntry;
|
||||
@@ -121,6 +122,8 @@ impl SegmentHolder {
|
||||
|
||||
fn sort_segment_ids_by_flush_dependency(&self, segment_ids: &[SegmentId]) -> Vec<SegmentId> {
|
||||
let flush_topology = self.flush_dependency.lock().clone();
|
||||
trace!("{flush_topology:?}");
|
||||
|
||||
let mut iter = flush_topology.sort_elements(segment_ids);
|
||||
let sorted_keys: Vec<_> = iter.by_ref().collect();
|
||||
|
||||
|
||||
Reference in New Issue
Block a user