thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-15 03:53:41 +00:00
Code Issues Packages Projects Releases Wiki Activity

update actual amount of tokens in bucket

Browse Source
This commit is contained in:
serxa 2023-09-18 18:12:55 +00:00
parent 1787803157
commit c5f3170a82
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/IO/Resource/ThrottlerConstraint.h
View File

@ -125,7 +125,9 @@ public:
double getTokens() const
{
return tokens;
auto now = event_queue->now();
double elapsed = std::chrono::nanoseconds(now - last_update).count() / 1e9;
return std::min(tokens + max_speed * elapsed, max_burst);
}
std::chrono::nanoseconds getThrottlingDuration() const