aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/coroutine/engine
diff options
context:
space:
mode:
authortobo <tobo@yandex-team.ru>2022-02-10 16:47:27 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:47:27 +0300
commit7fe839092527589b38f014d854c51565b3c1adfa (patch)
tree309e97022d3530044b712b8f71318c78faf7856e /library/cpp/coroutine/engine
parentd0d68c395c10da4cb56a1c845504570a04d7893e (diff)
downloadydb-7fe839092527589b38f014d854c51565b3c1adfa.tar.gz
Restoring authorship annotation for <tobo@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/coroutine/engine')
-rw-r--r--library/cpp/coroutine/engine/poller.cpp2
-rw-r--r--library/cpp/coroutine/engine/sockpool.cpp4
-rw-r--r--library/cpp/coroutine/engine/stack/stack_guards.h2
3 files changed, 4 insertions, 4 deletions
diff --git a/library/cpp/coroutine/engine/poller.cpp b/library/cpp/coroutine/engine/poller.cpp
index 61164fa56b..e2dc336cbb 100644
--- a/library/cpp/coroutine/engine/poller.cpp
+++ b/library/cpp/coroutine/engine/poller.cpp
@@ -188,7 +188,7 @@ namespace {
};
- inline short PollFlags(ui16 flags) noexcept {
+ inline short PollFlags(ui16 flags) noexcept {
short ret = 0;
if (flags & CONT_POLL_READ) {
diff --git a/library/cpp/coroutine/engine/sockpool.cpp b/library/cpp/coroutine/engine/sockpool.cpp
index b9482e780f..a7ae874b22 100644
--- a/library/cpp/coroutine/engine/sockpool.cpp
+++ b/library/cpp/coroutine/engine/sockpool.cpp
@@ -34,7 +34,7 @@ TPooledSocket TSocketPool::AllocateMore(TConnectData* conn) {
TSocketHolder s(NCoro::Socket(Addr_->Addr()->sa_family, SOCK_STREAM, 0));
if (s == INVALID_SOCKET) {
- ythrow TSystemError(errno) << TStringBuf("can not create socket");
+ ythrow TSystemError(errno) << TStringBuf("can not create socket");
}
SetCommonSockOpts(s, Addr_->Addr());
@@ -45,7 +45,7 @@ TPooledSocket TSocketPool::AllocateMore(TConnectData* conn) {
if (ret == EINTR) {
continue;
} else if (ret) {
- ythrow TSystemError(ret) << TStringBuf("can not connect(") << cont->Name() << ')';
+ ythrow TSystemError(ret) << TStringBuf("can not connect(") << cont->Name() << ')';
}
THolder<TPooledSocket::TImpl> res(new TPooledSocket::TImpl(s, this));
diff --git a/library/cpp/coroutine/engine/stack/stack_guards.h b/library/cpp/coroutine/engine/stack/stack_guards.h
index 3a7ef26481..d2b5c9487d 100644
--- a/library/cpp/coroutine/engine/stack/stack_guards.h
+++ b/library/cpp/coroutine/engine/stack/stack_guards.h
@@ -69,7 +69,7 @@ namespace NCoro::NStack {
}
private:
- static constexpr TStringBuf Canary = "[ThisIsACanaryCoroutineStackGuardIfYouReadThisTheStackIsStillOK]";
+ static constexpr TStringBuf Canary = "[ThisIsACanaryCoroutineStackGuardIfYouReadThisTheStackIsStillOK]";
static_assert(Canary.size() == 64);
static constexpr uint64_t AlignedSize_ = (Canary.size() + PageSize - 1) & ~PageSizeMask;
};