summaryrefslogtreecommitdiffstats
path: root/util/network/pollerimpl.h
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 /util/network/pollerimpl.h
parent5b8d95df2f0cfca4d3f5499a4259aa2050ef1571 (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.h28
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);