#include <grpc/support/port_platform.h>
#include "src/core/lib/backoff/backoff.h"
#include <algorithm>
namespace grpc_core {
BackOff::BackOff(const Options& options) : options_(options) { Reset(); }
Timestamp BackOff::NextAttemptTime() {
if (initial_) {
initial_ = false;
return current_backoff_ + Timestamp::Now();
}
current_backoff_ = std::min(current_backoff_ * options_.multiplier(),
options_.max_backoff());
const Duration jitter = Duration::FromSecondsAsDouble(
absl::Uniform(rand_gen_, -options_.jitter() * current_backoff_.seconds(),
options_.jitter() * current_backoff_.seconds()));
return Timestamp::Now() + current_backoff_ + jitter;
}
void BackOff::Reset() {
current_backoff_ = options_.initial_backoff();
initial_ = true;
}
}