1 /* +------------------------------------+
2 * | Inspire Internet Relay Chat Daemon |
3 * +------------------------------------+
5 * Inspire is copyright (C) 2002-2005 ChatSpike-Dev.
7 * <brain@chatspike.net>
8 * <Craig@chatspike.net>
10 * Written by Craig Edwards, Craig McLure, and others.
11 * This program is free but copyrighted software; see
12 * the file COPYING for details.
14 * ---------------------------------------------------
17 #include "inspircd_config.h"
21 #include <sys/epoll.h>
25 #include <sys/types.h>
26 #include <sys/event.h>
31 #include "socketengine.h"
35 SocketEngine::SocketEngine()
37 log(DEBUG,"SocketEngine::SocketEngine()");
39 EngineHandle = epoll_create(65535);
42 EngineHandle = kqueue();
46 SocketEngine::~SocketEngine()
48 log(DEBUG,"SocketEngine::~SocketEngine()");
57 char SocketEngine::GetType(int fd)
59 if ((fd < 0) || (fd > 65535))
61 /* Mask off the top bit used for 'read/write' state */
62 return (ref[fd] & ~0x80);
65 bool SocketEngine::AddFd(int fd, bool readable, char type)
67 if ((fd < 0) || (fd > 65535))
69 this->fds.push_back(fd);
73 log(DEBUG,"Set readbit");
76 log(DEBUG,"Add socket %d",fd);
78 struct epoll_event ev;
79 log(DEBUG,"epoll: Add socket to events, ep=%d socket=%d",EngineHandle,fd);
80 readable ? ev.events = EPOLLIN | EPOLLET : ev.events = EPOLLOUT | EPOLLET;
82 int i = epoll_ctl(EngineHandle, EPOLL_CTL_ADD, fd, &ev);
85 log(DEBUG,"epoll: List insertion failure!");
91 log(DEBUG,"kqueue: Add socket to events, kq=%d socket=%d",EngineHandle,fd);
92 EV_SET(&ke, fd, readable ? EVFILT_READ : EVFILT_WRITE, EV_ADD, 0, 0, NULL);
93 int i = kevent(EngineHandle, &ke, 1, 0, 0, NULL);
96 log(DEBUG,"kqueue: List insertion failure!");
103 bool SocketEngine::DelFd(int fd)
105 log(DEBUG,"SocketEngine::DelFd(%d)",fd);
107 if ((fd < 0) || (fd > 65535))
111 for (std::vector<int>::iterator i = fds.begin(); i != fds.end(); i++)
116 log(DEBUG,"Deleted fd %d",fd);
123 EV_SET(&ke, fd, ref[fd] && X_READBIT ? EVFILT_READ : EVFILT_WRITE, EV_DELETE, 0, 0, NULL);
124 int i = kevent(EngineHandle, &ke, 1, 0, 0, NULL);
127 log(DEBUG,"kqueue: Failed to remove socket from queue!");
132 struct epoll_event ev;
133 ref[fd] && X_READBIT ? ev.events = EPOLLIN | EPOLLET : ev.events = EPOLLOUT | EPOLLET;
135 int i = epoll_ctl(EngineHandle, EPOLL_CTL_DEL, fd, &ev);
138 log(DEBUG,"epoll: List deletion failure!");
146 bool SocketEngine::Wait(std::vector<int> &fdlist)
154 for (unsigned int a = 0; a < fds.size(); a++)
156 if (ref[fds[a]] & X_READBIT)
158 FD_SET (fds[a], &rfdset);
162 FD_SET (fds[a], &wfdset);
168 sresult = select(FD_SETSIZE, &rfdset, &wfdset, NULL, &tval);
171 for (unsigned int a = 0; a < fds.size(); a++)
173 if ((FD_ISSET (fds[a], &rfdset)) || (FD_ISSET (fds[a], &wfdset)))
174 fdlist.push_back(fds[a]);
181 int i = kevent(EngineHandle, NULL, 0, &ke_list[0], 65535, &ts);
182 for (int j = 0; j < i; j++)
183 fdlist.push_back(ke_list[j].ident);
186 int i = epoll_wait(EngineHandle, events, 65535, 100);
187 for (int j = 0; j < i; j++)
188 fdlist.push_back(events[j].data.fd);
193 std::string SocketEngine::GetName()
204 return "misconfigured";