MCPcopy Create free account
hub / github.com/MaterializeInc/materialize / take_write_for_commit

Method take_write_for_commit

src/txn-wal/src/txns.rs:817–822  ·  view source on GitHub ↗
(
        &mut self,
        data_id: &ShardId,
    )

Source from the content-addressed store, hash-verified

815 }
816
817 pub(crate) fn take_write_for_commit(
818 &mut self,
819 data_id: &ShardId,
820 ) -> Option<DataWriteCommit<K, V, T, D>> {
821 self.data_write_for_commit.remove(data_id)
822 }
823
824 pub(crate) fn put_write_for_commit(&mut self, data_write: DataWriteCommit<K, V, T, D>) {
825 let prev = self

Callers 1

commit_atMethod · 0.80

Calls 1

removeMethod · 0.45

Tested by

no test coverage detected