diff options
| author | tv <tv@krebsco.de> | 2026-11-01 19:35:20 +0100 |
|---|---|---|
| committer | tv <tv@krebsco.de> | 2026-11-01 19:35:20 +0100 |
| commit | 5640bacf735c6728acf4bc22217b0c07ac4bf7f9 (patch) | |
| tree | e1cdf1a912ca90d24d6a8100263edc0c5298305e /src/document/file.rs | |
| parent | 2ac2b0e2b08f14be07c46b3fd9a516a64e9933fb (diff) | |
document: allow writes during rejoin
Diffstat (limited to 'src/document/file.rs')
| -rw-r--r-- | src/document/file.rs | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/src/document/file.rs b/src/document/file.rs index 9efae42..3ea3afd 100644 --- a/src/document/file.rs +++ b/src/document/file.rs @@ -197,6 +197,11 @@ impl DocumentFile { /// What is due for a document of `epoch` at `heads`, written by this node's `actors` /// (see the module docs). + /// How many of this node's actors the file holds; None before it was written. + pub(crate) fn actors(&self) -> Option<usize> { + self.lock().as_ref().map(|written| written.actors) + } + pub(crate) fn due(&self, epoch: Epoch, actors: usize, heads: &[ChangeHash]) -> Due { let written = self.lock().clone(); let reason = match &written { |
