|

TCPRemotePeer.hpp

Go to the documentation of this file.

#ifndef IONFLUX_TOOLS_TCPREMOTEPEER
#define IONFLUX_TOOLS_TCPREMOTEPEER
/* ==========================================================================
 * Ionflux Tools
 * Copyright (c) 2004 Joern P. Meier
 * mail@ionflux.org
 * --------------------------------------------------------------------------
 * TCPRemotePeer.hpp                    Remote peer of a TCP connection.
 * ==========================================================================
 * 
 * This file is part of Ionflux Tools.
 * 
 * Ionflux Tools is free software; you can redistribute it and/or modify it 
 * under the terms of the GNU General Public License as published by the Free
 * Software Foundation; either version 2 of the License, or (at  your option)
 * any later version.
 * 
 * Ionflux Tools is distributed in the hope that it will be useful, but 
 * WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY
 * or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License
 * for more details.
 * 
 * You should have received a copy of the GNU General Public License
 * along with Ionflux Tools; if not, write to the Free Software Foundation, 
 * Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
 * 
 * ========================================================================== */

#include <string>
#include <iostream>
#include <vector>
#include "ionflux/Auth.hpp"
#include "ionflux/TCPSocket.hpp"
#include "ionflux/Message.hpp"
#include "ionflux/MessageDump.hpp"
#include "ionflux/MessageHandler.hpp"

namespace Ionflux
{

namespace Tools
{

class MessageHandler;

class TCPRemotePeer
: public MessageDump
{
    protected:
        int id;
        TCPSocket socket;
        std::string recvBuf;
        int protocolState;
        void *data;
        unsigned int dataSize;
        Message *message;
        MessageHandler *messageHandler;
        AuthData auth;
        Node *cache;
        
    public:
        static const int ID_NOT_SET;
        static const int PROTOCOL_STATE_UNDEFINED;
        
        TCPRemotePeer();
        
        TCPRemotePeer(int initID);
        
        virtual ~TCPRemotePeer();
        
        virtual bool receive();
        
        virtual bool send(const std::string &bytes);
        
        virtual void setID(int newID);
        
        virtual void setProtocolState(int newProtocolState);
        
        virtual void setMessageHandler(MessageHandler *newMessageHandler);
        
        virtual int getID();
        
        virtual TCPSocket &getSocket();
        
        virtual AuthData &getAuthData();
        
        virtual std::string &getRecvBuf();
        
        virtual unsigned int removeRecvBytes(unsigned int numBytes);
        
        virtual void clearRecvBuf();
        
        virtual int getProtocolState();
        
        virtual void *getData();
        
        virtual unsigned int getDataSize();
        
        virtual Message *getMessage();
        
        virtual Node *getCache();
        
        virtual void dump(Message &msg);

};

}

}

#endif

---