diff options
| author | tv <tv@krebsco.de> | 2026-11-01 13:34:26 +0100 |
|---|---|---|
| committer | tv <tv@krebsco.de> | 2026-11-01 13:34:26 +0100 |
| commit | 1202c0ba9bf49e7e31492c90b37af3e6c91b98b7 (patch) | |
| tree | 72263c64c60c1d99e6e7b4381c032e8d6a4ec990 /src/state/host.rs | |
| parent | da76a3fd1eeb01b67cf7e281180bd4b677476d48 (diff) | |
state: drop epoch_tx
The stamp is the only lock-free epoch label.
Diffstat (limited to 'src/state/host.rs')
| -rw-r--r-- | src/state/host.rs | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/state/host.rs b/src/state/host.rs index 6bb9d3b..7c3e165 100644 --- a/src/state/host.rs +++ b/src/state/host.rs @@ -283,10 +283,10 @@ impl Host for AppState { replica.epoch = epoch; replica.epoch_seq += 1; replica.writable = writable; + // Publishes the epoch with the heads (`Replica::stamps`), under the + // same lock, so it never disagrees with the document for anyone + // holding the lock. replica.refresh_heads(); - // Updated under the same lock, so the cached epoch never disagrees - // with the document for anyone holding the lock. - state.epoch_tx.send_replace(epoch); // Reset every peer's sync state before the lock is released, so no // message is generated from or applied to a state that describes the // old document. (Lock order doc -> peer, as in sync generation.) |
