Main Page | Namespace List | Class Hierarchy | Alphabetical List | Class List | Directories | File List | Namespace Members | Class Members | File Members

home » brain » inspircd-cvs » inspircd » include

inspsocket.h

Go to the documentation of this file.

/*       +------------------------------------+
 *       | Inspire Internet Relay Chat Daemon |
 *       +------------------------------------+
 *
 *  InspIRCd: (C) 2002-2008 InspIRCd Development Team
 * See: http://www.inspircd.org/wiki/index.php/Credits
 *
 * This program is free but copyrighted software; see
 *          the file COPYING for details.
 *
 * ---------------------------------------------------
 */

#ifndef __INSP_SOCKET_H__
#define __INSP_SOCKET_H__

#include "timer.h"

enum BufferedSocketState
{
        I_DISCONNECTED,
        I_CONNECTING,
        I_CONNECTED,
        I_ERROR
};

enum BufferedSocketError
{
        I_ERR_TIMEOUT,
        I_ERR_SOCKET,
        I_ERR_CONNECT,
        I_ERR_BIND,
        I_ERR_RESOLVE,
        I_ERR_WRITE,
        I_ERR_NOMOREFDS
};

/* Required forward declarations */
class BufferedSocket;
class InspIRCd;

class CoreExport SocketTimeout : public Timer
{
 private:
        BufferedSocket* sock;

        InspIRCd* ServerInstance;

        int sfd;

 public:
        SocketTimeout(int fd, InspIRCd* Instance, BufferedSocket* thesock, long secs_from_now, time_t now) : Timer(secs_from_now, now), sock(thesock), ServerInstance(Instance), sfd(fd) { };

        virtual void Tick(time_t now);
};

class CoreExport BufferedSocket : public EventHandler
{
 public:

        std::string cbindip;

        InspIRCd* ServerInstance;

        SocketTimeout* Timeout;

        std::deque<std::string> outbuffer;

        char host[MAXBUF];

        int port;

        BufferedSocketState state;

        char IP[MAXBUF];

        socklen_t length;

        bool FlushWriteBuffer();

        void SetQueues();

        bool ClosePending;

        bool BindAddr(const std::string &ip);

        BufferedSocket(InspIRCd* SI);

        BufferedSocket(InspIRCd* SI, int newfd, const char* ip);

        BufferedSocket(InspIRCd* SI, const std::string &ipaddr, int port, unsigned long maxtime, const std::string &connectbindip = "");

        virtual bool OnConnected();

        virtual void OnError(BufferedSocketError e);

        virtual int OnDisconnect();

        virtual bool OnDataReady();

        bool OnWriteReady();

        virtual void OnTimeout();

        virtual void OnClose();

        virtual const char* Read();

        std::string GetIP();

        virtual void Write(const std::string &data);

        void SetState(BufferedSocketState s);

        BufferedSocketState GetState();

        bool InternalMarkConnected();

        virtual void Close();

        virtual ~BufferedSocket();

        virtual bool DoConnect(unsigned long maxtime);

        void HandleEvent(EventType et, int errornum = 0);

        bool Readable();
};

#endif