Method ensure_span_index

atomic-core/src/pristine/txn/read.rs:1443–1463

Load `change_id`'s spans into the in-memory index on first access.

(&self, change_id: u64)

    /// Load `change_id`'s spans into the in-memory index on first access.
    fn ensure_span_index(&self, change_id: u64) -> PristineResult<()> {
        if self.span_index.lock().unwrap().contains_change(change_id) {
            return Ok(());
        }
        let start_key = encode_vertex(change_id, 0, 0);
        let end_key = encode_vertex(change_id, u64::MAX, u64::MAX);
        let mut set = std::collections::BTreeSet::new();
        for result in self.graph_table.range::<&[u8; 24]>(&start_key..=&end_key)? {
            let (key, _values) = result?;
            let (v_change, v_start, v_end) = decode_vertex(key.value());
            if v_change != change_id {
                continue;
            }
            set.insert((v_start, v_end));
        }
        self.span_index
            .lock()
            .unwrap()
            .insert_change(change_id, set);
        Ok(())
    }
}

impl<'txn> GraphTxnT for CachedGraphTxn<'txn> {