diff options
| author | tv <tv@krebsco.de> | 2026-11-01 19:45:40 +0100 |
|---|---|---|
| committer | tv <tv@krebsco.de> | 2026-11-01 19:45:40 +0100 |
| commit | 78f67ee4dba0fdcd2ad6d91b5d46844284cf2d87 (patch) | |
| tree | 4ff2d45d5253c491c23beb230544148185392c25 /src/remake/proposal.rs | |
| parent | 5640bacf735c6728acf4bc22217b0c07ac4bf7f9 (diff) | |
remake: decouple grace time from node's keepalive
Diffstat (limited to 'src/remake/proposal.rs')
| -rw-r--r-- | src/remake/proposal.rs | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/remake/proposal.rs b/src/remake/proposal.rs index d9cd893..7695b4c 100644 --- a/src/remake/proposal.rs +++ b/src/remake/proposal.rs @@ -23,7 +23,7 @@ pub(super) fn abortable_at(record: &Record, grace: u64) -> UnixMillis { record .proposal .settle_until - .plus_ms(grace.saturating_mul(2)) + .plus_ms(record.grace(grace).saturating_mul(2)) } /// Why this node may not abort expired `record` now, and the `force` name that would @@ -157,7 +157,7 @@ pub(super) async fn propose<H: Host>( coordinator_active: supersede .active_peers .contains(&record.proposal.coordinator), - since: record.proposal.settle_until.plus_ms(grace), + since: record.proposal.settle_until.plus_ms(record.grace(grace)), abortable_at: abortable_at(record, grace), tally: vote::tally(id, record, &all, ®ister), }) |