aboutsummaryrefslogtreecommitdiffstats
path: root/yt
diff options
context:
space:
mode:
authorcoteeq <coteeq@yandex-team.com>2024-07-12 23:47:05 +0300
committercoteeq <coteeq@yandex-team.com>2024-07-12 23:56:39 +0300
commit473ffd9303aee1ebd2b1087bfd05d0fa08539510 (patch)
tree61891f78600324127aca128f09aa0abac5c52f05 /yt
parent39ad63775e7d65ad1d3c2fc5389e830a94a6c243 (diff)
downloadydb-473ffd9303aee1ebd2b1087bfd05d0fa08539510.tar.gz
Fix unused variable
f04cb979b649ed479feea94f8e8391e4a0512973
Diffstat (limited to 'yt')
-rw-r--r--yt/yt/core/concurrency/throughput_throttler.cpp6
1 files changed, 3 insertions, 3 deletions
diff --git a/yt/yt/core/concurrency/throughput_throttler.cpp b/yt/yt/core/concurrency/throughput_throttler.cpp
index 76ae776a07..588e60c82c 100644
--- a/yt/yt/core/concurrency/throughput_throttler.cpp
+++ b/yt/yt/core/concurrency/throughput_throttler.cpp
@@ -332,7 +332,7 @@ private:
return request->Promise;
}
- static i64 GetDeltaAvailable(TInstant current, TInstant lastUpdated, TDuration period, double limit)
+ static i64 GetDeltaAvailable(TInstant current, TInstant lastUpdated, double limit)
{
auto timePassed = current - lastUpdated;
@@ -375,7 +375,7 @@ private:
Available_ = maxAvailable;
LastUpdated_ = now;
} else {
- auto deltaAvailable = GetDeltaAvailable(now, lastUpdated, period, *limit);
+ auto deltaAvailable = GetDeltaAvailable(now, lastUpdated, *limit);
auto newAvailable = ClampingAdd(Available_.load(), deltaAvailable, maxAvailable);
YT_VERIFY(newAvailable <= maxAvailable);
@@ -423,7 +423,7 @@ private:
auto current = GetInstant();
auto lastUpdated = LastUpdated_.load();
- auto deltaAvailable = GetDeltaAvailable(current, lastUpdated, period, limit);
+ auto deltaAvailable = GetDeltaAvailable(current, lastUpdated, limit);
if (deltaAvailable == 0) {
return;