Method iter_conflicts

atomic-core/src/pristine/txn/write/view.rs:50–64

(&self, view_id: u64)

    }

    fn iter_conflicts(&self, view_id: u64) -> PristineResult<Vec<(u64, Vec<StoredConflict>)>> {
        let table = self.txn.open_table(CONFLICTS)?;
        let start = encode_view_seq(view_id, 0);
        let end = encode_view_seq(view_id, u64::MAX);
        let mut out = Vec::new();
        for entry in table.range::<&[u8; 16]>(&start..=&end)? {
            let (key, value) = entry?;
            let (_vid, inode) = decode_view_seq(key.value());
            let conflicts = deserialize_conflicts(value.value())?;
            if !conflicts.is_empty() {
                out.push((inode, conflicts));
            }
        }
        Ok(out)
    }

    fn get_change_seq(&self, view: &ViewState, change_id: NodeId) -> PristineResult<Option<u64>> {
        let table = self.txn.open_table(REV_VIEW_CHANGES)?;