* | Inspire Internet Relay Chat Daemon |
* +------------------------------------+
*
- * Inspire is copyright (C) 2002-2005 ChatSpike-Dev.
+ * InspIRCd is copyright (C) 2002-2006 ChatSpike-Dev.
* E-mail:
* <brain@chatspike.net>
* <Craig@chatspike.net>
#include <vector>
#include <string>
+#include <map>
#include "inspircd_config.h"
#include "globals.h"
#include "inspircd.h"
-#ifdef USE_EPOLL
-#include <sys/epoll.h>
-#define EP_DELAY 5
-#endif
-#ifdef USE_KQUEUE
-#include <sys/types.h>
-#include <sys/event.h>
-#include <sys/time.h>
-#endif
-const char X_LISTEN = 0;
-const char X_ESTAB_CLIENT = 1;
-const char X_ESTAB_MODULE = 2;
-const char X_ESTAB_DNS = 3;
+/**
+ * Each of these values represents a socket
+ * type in our reference table (the reference
+ * table itself is only accessible to
+ * socketengine.cpp)
+ */
+const char X_EMPTY_SLOT = 0;
+const char X_LISTEN = 1;
+const char X_ESTAB_CLIENT = 2;
+const char X_ESTAB_MODULE = 3;
+const char X_ESTAB_DNS = 4;
+/**
+ * To indicate that a socket is readable, we
+ * mask its top bit with this X_READBIT value.
+ * The socket engine can handle two types of
+ * socket, readable and writeable (;error sockets
+ * are dealt with when read() and write() return
+ * negative or zero values).
+ */
const char X_READBIT = 0x80;
-class SocketEngine {
-
- std::vector<int> fds;
- int EngineHandle;
-#ifdef USE_SELECT
- fd_set wfdset, rfdset;
-#endif
-#ifdef USE_KQUEUE
- struct kevent ke_list[65535];
- struct timespec ts;
-#endif
-#ifdef USE_EPOLL
- struct epoll_event events[65535];
-#endif
-
+/**
+ * The actual socketengine class presents the
+ * same interface on all operating systems, but
+ * its private members and internal behaviour
+ * should be treated as blackboxed, and vary
+ * from system to system and upon the config
+ * settings chosen by the server admin. The current
+ * version supports select, epoll and kqueue.
+ * The configure script will enable a socket engine
+ * based upon what OS is detected, and will derive
+ * a class from SocketEngine based upon what it finds.
+ * The derived classes file will also implement a
+ * classfactory, SocketEngineFactory, which will
+ * create a derived instance of SocketEngine using
+ * polymorphism so that the core and modules do not
+ * have to be aware of which SocketEngine derived
+ * class they are using.
+ */
+class SocketEngine : public Extensible
+{
+protected:
+ int EngineHandle; /* Handle to the socket engine if needed */
+ int CurrentSetSize; /* Current number of descriptors in the engine */
+ char ref[MAX_DESCRIPTORS]; /* Reference table */
public:
+ /** Constructor
+ * The constructor transparently initializes
+ * the socket engine which the ircd is using.
+ * Please note that if there is a catastrophic
+ * failure (for example, you try and enable
+ * epoll on a 2.4 linux kernel) then this
+ * function may bail back to the shell.
+ */
SocketEngine();
- ~SocketEngine();
- bool AddFd(int fd, bool readable, char type);
+
+ /** Destructor
+ * The destructor transparently tidies up
+ * any resources used by the socket engine.
+ */
+ virtual ~SocketEngine();
+
+ /** Add a file descriptor to the engine
+ * Use AddFd to add a file descriptor to the
+ * engine and have the socket engine monitor
+ * it. You must provide a type (see the consts
+ * in socketengine.h) and a boolean flag to
+ * indicate wether to watch this fd for read
+ * or write events (there is currently no
+ * need for support of both).
+ */
+ virtual bool AddFd(int fd, bool readable, char type);
+
+ /** Returns the type value for this file descriptor
+ * This function masks off the X_READBIT value
+ * so that the type of the socket can be obtained.
+ * The core uses this to decide where to dispatch
+ * the event to. Please note that some engines
+ * such as select() have an upper limit of 1024
+ * descriptors which may be active at any one time,
+ * where others such as kqueue have no practical
+ * limits at all.
+ */
char GetType(int fd);
- bool DelFd(int fd);
- bool Wait(std::vector<int> &fdlist);
- std::string GetName();
+
+ /** Returns the maximum number of file descriptors
+ * you may store in the socket engine at any one time.
+ */
+ virtual int GetMaxFds();
+
+ /** Returns the number of file descriptor slots
+ * which are available for storing fds.
+ */
+ virtual int GetRemainingFds();
+
+ /** Delete a file descriptor from the engine
+ * This function call deletes a file descriptor
+ * from the engine, returning true if it succeeded
+ * and false if it failed.
+ */
+ virtual bool DelFd(int fd);
+
+ /** Returns true if a socket exists in the socket
+ * engine's list.
+ */
+ bool HasFd(int fd);
+
+ /** Waits for an event.
+ * Please note that this doesnt wait long, only
+ * a couple of milliseconds. It returns a list
+ * of active file descriptors in the vector
+ * fdlist which the core may then act upon.
+ */
+ virtual int Wait(int* fdlist);
+
+ /** Returns the socket engines name
+ * This returns the name of the engine for use
+ * in /VERSION responses.
+ */
+ virtual std::string GetName();
};
#endif
projects / user / henk / code / inspircd.git / blobdiff