From 07637c8953df2740430780be62b4c03b0e08567d Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Piotr=20Wo=CC=81jcik?= <3044353+pwojcikdev@users.noreply.github.com> Date: Mon, 9 Sep 2024 20:38:43 +0200 Subject: [PATCH] Rename to `rate_limiter` --- nano/node/bandwidth_limiter.cpp | 10 +++++----- nano/node/bandwidth_limiter.hpp | 10 +++++----- nano/node/bootstrap_ascending/service.hpp | 2 +- nano/node/local_block_broadcaster.hpp | 2 +- 4 files changed, 12 insertions(+), 12 deletions(-) diff --git a/nano/node/bandwidth_limiter.cpp b/nano/node/bandwidth_limiter.cpp index 344cb6a12..347fa4b2e 100644 --- a/nano/node/bandwidth_limiter.cpp +++ b/nano/node/bandwidth_limiter.cpp @@ -2,20 +2,20 @@ #include /* - * bandwidth_limiter + * rate_limiter */ -nano::bandwidth_limiter::bandwidth_limiter (std::size_t limit_a, double burst_ratio_a) : +nano::rate_limiter::rate_limiter (std::size_t limit_a, double burst_ratio_a) : bucket (static_cast (limit_a * burst_ratio_a), limit_a) { } -bool nano::bandwidth_limiter::should_pass (std::size_t message_size_a) +bool nano::rate_limiter::should_pass (std::size_t message_size_a) { return bucket.try_consume (nano::narrow_cast (message_size_a)); } -void nano::bandwidth_limiter::reset (std::size_t limit_a, double burst_ratio_a) +void nano::rate_limiter::reset (std::size_t limit_a, double burst_ratio_a) { bucket.reset (static_cast (limit_a * burst_ratio_a), limit_a); } @@ -31,7 +31,7 @@ nano::outbound_bandwidth_limiter::outbound_bandwidth_limiter (nano::outbound_ban { } -nano::bandwidth_limiter & nano::outbound_bandwidth_limiter::select_limiter (nano::bandwidth_limit_type type) +nano::rate_limiter & nano::outbound_bandwidth_limiter::select_limiter (nano::bandwidth_limit_type type) { switch (type) { diff --git a/nano/node/bandwidth_limiter.hpp b/nano/node/bandwidth_limiter.hpp index 5cb13f0eb..edd6c328b 100644 --- a/nano/node/bandwidth_limiter.hpp +++ b/nano/node/bandwidth_limiter.hpp @@ -21,11 +21,11 @@ nano::bandwidth_limit_type to_bandwidth_limit_type (nano::transport::traffic_typ /** * Class that tracks and manages bandwidth limits for IO operations */ -class bandwidth_limiter final +class rate_limiter final { public: // initialize with limit 0 = unbounded - bandwidth_limiter (std::size_t limit, double burst_ratio); + rate_limiter (std::size_t limit, double burst_ratio); bool should_pass (std::size_t buffer_size); void reset (std::size_t limit, double burst_ratio); @@ -64,13 +64,13 @@ private: /** * Returns reference to limiter corresponding to the limit type */ - bandwidth_limiter & select_limiter (bandwidth_limit_type); + nano::rate_limiter & select_limiter (bandwidth_limit_type); private: const config config_m; private: - bandwidth_limiter limiter_standard; - bandwidth_limiter limiter_bootstrap; + nano::rate_limiter limiter_standard; + nano::rate_limiter limiter_bootstrap; }; } \ No newline at end of file diff --git a/nano/node/bootstrap_ascending/service.hpp b/nano/node/bootstrap_ascending/service.hpp index 7506f48b0..d82971998 100644 --- a/nano/node/bootstrap_ascending/service.hpp +++ b/nano/node/bootstrap_ascending/service.hpp @@ -181,7 +181,7 @@ namespace bootstrap_ascending // Requests for accounts from database have much lower hitrate and could introduce strain on the network // A separate (lower) limiter ensures that we always reserve resources for querying accounts from priority queue - nano::bandwidth_limiter database_limiter; + nano::rate_limiter database_limiter; nano::interval sync_dependencies_interval; diff --git a/nano/node/local_block_broadcaster.hpp b/nano/node/local_block_broadcaster.hpp index e86af05a9..47a443acf 100644 --- a/nano/node/local_block_broadcaster.hpp +++ b/nano/node/local_block_broadcaster.hpp @@ -112,7 +112,7 @@ private: private: bool enabled{ false }; - nano::bandwidth_limiter limiter; + nano::rate_limiter limiter; nano::interval cleanup_interval; std::atomic stopped{ false };