diff options
| author | tv <tv@krebsco.de> | 2026-10-25 20:09:39 +0100 |
|---|---|---|
| committer | tv <tv@krebsco.de> | 2026-10-25 20:09:39 +0100 |
| commit | c972916c9b6be540eaabb7ee7888267076a7960e (patch) | |
| tree | f4acc07564315aeba577d2884aca1a943c3275f7 /src/remake/switch.rs | |
| parent | d4b523bf6373af52db089ef9384bce9d7f834f7e (diff) | |
only keep list of actor IDs within one epoch (fixup)
Diffstat (limited to 'src/remake/switch.rs')
| -rw-r--r-- | src/remake/switch.rs | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/src/remake/switch.rs b/src/remake/switch.rs index e78643a..1a4dbf9 100644 --- a/src/remake/switch.rs +++ b/src/remake/switch.rs @@ -207,6 +207,7 @@ async fn switch<H: Host>( let actor = ActorId::random(); host.remake().add_own_actor(actor.clone()); + let new_actor = actor.clone(); // 2. Build (or reuse), verify and replay without holding any lock. let (new_doc, copy_heads, mut stats) = tokio::task::spawn_blocking( @@ -245,6 +246,7 @@ async fn switch<H: Host>( // 3. Swap, replaying what arrived since the copy. let (old, late) = swap_in(host, expected, new_doc, copy_heads, late_translator).await?; stats.absorb(late); + host.remake().reset_own_actors(new_actor); // 4. Writes the remake had no place for wait for an operator (the old document // holds them); the old document is kept as configured either way. |
