mirror of
https://github.com/inspircd/inspircd.git
synced 2025-03-20 07:59:03 -04:00
dd168c56c9
epoll now allows both a write and a read event on a socket at the same time. git-svn-id: http://svn.inspircd.org/repository/trunk/inspircd@5580 e03df62e-2008-0410-955e-edbf42e46eb7
68 lines
1.7 KiB
C++
68 lines
1.7 KiB
C++
/* +------------------------------------+
|
|
* | Inspire Internet Relay Chat Daemon |
|
|
* +------------------------------------+
|
|
*
|
|
* InspIRCd is copyright (C) 2002-2006 ChatSpike-Dev.
|
|
* E-mail:
|
|
* <brain@chatspike.net>
|
|
* <Craig@chatspike.net>
|
|
*
|
|
* Written by Craig Edwards, Craig McLure, and others.
|
|
* This program is free but copyrighted software; see
|
|
* the file COPYING for details.
|
|
*
|
|
* ---------------------------------------------------
|
|
*/
|
|
|
|
#ifndef __SOCKETENGINE_EPOLL__
|
|
#define __SOCKETENGINE_EPOLL__
|
|
|
|
#include <vector>
|
|
#include <string>
|
|
#include <map>
|
|
#include "inspircd_config.h"
|
|
#include "globals.h"
|
|
#include "inspircd.h"
|
|
#include "socketengine.h"
|
|
#include <sys/epoll.h>
|
|
#define EP_DELAY 5
|
|
|
|
class InspIRCd;
|
|
|
|
/** A specialisation of the SocketEngine class, designed to use linux 2.6 epoll().
|
|
*/
|
|
class EPollEngine : public SocketEngine
|
|
{
|
|
private:
|
|
/** These are used by epoll() to hold socket events
|
|
*/
|
|
struct epoll_event events[MAX_DESCRIPTORS];
|
|
public:
|
|
/** Create a new EPollEngine
|
|
* @param Instance The creator of this object
|
|
*/
|
|
EPollEngine(InspIRCd* Instance);
|
|
/** Delete an EPollEngine
|
|
*/
|
|
virtual ~EPollEngine();
|
|
virtual bool AddFd(EventHandler* eh);
|
|
virtual int GetMaxFds();
|
|
virtual int GetRemainingFds();
|
|
virtual bool DelFd(EventHandler* eh);
|
|
virtual int DispatchEvents();
|
|
virtual std::string GetName();
|
|
virtual void WantWrite(EventHandler* eh);
|
|
};
|
|
|
|
/** Creates a SocketEngine
|
|
*/
|
|
class SocketEngineFactory
|
|
{
|
|
public:
|
|
/** Create a new instance of SocketEngine based on EpollEngine
|
|
*/
|
|
SocketEngine* Create(InspIRCd* Instance) { return new EPollEngine(Instance); }
|
|
};
|
|
|
|
#endif
|