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 /util/network/pollerimpl.h | |
| parent | 5b8d95df2f0cfca4d3f5499a4259aa2050ef1571 (diff) | |
Restoring authorship annotation for Arseny Smalyuk <[email protected]>. Commit 1 of 2.
Diffstat (limited to 'util/network/pollerimpl.h')
| -rw-r--r-- | util/network/pollerimpl.h | 28 |
1 files changed, 14 insertions, 14 deletions
diff --git a/util/network/pollerimpl.h b/util/network/pollerimpl.h index e8c7e40fbaf..25ece427017 100644 --- a/util/network/pollerimpl.h +++ b/util/network/pollerimpl.h @@ -36,7 +36,7 @@ enum EContPoll { CONT_POLL_RDHUP = 4, CONT_POLL_ONE_SHOT = 8, // Disable after first event CONT_POLL_MODIFY = 16, // Modify already added event - CONT_POLL_EDGE_TRIGGERED = 32, // Notify only about new events + CONT_POLL_EDGE_TRIGGERED = 32, // Notify only about new events CONT_POLL_BACKLOG_EMPTY = 64, // Backlog is empty (seen end of request, EAGAIN or truncated read) }; @@ -245,10 +245,10 @@ public: e.events |= EPOLLOUT; } - if (what & CONT_POLL_RDHUP) { - e.events |= EPOLLRDHUP; - } - + if (what & CONT_POLL_RDHUP) { + e.events |= EPOLLRDHUP; + } + e.data.ptr = data; if ((what & CONT_POLL_MODIFY) || epoll_ctl(Fd_, EPOLL_CTL_ADD, fd, &e) == -1) { @@ -297,10 +297,10 @@ public: ret |= CONT_POLL_WRITE; } - if (event->events & EPOLLRDHUP) { - ret |= CONT_POLL_RDHUP; - } - + if (event->events & EPOLLRDHUP) { + ret |= CONT_POLL_RDHUP; + } + return ret; } @@ -495,11 +495,11 @@ public: SOCKET* keysToDeleteEnd = keysToDeleteBegin; #if defined(_msan_enabled_) // msan doesn't handle FD_ZERO and cause false positive BALANCER-1347 - memset(in, 0, sizeof(*in)); - memset(out, 0, sizeof(*out)); - memset(errFds, 0, sizeof(*errFds)); + memset(in, 0, sizeof(*in)); + memset(out, 0, sizeof(*out)); + memset(errFds, 0, sizeof(*errFds)); #endif - + FD_ZERO(in); FD_ZERO(out); FD_ZERO(errFds); @@ -669,7 +669,7 @@ public: static inline int ExtractFilter(const TEvent* event) noexcept { if (TBase::ExtractStatus(event)) { - return CONT_POLL_READ | CONT_POLL_WRITE | CONT_POLL_RDHUP; + return CONT_POLL_READ | CONT_POLL_WRITE | CONT_POLL_RDHUP; } return TBase::ExtractFilterImpl(event); |
