diff options
| author | prout <[email protected]> | 2022-02-10 16:49:42 +0300 |
|---|---|---|
| committer | Daniil Cherednik <[email protected]> | 2022-02-10 16:49:42 +0300 |
| commit | 7b7fa28b9099b7adca890459a699c6ba5eeff4ca (patch) | |
| tree | cffe238e08f715008f864d223dd0db8fc1f92f9f /util/network/pollerimpl.h | |
| parent | 0fd1998e1b2369f50fb694556f817d3c7fef10c8 (diff) | |
Restoring authorship annotation for <[email protected]>. Commit 1 of 2.
Diffstat (limited to 'util/network/pollerimpl.h')
| -rw-r--r-- | util/network/pollerimpl.h | 56 |
1 files changed, 28 insertions, 28 deletions
diff --git a/util/network/pollerimpl.h b/util/network/pollerimpl.h index e8c7e40fbaf..7bc6900289c 100644 --- a/util/network/pollerimpl.h +++ b/util/network/pollerimpl.h @@ -160,29 +160,29 @@ public: } static inline int ExtractStatus(const TEvent* event) noexcept { - if (event->flags & EV_ERROR) { - return EIO; - } - + if (event->flags & EV_ERROR) { + return EIO; + } + return event->fflags; } static inline int ExtractFilterImpl(const TEvent* event) noexcept { if (event->filter == EVFILT_READ) { - return CONT_POLL_READ; - } - - if (event->filter == EVFILT_WRITE) { - return CONT_POLL_WRITE; - } + return CONT_POLL_READ; + } + if (event->filter == EVFILT_WRITE) { + return CONT_POLL_WRITE; + } + if (event->flags & EV_EOF) { return CONT_POLL_READ | CONT_POLL_WRITE; } - return 0; - } - + return 0; + } + private: int Fd_; }; @@ -287,23 +287,23 @@ public: } static inline int ExtractFilterImpl(const TEvent* event) noexcept { - int ret = 0; - - if (event->events & EPOLLIN) { - ret |= CONT_POLL_READ; - } - - if (event->events & EPOLLOUT) { - ret |= CONT_POLL_WRITE; - } - + int ret = 0; + + if (event->events & EPOLLIN) { + ret |= CONT_POLL_READ; + } + + if (event->events & EPOLLOUT) { + ret |= CONT_POLL_WRITE; + } + if (event->events & EPOLLRDHUP) { ret |= CONT_POLL_RDHUP; } - return ret; - } - + return ret; + } + private: int Fd_; }; @@ -585,8 +585,8 @@ public: static inline int ExtractFilterImpl(const TEvent* event) noexcept { return event->Filter(); - } - + } + private: inline void Signal() noexcept { char ch = 13; |
