diff options
| author | leo <[email protected]> | 2022-02-10 16:46:40 +0300 |
|---|---|---|
| committer | Daniil Cherednik <[email protected]> | 2022-02-10 16:46:40 +0300 |
| commit | 99609724f661f7e21d1cb08e8d80e87c3632fdb3 (patch) | |
| tree | 49e222ea1c5804306084bb3ae065bb702625360f /util/network/pollerimpl.h | |
| parent | 980edcd3304699edf9d4e4d6a656e585028e2a72 (diff) | |
Restoring authorship annotation for <[email protected]>. Commit 2 of 2.
Diffstat (limited to 'util/network/pollerimpl.h')
| -rw-r--r-- | util/network/pollerimpl.h | 10 |
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 { |
