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

home » brain » inspircd-cvs » 1_1_stable » 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 <sstream>
#include <string>
#include <deque>
#include "dns.h"
#include "inspircd_config.h"
#include "socket.h"
#include "inspsocket.h"
#include "timer.h"

enum InspSocketState
{
        I_DISCONNECTED,
        I_CONNECTING,
        I_CONNECTED,
        I_LISTENING,
        I_ERROR
};

enum InspSocketError
{
        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 InspSocket;
class InspIRCd;

using irc::sockets::insp_sockaddr;
using irc::sockets::insp_inaddr;
using irc::sockets::insp_ntoa;
using irc::sockets::insp_aton;

class CoreExport SocketTimeout : public InspTimer
{
 private:
        InspSocket* sock;
        InspIRCd* ServerInstance;
        int sfd;
 public:
        SocketTimeout(int fd, InspIRCd* Instance, InspSocket* thesock, long secs_from_now, time_t now) : InspTimer(secs_from_now, now), sock(thesock), ServerInstance(Instance), sfd(fd) { };
        virtual void Tick(time_t now);
};

class CoreExport InspSocket : public EventHandler
{
 public:

        std::string cbindip;

        bool IsIOHooked;

        InspIRCd* Instance;

        SocketTimeout* Timeout;

        unsigned long timeout_val;

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

        char host[MAXBUF];

        int port;

        InspSocketState state;

        bool timeout;
        
        char ibuf[65535];

        char IP[MAXBUF];

        socklen_t length;

        bool FlushWriteBuffer();

        void SetQueues(int nfd);

        bool ClosePending;

        bool WaitingForWriteEvent;

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

        InspSocket(InspIRCd* SI);

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

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

        virtual bool OnConnected();

        virtual void OnError(InspSocketError e);

        virtual int OnDisconnect();

        virtual bool OnDataReady();

        virtual bool OnWriteReady();

        virtual void OnTimeout();

        virtual void OnClose();

        virtual char* Read();

        std::string GetIP();

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

        virtual int OnIncomingConnection(int newfd, char* ip);

        void SetState(InspSocketState s);

        void WantWrite();

        InspSocketState GetState();

        bool Poll();

        int GetFd();

        virtual void Close();

        virtual ~InspSocket();

        virtual bool DoConnect();

        void MarkAsClosed();

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

        bool Readable();
};

#endif