summaryrefslogtreecommitdiffstats
path: root/util/network/pollerimpl.h
diff options
context:
space:
mode:
authorleo <[email protected]>2022-02-10 16:46:40 +0300
committerDaniil Cherednik <[email protected]>2022-02-10 16:46:40 +0300
commit99609724f661f7e21d1cb08e8d80e87c3632fdb3 (patch)
tree49e222ea1c5804306084bb3ae065bb702625360f /util/network/pollerimpl.h
parent980edcd3304699edf9d4e4d6a656e585028e2a72 (diff)
Restoring authorship annotation for <[email protected]>. Commit 2 of 2.
Diffstat (limited to 'util/network/pollerimpl.h')
-rw-r--r--util/network/pollerimpl.h10
1 files changed, 5 insertions, 5 deletions
diff --git a/util/network/pollerimpl.h b/util/network/pollerimpl.h
index a9e8dffe9d9..e8c7e40fbaf 100644
--- a/util/network/pollerimpl.h
+++ b/util/network/pollerimpl.h
@@ -360,7 +360,7 @@ struct TSelectPollerNoTemplate {
(*this)[fd].Set(data, filter);
}
- inline void Remove(SOCKET fd) {
+ inline void Remove(SOCKET fd) {
erase(fd);
}
@@ -424,7 +424,7 @@ public:
closesocket(Signal_[1]);
}
- inline void SetImpl(void* data, SOCKET fd, int what) {
+ inline void SetImpl(void* data, SOCKET fd, int what) {
with_lock (CommandLock_) {
Commands_.push_back(TCommand(fd, what, data));
}
@@ -512,7 +512,7 @@ public:
tout.tv_sec = timeout / 1000000;
tout.tv_usec = timeout % 1000000;
- int ret = ContSelect(int(maxFdNum + 1), in, out, errFds, &tout);
+ int ret = ContSelect(int(maxFdNum + 1), in, out, errFds, &tout);
if (ret > 0 && FD_ISSET(WaitSock(), in)) {
--ret;
@@ -524,7 +524,7 @@ public:
TEvent* eventsStart = events;
for (typename TFds::iterator it = Fds_.begin(); it != Fds_.end(); ++it) {
- const SOCKET fd = it->first;
+ const SOCKET fd = it->first;
THandle& handle = it->second;
if (FD_ISSET(fd, errFds)) {
@@ -659,7 +659,7 @@ public:
using TEvent = typename TBase::TEvent;
- inline void Set(void* data, SOCKET fd, int what) {
+ inline void Set(void* data, SOCKET fd, int what) {
if (what) {
this->SetImpl(data, fd, what);
} else {