aboutsummaryrefslogtreecommitdiff
path: root/src/socketengines/kqueue.cpp
diff options
context:
space:
mode:
authorGravatar Sadie Powell2022-10-12 18:38:16 +0100
committerGravatar Sadie Powell2022-10-12 19:34:22 +0100
commita4ec09b455605cb6030ba4c8ae1a6664ad1d7f8d (patch)
tree3189bdb438bd9dc374ba26a5a244878d90636e51 /src/socketengines/kqueue.cpp
parentRemove some unused method arguments. (diff)
Clean up various socket-related code.
Diffstat (limited to 'src/socketengines/kqueue.cpp')
-rw-r--r--src/socketengines/kqueue.cpp8
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;