From bebbbda5c5ff4ec70d301ac897eb8d6c8da7a9a4 Mon Sep 17 00:00:00 2001 From: kozlov-as Date: Thu, 10 Feb 2022 16:50:08 +0300 Subject: Restoring authorship annotation for . Commit 2 of 2. --- library/cpp/coroutine/engine/impl.h | 4 ++-- library/cpp/coroutine/engine/network.cpp | 8 ++++---- 2 files changed, 6 insertions(+), 6 deletions(-) (limited to 'library/cpp/coroutine') diff --git a/library/cpp/coroutine/engine/impl.h b/library/cpp/coroutine/engine/impl.h index e3668ea8b61..283a96ecf11 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 7d5c7d6236d..85b647d2105 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); } -- cgit v1.3