aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/coroutine/engine
diff options
context:
space:
mode:
authoryazevnul <yazevnul@yandex-team.ru>2022-02-10 16:46:48 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:46:48 +0300
commit9abfb1a53b7f7b791444d1378e645d8fad9b06ed (patch)
tree49e222ea1c5804306084bb3ae065bb702625360f /library/cpp/coroutine/engine
parent8cbc307de0221f84c80c42dcbe07d40727537e2c (diff)
downloadydb-9abfb1a53b7f7b791444d1378e645d8fad9b06ed.tar.gz
Restoring authorship annotation for <yazevnul@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/coroutine/engine')
-rw-r--r--library/cpp/coroutine/engine/coroutine_ut.cpp2
-rw-r--r--library/cpp/coroutine/engine/events.h2
-rw-r--r--library/cpp/coroutine/engine/impl.cpp2
-rw-r--r--library/cpp/coroutine/engine/impl.h2
-rw-r--r--library/cpp/coroutine/engine/mutex.h4
-rw-r--r--library/cpp/coroutine/engine/poller.cpp2
-rw-r--r--library/cpp/coroutine/engine/sockpool.cpp2
-rw-r--r--library/cpp/coroutine/engine/sockpool.h2
8 files changed, 9 insertions, 9 deletions
diff --git a/library/cpp/coroutine/engine/coroutine_ut.cpp b/library/cpp/coroutine/engine/coroutine_ut.cpp
index 6749f2e076..8b372496a2 100644
--- a/library/cpp/coroutine/engine/coroutine_ut.cpp
+++ b/library/cpp/coroutine/engine/coroutine_ut.cpp
@@ -5,7 +5,7 @@
#include <library/cpp/testing/unittest/registar.h>
#include <util/string/cast.h>
-#include <util/system/pipe.h>
+#include <util/system/pipe.h>
#include <util/system/env.h>
#include <util/system/info.h>
#include <util/system/thread.h>
diff --git a/library/cpp/coroutine/engine/events.h b/library/cpp/coroutine/engine/events.h
index b5a7726343..07cc4d25e8 100644
--- a/library/cpp/coroutine/engine/events.h
+++ b/library/cpp/coroutine/engine/events.h
@@ -69,7 +69,7 @@ public:
}
~TContWaitQueue() {
- Y_ASSERT(Waiters_.Empty());
+ Y_ASSERT(Waiters_.Empty());
}
int WaitD(TCont* current, TInstant deadline) {
diff --git a/library/cpp/coroutine/engine/impl.cpp b/library/cpp/coroutine/engine/impl.cpp
index 5e2d7f6610..7ae6f74051 100644
--- a/library/cpp/coroutine/engine/impl.cpp
+++ b/library/cpp/coroutine/engine/impl.cpp
@@ -34,7 +34,7 @@ TCont::TCont(NCoro::NStack::IAllocator& allocator,
{}
-void TCont::PrintMe(IOutputStream& out) const noexcept {
+void TCont::PrintMe(IOutputStream& out) const noexcept {
out << "cont("
<< "name = " << Name_ << ", "
<< "addr = " << Hex((size_t)this)
diff --git a/library/cpp/coroutine/engine/impl.h b/library/cpp/coroutine/engine/impl.h
index d0041bf789..283a96ecf1 100644
--- a/library/cpp/coroutine/engine/impl.h
+++ b/library/cpp/coroutine/engine/impl.h
@@ -66,7 +66,7 @@ public:
return Name_;
}
- void PrintMe(IOutputStream& out) const noexcept;
+ void PrintMe(IOutputStream& out) const noexcept;
void Yield() noexcept;
diff --git a/library/cpp/coroutine/engine/mutex.h b/library/cpp/coroutine/engine/mutex.h
index 252d281c98..93e9119503 100644
--- a/library/cpp/coroutine/engine/mutex.h
+++ b/library/cpp/coroutine/engine/mutex.h
@@ -11,7 +11,7 @@ public:
}
~TContMutex() {
- Y_ASSERT(Token_);
+ Y_ASSERT(Token_);
}
int LockD(TCont* current, TInstant deadline) {
@@ -37,7 +37,7 @@ public:
}
void UnLock() noexcept {
- Y_ASSERT(!Token_);
+ Y_ASSERT(!Token_);
Token_ = true;
WaitQueue_.Signal();
diff --git a/library/cpp/coroutine/engine/poller.cpp b/library/cpp/coroutine/engine/poller.cpp
index cba6ae0c79..61164fa56b 100644
--- a/library/cpp/coroutine/engine/poller.cpp
+++ b/library/cpp/coroutine/engine/poller.cpp
@@ -162,7 +162,7 @@ namespace {
T* Get(size_t i) {
TValRef& v = V_.Get(i);
- if (Y_UNLIKELY(!v)) {
+ if (Y_UNLIKELY(!v)) {
v.Reset(new (&P_) TVal());
I_.PushFront(v.Get());
}
diff --git a/library/cpp/coroutine/engine/sockpool.cpp b/library/cpp/coroutine/engine/sockpool.cpp
index 8a61b19bcd..b9482e780f 100644
--- a/library/cpp/coroutine/engine/sockpool.cpp
+++ b/library/cpp/coroutine/engine/sockpool.cpp
@@ -21,7 +21,7 @@ void SetCommonSockOpts(SOCKET sock, const struct sockaddr* sa) {
warn("bind6");
}
} else {
- Y_ASSERT(0);
+ Y_ASSERT(0);
}
SetNoDelay(sock, true);
diff --git a/library/cpp/coroutine/engine/sockpool.h b/library/cpp/coroutine/engine/sockpool.h
index c58455d6f5..1ebb7e7b38 100644
--- a/library/cpp/coroutine/engine/sockpool.h
+++ b/library/cpp/coroutine/engine/sockpool.h
@@ -227,7 +227,7 @@ inline void TPooledSocket::TImpl::ReturnToPool() noexcept {
}
-class TContIO: public IInputStream, public IOutputStream {
+class TContIO: public IInputStream, public IOutputStream {
public:
TContIO(SOCKET fd, TCont* cont)
: Fd_(fd)