aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/messagebus
diff options
context:
space:
mode:
authorarcadia-devtools <arcadia-devtools@yandex-team.ru>2022-06-17 02:25:55 +0300
committerarcadia-devtools <arcadia-devtools@yandex-team.ru>2022-06-17 02:25:55 +0300
commit41efd2a342bf21ed508c248ae2ea9a1d76e8753c (patch)
tree0a4e2dbff32d164060effd5d2712041beadeb710 /library/cpp/messagebus
parentddc339a55fe43529cacdde3dd3232df49210a1db (diff)
downloadydb-41efd2a342bf21ed508c248ae2ea9a1d76e8753c.tar.gz
intermediate changes
ref:d0ce1d9d4e9d8b7d3aec4b22f416a01feec11da5
Diffstat (limited to 'library/cpp/messagebus')
-rw-r--r--library/cpp/messagebus/misc/tokenquota.h4
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;
}