diff options
author | kozlov-as <kozlov-as@yandex-team.ru> | 2022-02-10 16:50:08 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:50:08 +0300 |
commit | bebbbda5c5ff4ec70d301ac897eb8d6c8da7a9a4 (patch) | |
tree | 5d5cb817648f650d76cf1076100726fd9b8448e8 /library/cpp/coroutine/engine | |
parent | 9010440c5d8f8b271fbdd254cfac6a88b0395263 (diff) | |
download | ydb-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.h | 4 | ||||
-rw-r--r-- | library/cpp/coroutine/engine/network.cpp | 8 |
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); } |