diff options
author | agorodilov <agorodilov@yandex-team.ru> | 2022-02-10 16:47:09 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:47:09 +0300 |
commit | 7a4979e6211c3e78c7f9041d4a9e5d3405343c36 (patch) | |
tree | 9e9943579e5a14679af7cd2cda3c36d8c0b775d3 /library/cpp/coroutine | |
parent | 676340c42e269f3070f194d160f42a83a10568d4 (diff) | |
download | ydb-7a4979e6211c3e78c7f9041d4a9e5d3405343c36.tar.gz |
Restoring authorship annotation for <agorodilov@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/coroutine')
-rw-r--r-- | library/cpp/coroutine/engine/coroutine_ut.cpp | 18 | ||||
-rw-r--r-- | library/cpp/coroutine/engine/poller.cpp | 4 | ||||
-rw-r--r-- | library/cpp/coroutine/engine/sockpool.h | 10 | ||||
-rw-r--r-- | library/cpp/coroutine/listener/listen.cpp | 4 |
4 files changed, 18 insertions, 18 deletions
diff --git a/library/cpp/coroutine/engine/coroutine_ut.cpp b/library/cpp/coroutine/engine/coroutine_ut.cpp index 8b372496a2..7d1705b8f3 100644 --- a/library/cpp/coroutine/engine/coroutine_ut.cpp +++ b/library/cpp/coroutine/engine/coroutine_ut.cpp @@ -139,7 +139,7 @@ static void CoRun(TCont* c, void* /*run*/) { static void CoMain(TCont* c, void* /*arg*/) { for (volatile size_t i2 = 0; i2 < 10; ++i2) { UNIT_ASSERT(RunningCont() == c); - c->Executor()->Create(CoRun, nullptr, "run"); + c->Executor()->Create(CoRun, nullptr, "run"); UNIT_ASSERT(RunningCont() == c); } } @@ -274,8 +274,8 @@ static void CoMutex(TCont* c, void* /*run*/) { } static void CoMutexTest(TCont* c, void* /*run*/) { - c->Executor()->Create(CoMutex, nullptr, "1"); - c->Executor()->Create(CoMutex, nullptr, "2"); + c->Executor()->Create(CoMutex, nullptr, "1"); + c->Executor()->Create(CoMutex, nullptr, "2"); } void TCoroTest::TestMutex() { @@ -298,17 +298,17 @@ static void CoCondVar(TCont* c, void* /*run*/) { } static void CoCondVarTest(TCont* c, void* /*run*/) { - c->Executor()->Create(CoCondVar, nullptr, "1"); + c->Executor()->Create(CoCondVar, nullptr, "1"); c->Yield(); - c->Executor()->Create(CoCondVar, nullptr, "2"); + c->Executor()->Create(CoCondVar, nullptr, "2"); c->Yield(); - c->Executor()->Create(CoCondVar, nullptr, "3"); + c->Executor()->Create(CoCondVar, nullptr, "3"); c->Yield(); - c->Executor()->Create(CoCondVar, nullptr, "4"); + c->Executor()->Create(CoCondVar, nullptr, "4"); c->Yield(); - c->Executor()->Create(CoCondVar, nullptr, "5"); + c->Executor()->Create(CoCondVar, nullptr, "5"); c->Yield(); - c->Executor()->Create(CoCondVar, nullptr, "6"); + c->Executor()->Create(CoCondVar, nullptr, "6"); c->Yield(); for (size_t i5 = 0; i5 < 3; ++i5) { diff --git a/library/cpp/coroutine/engine/poller.cpp b/library/cpp/coroutine/engine/poller.cpp index 61164fa56b..e0b893be11 100644 --- a/library/cpp/coroutine/engine/poller.cpp +++ b/library/cpp/coroutine/engine/poller.cpp @@ -51,11 +51,11 @@ namespace { { } - void Set(const TChange& c) override { + void Set(const TChange& c) override { P_.Set(c); } - void Wait(TEvents& events, TInstant deadLine) override { + void Wait(TEvents& events, TInstant deadLine) override { P_.Wait(events, deadLine); } diff --git a/library/cpp/coroutine/engine/sockpool.h b/library/cpp/coroutine/engine/sockpool.h index 1ebb7e7b38..3365b1a4b6 100644 --- a/library/cpp/coroutine/engine/sockpool.h +++ b/library/cpp/coroutine/engine/sockpool.h @@ -7,7 +7,7 @@ #include <util/network/socket.h> #include <util/system/mutex.h> -extern void SetCommonSockOpts(SOCKET sock, const struct sockaddr* sa = nullptr); +extern void SetCommonSockOpts(SOCKET sock, const struct sockaddr* sa = nullptr); class TSocketPool; @@ -90,7 +90,7 @@ class TPooledSocket { public: TPooledSocket() - : Impl_(nullptr) + : Impl_(nullptr) { } @@ -204,7 +204,7 @@ private: return ret.Release(); } } - return nullptr; + return nullptr; } void Release(TPooledSocket::TImpl* impl) noexcept { @@ -235,11 +235,11 @@ public: { } - void DoWrite(const void* buf, size_t len) override { + void DoWrite(const void* buf, size_t len) override { NCoro::WriteI(Cont_, Fd_, buf, len).Checked(); } - size_t DoRead(void* buf, size_t len) override { + size_t DoRead(void* buf, size_t len) override { return NCoro::ReadI(Cont_, Fd_, buf, len).Checked(); } diff --git a/library/cpp/coroutine/listener/listen.cpp b/library/cpp/coroutine/listener/listen.cpp index 3d4e711d1d..90f8003a85 100644 --- a/library/cpp/coroutine/listener/listen.cpp +++ b/library/cpp/coroutine/listener/listen.cpp @@ -55,7 +55,7 @@ private: public: inline TOneSocketListener(TImpl* parent, IRemoteAddrPtr addr) : Parent_(parent) - , C_(nullptr) + , C_(nullptr) , ListenSocket_(socket(addr->Addr()->sa_family, SOCK_STREAM, 0)) , Addr_(std::move(addr)) { @@ -92,7 +92,7 @@ private: inline void Run(TCont* cont) noexcept { C_ = cont; DoRun(); - C_ = nullptr; + C_ = nullptr; } inline void StartListen() { |