(
&mut self,
data_id: &ShardId,
)
| 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 |