// Copyright 2020-2026 The Jujutsu Authors // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. // You may obtain a copy of the License at // // https://www.apache.org/licenses/LICENSE-2.0 // // Unless required by applicable law or agreed to in writing, software // distributed under the License is distributed on an "AS IS" BASIS, // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. // See the License for the specific language governing permissions and // limitations under the License. use std::time::Duration; pub struct BackoffIterator { next_sleep_secs: f32, elapsed_secs: f32, } impl BackoffIterator { #[cfg_attr(unix, expect(dead_code))] pub fn new() -> Self { Self { next_sleep_secs: 0.001, elapsed_secs: 0.0, } } } impl Iterator for BackoffIterator { type Item = Duration; fn next(&mut self) -> Option { if self.elapsed_secs >= 10.0 { None } else { let current_sleep = self.next_sleep_secs * (rand::random::() + 0.5); self.next_sleep_secs *= 1.5; self.elapsed_secs += current_sleep; Some(Duration::from_secs_f32(current_sleep)) } } }