aboutsummaryrefslogtreecommitdiffstats
path: root/library
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
parentddc339a55fe43529cacdde3dd3232df49210a1db (diff)
downloadydb-41efd2a342bf21ed508c248ae2ea9a1d76e8753c.tar.gz
intermediate changes
ref:d0ce1d9d4e9d8b7d3aec4b22f416a01feec11da5
Diffstat (limited to 'library')
-rw-r--r--library/cpp/messagebus/misc/tokenquota.h4
-rw-r--r--library/cpp/monlib/counters/counters.h14
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;
}