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 | 121d1db3a8c07d3eb450b95e76d1d7eb95d801d3 (patch) | |
| tree | a101b7751255e997cd9750bdb71a88b7bbccfd58 /src/remake/proposal.rs | |
| parent | 1f3be9d059876f7f3994056b1ac8ce307628a52a (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), }) |