aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/coroutine
diff options
context:
space:
mode:
authorelantsev <elantsev@yandex-team.ru>2022-02-10 16:49:47 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:49:47 +0300
commit095c2e55a230f89487c2f2caace05e108742d72c (patch)
tree5d5cb817648f650d76cf1076100726fd9b8448e8 /library/cpp/coroutine
parentafa1b6e6f8b6ee9f8df080d41bcb19b95c25c261 (diff)
downloadydb-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.h8
-rw-r--r--library/cpp/coroutine/engine/poller.cpp10
-rw-r--r--library/cpp/coroutine/listener/listen.cpp18
-rw-r--r--library/cpp/coroutine/listener/listen.h28
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;
};