aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/coroutine/engine
diff options
context:
space:
mode:
authorkozlov-as <kozlov-as@yandex-team.ru>2022-02-10 16:50:08 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:50:08 +0300
commitbebbbda5c5ff4ec70d301ac897eb8d6c8da7a9a4 (patch)
tree5d5cb817648f650d76cf1076100726fd9b8448e8 /library/cpp/coroutine/engine
parent9010440c5d8f8b271fbdd254cfac6a88b0395263 (diff)
downloadydb-bebbbda5c5ff4ec70d301ac897eb8d6c8da7a9a4.tar.gz
Restoring authorship annotation for <kozlov-as@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/coroutine/engine')
-rw-r--r--library/cpp/coroutine/engine/impl.h4
-rw-r--r--library/cpp/coroutine/engine/network.cpp8
2 files changed, 6 insertions, 6 deletions
diff --git a/library/cpp/coroutine/engine/impl.h b/library/cpp/coroutine/engine/impl.h
index e3668ea8b6..283a96ecf1 100644
--- a/library/cpp/coroutine/engine/impl.h
+++ b/library/cpp/coroutine/engine/impl.h
@@ -84,9 +84,9 @@ public:
}
bool IAmRunning() const noexcept;
-
+
void Cancel() noexcept;
-
+
bool Cancelled() const noexcept {
return Cancelled_;
}
diff --git a/library/cpp/coroutine/engine/network.cpp b/library/cpp/coroutine/engine/network.cpp
index 7d5c7d6236..85b647d210 100644
--- a/library/cpp/coroutine/engine/network.cpp
+++ b/library/cpp/coroutine/engine/network.cpp
@@ -112,11 +112,11 @@ namespace NCoro {
TContIOStatus ReadVectorD(TCont* cont, SOCKET fd, TContIOVector* vec, TInstant deadline) noexcept {
while (true) {
ssize_t res = DoReadVector(fd, vec);
-
+
if (res >= 0) {
return TContIOStatus::Success((size_t) res);
- }
-
+ }
+
{
const int err = LastSystemError();
@@ -215,7 +215,7 @@ namespace NCoro {
}
const int ret = ConnectD(cont, res, ai.ai_addr, (socklen_t) ai.ai_addrlen, deadline);
-
+
if (!ret) {
s.Swap(res);
}