Method missing_locks

src/adapter/src/session.rs:1827–1838

Returns the collections we're missing locks for, if any.

(
        &self,
        writes: impl Iterator<Item = CatalogItemId>,
    )

    /// Returns the collections we're missing locks for, if any.
    pub fn missing_locks(
        &self,
        writes: impl Iterator<Item = CatalogItemId>,
    ) -> BTreeSet<CatalogItemId> {
        let mut missing = BTreeSet::new();
        for write in writes {
            if !self.locks.contains_key(&write) {
                missing.insert(write);
            }
        }
        missing
    }
}

impl Drop for GroupCommitWriteLocks {