* | Inspire Internet Relay Chat Daemon |
* +------------------------------------+
*
- * InspIRCd: (C) 2002-2009 InspIRCd Development Team
+ * InspIRCd: (C) 2002-2010 InspIRCd Development Team
* See: http://wiki.inspircd.org/Credits
*
* This program is free but copyrighted software; see
#include "inspircd.h"
#include "exitcodes.h"
-#include "socketengines/socketengine_poll.h"
+
+#ifndef __SOCKETENGINE_POLL__
+#define __SOCKETENGINE_POLL__
+
+#include <vector>
+#include <string>
+#include <map>
+#include "inspircd_config.h"
+#include "inspircd.h"
+#include "socketengine.h"
+
+#ifndef WINDOWS
+ #ifndef __USE_XOPEN
+ #define __USE_XOPEN /* fuck every fucking OS ever made. needed by poll.h to work.*/
+ #endif
+ #include <poll.h>
+ #include <sys/poll.h>
+#else
+ /* *grumble* */
+ #define struct pollfd WSAPOLLFD
+ #define poll WSAPoll
+#endif
+
+class InspIRCd;
+
+/** A specialisation of the SocketEngine class, designed to use poll().
+ */
+class PollEngine : public SocketEngine
+{
+private:
+ /** These are used by poll() to hold socket events
+ */
+ struct pollfd *events;
+ /** This map maps fds to an index in the events array.
+ */
+ std::map<int, unsigned int> fd_mappings;
+public:
+ /** Create a new PollEngine
+ */
+ PollEngine();
+ /** Delete a PollEngine
+ */
+ virtual ~PollEngine();
+ virtual bool AddFd(EventHandler* eh, int event_mask);
+ virtual void OnSetEvent(EventHandler* eh, int old_mask, int new_mask);
+ virtual EventHandler* GetRef(int fd);
+ virtual void DelFd(EventHandler* eh);
+ virtual int DispatchEvents();
+ virtual std::string GetName();
+};
+
+#endif
+
#include <ulimit.h>
#ifdef __FreeBSD__
#include <sys/sysctl.h>
events[it->second].events = mask_to_poll(new_mask);
}
-bool PollEngine::DelFd(EventHandler* eh, bool force)
+void PollEngine::DelFd(EventHandler* eh)
{
int fd = eh->GetFd();
if ((fd < 0) || (fd > MAX_DESCRIPTORS))
{
ServerInstance->Logs->Log("SOCKET", DEBUG, "DelFd out of range: (fd: %d, max: %d)", fd, GetMaxFds());
- return false;
+ return;
}
std::map<int, unsigned int>::iterator it = fd_mappings.find(fd);
if (it == fd_mappings.end())
{
ServerInstance->Logs->Log("SOCKET",DEBUG,"DelFd() on unknown fd: %d", fd);
- return false;
+ return;
}
unsigned int index = it->second;
ServerInstance->Logs->Log("SOCKET", DEBUG, "Remove file descriptor: %d (index: %d) "
"(Filled gap with: %d (index: %d))", fd, index, last_fd, last_index);
- return true;
}
int PollEngine::DispatchEvents()
socklen_t codesize = sizeof(int);
int errcode;
int processed = 0;
+ ServerInstance->UpdateTime();
if (i > 0)
{
{
SetEventMask(eh, eh->GetEventMask() & ~FD_READ_WILL_BLOCK);
eh->HandleEvent(EVENT_READ);
+ if (eh != ref[index])
+ // whoops, deleted out from under us
+ continue;
}
if (events[index].revents & POLLOUT)
return "poll";
}
+SocketEngine* CreateSocketEngine()
+{
+ return new PollEngine;
+}