diff options
author | elantsev <elantsev@yandex-team.ru> | 2022-02-10 16:49:47 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:49:47 +0300 |
commit | 095c2e55a230f89487c2f2caace05e108742d72c (patch) | |
tree | 5d5cb817648f650d76cf1076100726fd9b8448e8 /library/cpp/coroutine | |
parent | afa1b6e6f8b6ee9f8df080d41bcb19b95c25c261 (diff) | |
download | ydb-095c2e55a230f89487c2f2caace05e108742d72c.tar.gz |
Restoring authorship annotation for <elantsev@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/coroutine')
-rw-r--r-- | library/cpp/coroutine/engine/impl.h | 8 | ||||
-rw-r--r-- | library/cpp/coroutine/engine/poller.cpp | 10 | ||||
-rw-r--r-- | library/cpp/coroutine/listener/listen.cpp | 18 | ||||
-rw-r--r-- | library/cpp/coroutine/listener/listen.h | 28 |
4 files changed, 32 insertions, 32 deletions
diff --git a/library/cpp/coroutine/engine/impl.h b/library/cpp/coroutine/engine/impl.h index 715454d6958..283a96ecf11 100644 --- a/library/cpp/coroutine/engine/impl.h +++ b/library/cpp/coroutine/engine/impl.h @@ -92,9 +92,9 @@ public: } bool Scheduled() const noexcept { - return Scheduled_; - } - + return Scheduled_; + } + bool Join(TCont* c, TInstant deadLine = TInstant::Max()) noexcept; void ReSchedule() noexcept; @@ -116,7 +116,7 @@ private: NCoro::TTrampoline Trampoline_; - TIntrusiveList<TJoinWait> Waiters_; + TIntrusiveList<TJoinWait> Waiters_; bool Cancelled_ = false; bool Scheduled_ = false; }; diff --git a/library/cpp/coroutine/engine/poller.cpp b/library/cpp/coroutine/engine/poller.cpp index 4a8a33e4aff..61164fa56bf 100644 --- a/library/cpp/coroutine/engine/poller.cpp +++ b/library/cpp/coroutine/engine/poller.cpp @@ -82,9 +82,9 @@ namespace { } void Reserve(size_t size) { - E_.Reserve(size); - } - + E_.Reserve(size); + } + void Wait(TEvents& events, TInstant deadLine) { const size_t ret = P_.WaitD(~E_, +E_, deadLine); @@ -220,8 +220,8 @@ namespace { for (TFds::TConstIterator it = S_.Begin(); it != S_.End(); ++it) { t.Set(*it); } - - t.Reserve(Size()); + + t.Reserve(Size()); } void Set(const TChange& c) { diff --git a/library/cpp/coroutine/listener/listen.cpp b/library/cpp/coroutine/listener/listen.cpp index e7b56a33638..3d4e711d1d5 100644 --- a/library/cpp/coroutine/listener/listen.cpp +++ b/library/cpp/coroutine/listener/listen.cpp @@ -65,18 +65,18 @@ private: FixIPv6ListenSocket(ListenSocket_); CheckedSetSockOpt(ListenSocket_, SOL_SOCKET, SO_REUSEADDR, 1, "reuse addr"); - - const TOptions& opts = Parent_->Opts_; - if (opts.SendBufSize) { - SetOutputBuffer(ListenSocket_, opts.SendBufSize); - } - if (opts.RecvBufSize) { - SetInputBuffer(ListenSocket_, opts.RecvBufSize); - } + + const TOptions& opts = Parent_->Opts_; + if (opts.SendBufSize) { + SetOutputBuffer(ListenSocket_, opts.SendBufSize); + } + if (opts.RecvBufSize) { + SetInputBuffer(ListenSocket_, opts.RecvBufSize); + } if (opts.ReusePort) { SetReusePort(ListenSocket_, opts.ReusePort); } - + SetNonBlock(ListenSocket_); if (bind(ListenSocket_, Addr_->Addr(), Addr_->Len()) < 0) { diff --git a/library/cpp/coroutine/listener/listen.h b/library/cpp/coroutine/listener/listen.h index 1c96e9ef4e1..3a89cd3eccc 100644 --- a/library/cpp/coroutine/listener/listen.h +++ b/library/cpp/coroutine/listener/listen.h @@ -17,8 +17,8 @@ public: struct TOptions { inline TOptions() noexcept : ListenQueue(Max<size_t>()) - , SendBufSize(0) - , RecvBufSize(0) + , SendBufSize(0) + , RecvBufSize(0) , EnableDeferAccept(false) , ReusePort(false) { @@ -37,17 +37,17 @@ public: } inline TOptions& SetSendBufSize(unsigned size) noexcept { - SendBufSize = size; - - return *this; - } - + SendBufSize = size; + + return *this; + } + inline TOptions& SetRecvBufSize(unsigned size) noexcept { - RecvBufSize = size; - - return *this; - } - + RecvBufSize = size; + + return *this; + } + inline TOptions& SetReusePort(bool reusePort) noexcept { ReusePort = reusePort; @@ -55,8 +55,8 @@ public: } size_t ListenQueue; - unsigned SendBufSize; - unsigned RecvBufSize; + unsigned SendBufSize; + unsigned RecvBufSize; bool EnableDeferAccept; bool ReusePort; }; |