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 | |
parent | ddc339a55fe43529cacdde3dd3232df49210a1db (diff) | |
download | ydb-41efd2a342bf21ed508c248ae2ea9a1d76e8753c.tar.gz |
intermediate changes
ref:d0ce1d9d4e9d8b7d3aec4b22f416a01feec11da5
Diffstat (limited to 'library')
-rw-r--r-- | library/cpp/messagebus/misc/tokenquota.h | 4 | ||||
-rw-r--r-- | library/cpp/monlib/counters/counters.h | 14 |
2 files changed, 9 insertions, 9 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; } diff --git a/library/cpp/monlib/counters/counters.h b/library/cpp/monlib/counters/counters.h index 4f5eba4fc3..d3943d6578 100644 --- a/library/cpp/monlib/counters/counters.h +++ b/library/cpp/monlib/counters/counters.h @@ -46,7 +46,7 @@ namespace NMonitoring { { } - TDeprecatedCounter(TValue value, bool derivative = false) + TDeprecatedCounter(TValueBase value, bool derivative = false) : Value(value) , Derivative(derivative) { @@ -63,7 +63,7 @@ namespace NMonitoring { return AtomicGet(Value); } - void Set(TValue val) { + void Set(TValueBase val) { AtomicSet(Value, val); } @@ -74,10 +74,10 @@ namespace NMonitoring { return AtomicDecrement(Value); } - TValueBase Add(const TValue val) { + TValueBase Add(const TValueBase val) { return AtomicAdd(Value, val); } - TValueBase Sub(const TValue val) { + TValueBase Sub(const TValueBase val) { return AtomicAdd(Value, -val); } @@ -96,14 +96,14 @@ namespace NMonitoring { Dec(); } - void operator+=(TValue rhs) { + void operator+=(TValueBase rhs) { Add(rhs); } - void operator-=(TValue rhs) { + void operator-=(TValueBase rhs) { Sub(rhs); } - TValueBase operator=(TValue rhs) { + TValueBase operator=(TValueBase rhs) { AtomicSwap(&Value, rhs); return rhs; } |