aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/messagebus/misc
diff options
context:
space:
mode:
authoryazevnul <yazevnul@yandex-team.ru>2022-02-10 16:46:46 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:46:46 +0300
commit8cbc307de0221f84c80c42dcbe07d40727537e2c (patch)
tree625d5a673015d1df891e051033e9fcde5c7be4e5 /library/cpp/messagebus/misc
parent30d1ef3941e0dc835be7609de5ebee66958f215a (diff)
downloadydb-8cbc307de0221f84c80c42dcbe07d40727537e2c.tar.gz
Restoring authorship annotation for <yazevnul@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/messagebus/misc')
-rw-r--r--library/cpp/messagebus/misc/test_sync.h10
-rw-r--r--library/cpp/messagebus/misc/tokenquota.h4
-rw-r--r--library/cpp/messagebus/misc/weak_ptr.h4
-rw-r--r--library/cpp/messagebus/misc/weak_ptr_ut.cpp4
4 files changed, 11 insertions, 11 deletions
diff --git a/library/cpp/messagebus/misc/test_sync.h b/library/cpp/messagebus/misc/test_sync.h
index be3f4f20b8..a74b5d6f3b 100644
--- a/library/cpp/messagebus/misc/test_sync.h
+++ b/library/cpp/messagebus/misc/test_sync.h
@@ -32,7 +32,7 @@ public:
void WaitFor(unsigned n) {
TGuard<TMutex> guard(Mutex);
- Y_VERIFY(Current <= n, "too late, waiting for %d, already %d", n, Current);
+ Y_VERIFY(Current <= n, "too late, waiting for %d, already %d", n, Current);
while (n > Current) {
CondVar.WaitI(Mutex);
@@ -42,7 +42,7 @@ public:
void WaitForAndIncrement(unsigned n) {
TGuard<TMutex> guard(Mutex);
- Y_VERIFY(Current <= n, "too late, waiting for %d, already %d", n, Current);
+ Y_VERIFY(Current <= n, "too late, waiting for %d, already %d", n, Current);
while (n > Current) {
CondVar.WaitI(Mutex);
@@ -55,7 +55,7 @@ public:
void CheckAndIncrement(unsigned n) {
TGuard<TMutex> guard(Mutex);
- Y_VERIFY(Current == n, "must be %d, currently %d", n, Current);
+ Y_VERIFY(Current == n, "must be %d, currently %d", n, Current);
DoInc();
CondVar.BroadCast();
@@ -64,12 +64,12 @@ public:
void Check(unsigned n) {
TGuard<TMutex> guard(Mutex);
- Y_VERIFY(Current == n, "must be %d, currently %d", n, Current);
+ Y_VERIFY(Current == n, "must be %d, currently %d", n, Current);
}
private:
void DoInc() {
unsigned r = ++Current;
- Y_UNUSED(r);
+ Y_UNUSED(r);
}
};
diff --git a/library/cpp/messagebus/misc/tokenquota.h b/library/cpp/messagebus/misc/tokenquota.h
index 190547fa54..96b5f7c4b9 100644
--- a/library/cpp/messagebus/misc/tokenquota.h
+++ b/library/cpp/messagebus/misc/tokenquota.h
@@ -22,7 +22,7 @@ namespace NBus {
, WakeLev(wake < 1 ? Max<size_t>(1, tokens / 2) : 0)
, Tokens_(tokens)
{
- Y_UNUSED(padd_);
+ Y_UNUSED(padd_);
}
bool Acquire(TAtomic level = 1, bool force = false) {
@@ -37,7 +37,7 @@ namespace NBus {
void Consume(size_t items) {
if (Enabled) {
- Y_ASSERT(Acquired >= TAtomicBase(items));
+ Y_ASSERT(Acquired >= TAtomicBase(items));
Acquired -= items;
}
diff --git a/library/cpp/messagebus/misc/weak_ptr.h b/library/cpp/messagebus/misc/weak_ptr.h
index 70fdeb0e2a..20afeafa88 100644
--- a/library/cpp/messagebus/misc/weak_ptr.h
+++ b/library/cpp/messagebus/misc/weak_ptr.h
@@ -23,13 +23,13 @@ private:
void Release() {
TGuard<TMutex> g(Mutex);
- Y_ASSERT(!!Outer);
+ Y_ASSERT(!!Outer);
Outer = nullptr;
}
TIntrusivePtr<TSelf> Get() {
TGuard<TMutex> g(Mutex);
- Y_ASSERT(!Outer || Outer->RefCount() > 0);
+ Y_ASSERT(!Outer || Outer->RefCount() > 0);
return Outer;
}
};
diff --git a/library/cpp/messagebus/misc/weak_ptr_ut.cpp b/library/cpp/messagebus/misc/weak_ptr_ut.cpp
index 5a325278db..b499ca7b1d 100644
--- a/library/cpp/messagebus/misc/weak_ptr_ut.cpp
+++ b/library/cpp/messagebus/misc/weak_ptr_ut.cpp
@@ -2,7 +2,7 @@
#include "weak_ptr.h"
-Y_UNIT_TEST_SUITE(TWeakPtrTest) {
+Y_UNIT_TEST_SUITE(TWeakPtrTest) {
struct TWeakPtrTester: public TWeakRefCounted<TWeakPtrTester> {
int* const CounterPtr;
@@ -15,7 +15,7 @@ Y_UNIT_TEST_SUITE(TWeakPtrTest) {
}
};
- Y_UNIT_TEST(Simple) {
+ Y_UNIT_TEST(Simple) {
int destroyCount = 0;
TIntrusivePtr<TWeakPtrTester> p(new TWeakPtrTester(&destroyCount));