RTFXPeerSession.h

#ifndef __RTFX_PEERSESSION__
#define __RTFX_PEERSESSION__

#pragma warning(disable: 4996)

#include <boost/bind.hpp>
#include <boost/shared_ptr.hpp>
#include <boost/enable_shared_from_this.hpp>
#include <boost/asio.hpp>

#include "RTFXParticipant.h"
#include "RTFXPeerPostOffice.h"
#include "RTFXDebug.h"

using boost::asio::ip::tcp;

namespace RTFX
{

    class RTFXAPI RTFXPeerSession : public RTFXParticipant, public boost::enable_shared_from_this<RTFXPeerSession>
    {
        public:

            RTFXPeerSession( boost::asio::io_service &_ioService, RTFXPeerPostOffice * _postOffice );

            ~RTFXPeerSession() { postOffice = NULL; }

            tcp::socket& Socket();

            void Start();

            void Deliver( const RTFXParcel &_parcel );

            void HandleReadHeader( const boost::system::error_code &_error );

            void HandleReadBody( const boost::system::error_code &_error );

            void HandleWrite( const boost:: system::error_code &_error );

            void SetOwnerID( boost::uuids::uuid _id )
            {
                ownerID = _id;
            }

            boost::uuids::uuid GetOwnerID()
            {
                return ownerID;
            }

            void SetP2P( bool _isP2P )
            {
                isP2P = _isP2P;
            }

            bool GetP2P()
            {
                return isP2P;
            }

            void SetPeer( void * _ptr )
            {
                peerPtr = _ptr;
            }

            void * GetPeer()
            {
                return peerPtr;
            }

            void SetHostname( string _hostname )
            {
                hostname = _hostname;
            }

            string GetHostname()
            {
                return hostname;
            }

            void DeleteHostname();

            bool IsSelf() 
            {
                return isSelf;
            }

        private:

            bool isSelf;

            string hostname;

            void * peerPtr;

            bool isP2P;

            bool hasHostnameSent;

            boost::uuids::uuid ownerID;

            tcp::socket socket;

            RTFXPeerPostOffice * postOffice;

            RTFXParcel readParcel;

            RTFXParcelQueue writeParcels;

            bool isBinaryData;
    };
}

#endif