diff options
Diffstat (limited to 'src/modules.cpp')
| -rw-r--r-- | src/modules.cpp | 22 |
1 files changed, 20 insertions, 2 deletions
diff --git a/src/modules.cpp b/src/modules.cpp index 006802cf5..e29299d5e 100644 --- a/src/modules.cpp +++ b/src/modules.cpp @@ -23,6 +23,11 @@ #include <sys/errno.h> #include <sys/ioctl.h> #include <sys/utsname.h> +#ifdef USE_KQUEUE +#include <sys/types.h> +#include <sys/event.h> +#include <sys/time.h> +#endif #include <cstdio> #include <time.h> #include <string> @@ -61,6 +66,10 @@ using namespace std; +#ifdef USE_KQUEUE +extern int kq; +#endif + extern int MODCOUNT; extern std::vector<Module*> modules; extern std::vector<ircd_module*> factory; @@ -674,8 +683,17 @@ bool Server::UserToPseudo(userrec* user,std::string message) user->fd = FD_MAGIC_NUMBER; user->ClearBuffer(); Write(old_fd,"ERROR :Closing link (%s@%s) [%s]",user->ident,user->host,message.c_str()); - shutdown(old_fd,2); - close(old_fd); +#ifdef USE_KQUEUE + struct kevent ke; + EV_SET(&ke, old_fd, EVFILT_READ, EV_DELETE, 0, 0, NULL); + int i = kevent(kq, &ke, 1, 0, 0, NULL); + if (i == -1) + { + log(DEBUG,"kqueue: Failed to remove user from queue!"); + } +#endif + shutdown(old_fd,2); + close(old_fd); } bool Server::PseudoToUser(userrec* alive,userrec* zombie,std::string message) |