diff options
author | Arseny Smalyuk <[email protected]> | 2022-02-10 16:48:05 +0300 |
---|---|---|
committer | Daniil Cherednik <[email protected]> | 2022-02-10 16:48:05 +0300 |
commit | 12559cd7f2fa0cf54ffb0d961949fea58c0e18cb (patch) | |
tree | 1c6e1bb383ce1ed8ea168386f913410dd55ccb7f /library/cpp/coroutine/engine/poller.cpp | |
parent | 5b8d95df2f0cfca4d3f5499a4259aa2050ef1571 (diff) |
Restoring authorship annotation for Arseny Smalyuk <[email protected]>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/coroutine/engine/poller.cpp')
-rw-r--r-- | library/cpp/coroutine/engine/poller.cpp | 34 |
1 files changed, 17 insertions, 17 deletions
diff --git a/library/cpp/coroutine/engine/poller.cpp b/library/cpp/coroutine/engine/poller.cpp index 61164fa56bf..8aeff4e9659 100644 --- a/library/cpp/coroutine/engine/poller.cpp +++ b/library/cpp/coroutine/engine/poller.cpp @@ -88,8 +88,8 @@ namespace { void Wait(TEvents& events, TInstant deadLine) { const size_t ret = P_.WaitD(~E_, +E_, deadLine); - events.reserve(ret); - + events.reserve(ret); + for (size_t i = 0; i < ret; ++i) { const TInternalEvent* ie = ~E_ + i; @@ -199,12 +199,12 @@ namespace { ret |= POLLOUT; } -#if defined(_linux_) - if (flags & CONT_POLL_RDHUP) { - ret |= POLLRDHUP; - } -#endif - +#if defined(_linux_) + if (flags & CONT_POLL_RDHUP) { + ret |= POLLRDHUP; + } +#endif + return ret; } @@ -248,12 +248,12 @@ namespace { const ssize_t ret = PollD(T_.data(), (nfds_t) T_.size(), deadLine); - if (ret <= 0) { + if (ret <= 0) { return; } events.reserve(T_.size()); - + for (size_t i = 0; i < T_.size(); ++i) { const pollfd& pfd = T_[i]; const short ev = pfd.revents; @@ -274,12 +274,12 @@ namespace { filter |= CONT_POLL_WRITE; } -#if defined(_linux_) - if (ev & POLLRDHUP) { - filter |= CONT_POLL_RDHUP; - } -#endif - +#if defined(_linux_) + if (ev & POLLRDHUP) { + filter |= CONT_POLL_RDHUP; + } +#endif + if (ev & POLLERR) { status = EIO; } else if (ev & POLLHUP && pfd.events & POLLOUT) { @@ -290,7 +290,7 @@ namespace { } if (status) { - filter = CONT_POLL_READ | CONT_POLL_WRITE | CONT_POLL_RDHUP; + filter = CONT_POLL_READ | CONT_POLL_WRITE | CONT_POLL_RDHUP; } const TEvent res = { |