pegasus/unrealircd
1
0
Fork 0
mirror of https://github.com/unrealircd/unrealircd.git synced 2026-06-29 23:36:38 +02:00
Code Activity

- fdlist: do not update the backend if it is not actively tracking an FD

Browse Source
This commit is contained in:
William Pitcock
2013-05-25 00:30:38 +00:00
parent 349259eecb
commit bdf6ecf552
2 changed files with 16 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/fdlist.c
+4 -1
View File
@@ -113,7 +113,10 @@ void fd_close(int fd)
memset(fde, 0, sizeof(FDEntry));
fde->fd = fd;
fd_refresh(fd);
/* only notify the backend if it is actively tracking the FD */
if (fde->backend_flags)
fd_refresh(fd);
CLOSE_SOCK(fd);
}
src/s_dispatch.c
+12
View File
@@ -140,6 +140,8 @@ void fd_refresh(int fd)
while (highest_fd > 0 &&
!(FD_ISSET(highest_fd, &read_fds) || FD_ISSET(highest_fd, &write_fds)))
highest_fd--;
fde->backend_flags = flags;
}
void fd_select(time_t delay)
@@ -236,6 +238,8 @@ void fd_refresh(int fd)
if (kqueue_fd == -1)
kqueue_fd = kqueue();
fde->backend_flags = 0;
EV_SET(&ev, (uintptr_t) fd, (short) EVFILT_READ, fde->read_callback != NULL ? EV_ADD : EV_DELETE, 0, 0, fde);
if (kevent(kqueue_fd, &ev, 1, NULL, 0, &(const struct timespec){ .tv_sec = 0, .tv_nsec = 0}) != 0)
{
@@ -255,6 +259,12 @@ void fd_refresh(int fd)
ircd_log(LOG_ERROR, "[BUG?] kevent returned %d", errno);
return;
}
if (fde->read_callback != NULL)
fde->backend_flags |= EVFILT_READ;
if (fde->write_callback != NULL)
fde->backend_flags |= EVFILT_WRITE;
}
void fd_select(time_t delay)
@@ -466,6 +476,8 @@ void fd_refresh(int fd)
while (nfds > 0 && pollfds[nfds].fd == -1)
nfds--;
fde->backend_flags = pflags;
}
void fd_select(time_t delay)