summaryrefslogtreecommitdiffstats
path: root/library/cpp/coroutine/engine/poller.cpp
diff options
context:
space:
mode:
authorArseny Smalyuk <[email protected]>2022-02-10 16:48:05 +0300
committerDaniil Cherednik <[email protected]>2022-02-10 16:48:05 +0300
commit12559cd7f2fa0cf54ffb0d961949fea58c0e18cb (patch)
tree1c6e1bb383ce1ed8ea168386f913410dd55ccb7f /library/cpp/coroutine/engine/poller.cpp
parent5b8d95df2f0cfca4d3f5499a4259aa2050ef1571 (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.cpp34
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 = {