From 1f3be9d059876f7f3994056b1ac8ce307628a52a Mon Sep 17 00:00:00 2001
From: tv <tv@krebsco.de>
Date: Sun, 1 Nov 2026 19:35:20 +0100
Subject: document: allow writes during rejoin

---
 src/remake/local.rs | 11 ++++++++---
 1 file changed, 8 insertions(+), 3 deletions(-)

(limited to 'src/remake/local.rs')

diff --git a/src/remake/local.rs b/src/remake/local.rs
index e8fc9eb..ce133ec 100644
--- a/src/remake/local.rs
+++ b/src/remake/local.rs
@@ -16,7 +16,7 @@ use super::records::Retention;
 use super::snapshot::Snapshot;
 use crate::clock::UnixMillis;
 use crate::document::replica::Epoch;
-use crate::document::{ActorId, Document};
+use crate::document::{ActorId, ChangeHash, Document};
 use crate::locks::MutexExt;
 
 pub(crate) struct RemakeState {
@@ -87,8 +87,13 @@ pub(crate) struct CatchUp {
 pub(crate) struct Rejoin {
     pub(crate) previous: Epoch,
     pub(crate) target: Epoch,
-    /// The document of `previous`, until it is replayed, quarantined or restored.
-    pub(crate) old: Document,
+    /// The document of `previous`, until it is replayed, quarantined or restored; of a
+    /// node that was ready, kept by the node instead, where it takes its writes
+    /// meanwhile (`Host::begin_rejoin`).
+    pub(crate) old: Option<Document>,
+    /// That document's heads as the rejoin began: the changes after them it took
+    /// during the rejoin.
+    pub(crate) heads: Vec<ChangeHash>,
     pub(crate) started: Instant,
     /// The node served requests before; it does again once the rejoin is over.
     pub(crate) was_ready: bool,
-- 
cgit v1.3.1