diff options
author | arcadia-devtools <arcadia-devtools@yandex-team.ru> | 2022-06-17 02:25:55 +0300 |
---|---|---|
committer | arcadia-devtools <arcadia-devtools@yandex-team.ru> | 2022-06-17 02:25:55 +0300 |
commit | 41efd2a342bf21ed508c248ae2ea9a1d76e8753c (patch) | |
tree | 0a4e2dbff32d164060effd5d2712041beadeb710 /library/cpp/messagebus | |
parent | ddc339a55fe43529cacdde3dd3232df49210a1db (diff) | |
download | ydb-41efd2a342bf21ed508c248ae2ea9a1d76e8753c.tar.gz |
intermediate changes
ref:d0ce1d9d4e9d8b7d3aec4b22f416a01feec11da5
Diffstat (limited to 'library/cpp/messagebus')
-rw-r--r-- | library/cpp/messagebus/misc/tokenquota.h | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/library/cpp/messagebus/misc/tokenquota.h b/library/cpp/messagebus/misc/tokenquota.h index f4ca8873c1..5a3161ae9c 100644 --- a/library/cpp/messagebus/misc/tokenquota.h +++ b/library/cpp/messagebus/misc/tokenquota.h @@ -25,7 +25,7 @@ namespace NBus { Y_UNUSED(padd_); } - bool Acquire(TAtomic level = 1, bool force = false) { + bool Acquire(TAtomicBase level = 1, bool force = false) { level = Max(TAtomicBase(level), TAtomicBase(1)); if (Enabled && (Acquired < level || force)) { @@ -65,7 +65,7 @@ namespace NBus { return Acquired + AtomicGet(Tokens_); } - size_t Check(const TAtomic level) const noexcept { + size_t Check(const TAtomicBase level) const noexcept { return !Enabled || level <= Acquired; } |