diff options
| author | 2022-10-12 18:38:16 +0100 | |
|---|---|---|
| committer | 2022-10-12 19:34:22 +0100 | |
| commit | a4ec09b455605cb6030ba4c8ae1a6664ad1d7f8d (patch) | |
| tree | 3189bdb438bd9dc374ba26a5a244878d90636e51 /src/socketengines/kqueue.cpp | |
| parent | Remove some unused method arguments. (diff) | |
Clean up various socket-related code.
Diffstat (limited to 'src/socketengines/kqueue.cpp')
| -rw-r--r-- | src/socketengines/kqueue.cpp | 8 |
1 files changed, 3 insertions, 5 deletions
diff --git a/src/socketengines/kqueue.cpp b/src/socketengines/kqueue.cpp index 2114e9652..bfef2a91a 100644 --- a/src/socketengines/kqueue.cpp +++ b/src/socketengines/kqueue.cpp @@ -96,15 +96,14 @@ static struct kevent* GetChangeKE() bool SocketEngine::AddFd(EventHandler* eh, int event_mask) { - int fd = eh->GetFd(); - - if (fd < 0) + if (!eh->HasFd()) return false; if (!SocketEngine::AddFdRef(eh)) return false; // We always want to read from the socket... + int fd = eh->GetFd(); struct kevent* ke = GetChangeKE(); EV_SET(ke, fd, EVFILT_READ, EV_ADD, 0, 0, udata_cast(eh)); @@ -120,8 +119,7 @@ bool SocketEngine::AddFd(EventHandler* eh, int event_mask) void SocketEngine::DelFd(EventHandler* eh) { int fd = eh->GetFd(); - - if (fd < 0) + if (!eh->HasFd()) { ServerInstance->Logs.Normal("SOCKET", "DelFd() on invalid fd: %d", fd); return; |
