@@ -20,7 +20,7 @@ impl Locator {
}
pub fn from_index(ix: usize, count: usize) -> Self {
- let id = ((ix as u128 * u64::MAX as u128) / count as u128) as u64;
+ let id = (1 + ix as u64) * (u64::MAX / (count as u64 + 2));
Self(smallvec![id])
}
@@ -602,36 +602,3 @@ fn test_random_concurrent_edits(mut rng: StdRng) {
buffer.check_invariants();
}
}
--impl Buffer {- fn check_invariants(&self) {- // Ensure every fragment is ordered by locator in the fragment tree and corresponds- // to an insertion fragment in the insertions tree.- let mut prev_fragment_id = Locator::min();- for fragment in self.snapshot.fragments.items(&None) {- assert!(fragment.id > prev_fragment_id);- prev_fragment_id = fragment.id.clone();-- let insertion_fragment = self- .snapshot- .insertions- .get(- &InsertionFragmentKey {- timestamp: fragment.insertion_timestamp.local(),- split_offset: fragment.insertion_offset,- },- &(),- )- .unwrap();- assert_eq!(insertion_fragment.fragment_id, fragment.id);- }-- let mut cursor = self.snapshot.fragments.cursor::<Option<&Locator>>();- for insertion_fragment in self.snapshot.insertions.cursor::<()>() {- cursor.seek(&Some(&insertion_fragment.fragment_id), Bias::Left, &None);- let fragment = cursor.item().unwrap();- assert_eq!(insertion_fragment.fragment_id, fragment.id);- assert_eq!(insertion_fragment.split_offset, fragment.insertion_offset);- }- }-}