diff options
| author | tv <tv@krebsco.de> | 2026-11-07 22:35:21 +0100 |
|---|---|---|
| committer | tv <tv@krebsco.de> | 2026-11-07 22:35:21 +0100 |
| commit | 1a5b5ea02909e6c176ebd85d395e47fe15fcdba0 (patch) | |
| tree | 0e365788ce87a372353aae7a03403af0daf284d4 /src/remake/catchup.rs | |
| parent | 046b738c74f62469f7a080415690e2dacd85e1e6 (diff) | |
remake: replays keep their writers
A remake's replay writes each value as the user who wrote it,
splitting where several users wrote under a path, so replays are
judged as the original writes.
Auth plan M6 (remakes, 2.4).
Diffstat (limited to 'src/remake/catchup.rs')
| -rw-r--r-- | src/remake/catchup.rs | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/src/remake/catchup.rs b/src/remake/catchup.rs index 1ee9508..71f077a 100644 --- a/src/remake/catchup.rs +++ b/src/remake/catchup.rs @@ -404,6 +404,7 @@ async fn finish<H: Host>(host: &H) { // The writes, under the lock, with the switch back to serving requests. let quarantined_whole = matches!(plan, Plan::Quarantine { .. }); let superseded = host.superseded(); + let node = host.node_id(); let ((stats, unplaced), old) = host .finish_rejoin(old, move |live, old| { let mut stats = ReplayStats::default(); @@ -420,6 +421,7 @@ async fn finish<H: Host>(host: &H) { &before, &after, live, + &node, &translator, superseded, )); @@ -436,6 +438,7 @@ async fn finish<H: Host>(host: &H) { &began, &heads, live, + &node, &translator, superseded, )); |
