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 | 9010440c5d8f8b271fbdd254cfac6a88b0395263 (patch) | |
tree | 7612782abdffb3212b5307c6f7cf635f15694cd0 | |
parent | df35d89845ad252e6db1c6adf84da9b15de0e3b3 (diff) | |
download | ydb-9010440c5d8f8b271fbdd254cfac6a88b0395263.tar.gz |
Restoring authorship annotation for <kozlov-as@yandex-team.ru>. Commit 1 of 2.
-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 283a96ecf1..e3668ea8b6 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 85b647d210..7d5c7d6236 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); } |