upstream-archive/qdrant
1
0
Fork 0
mirror of https://github.com/qdrant/qdrant.git synced 2026-09-21 05:27:39 -05:00
Code Issues Packages Projects Releases Wiki Activity

Switch to drain, it is simpler and recommended by docs (#7803)

Browse Source
This commit is contained in:
Tim Visée
2025-12-19 12:16:17 +01:00
committed by timvisee
parent 6c8c9179ef
commit 66d7022b25
1 changed files with 11 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files
lib/segment/src/id_tracker/mutable_id_tracker.rs
+11 -12
View File
@@ -836,19 +836,18 @@ fn reconcile_persisted_mapping_changes(
changes: &Vec<MappingChange>,
) {
let mut pending = pending.lock();
let mut delete_up_to = 0;
for (pending, persisted) in pending.iter().zip(changes) {
if pending != persisted {
// This should not happen, since flushers are supposed to be requested->executed
// one at a time, but if it does, it should be fine.
//
// The only consequence is to persist some operations again.
break;
}
delete_up_to += 1;
}
*pending = pending.split_off(delete_up_to);
// Count how many entries are equal in both lists
// With concurrent flushers it is possible that the beginning of the lists doesn't match. Since
// each event is idempotent it is not a problem, and we can store everything again in the next
// iteration.
let count = pending
.iter()
.zip(changes)
.take_while(|(pending, persisted)| pending == persisted)
.count();
pending.drain(0..count);
}
#[cfg(test)]