RTFXSession.h

#ifndef __RTFX_SESSION__
#define __RTFX_SESSION__

#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 "RTFXPostOffice.h"
#include "RTFXDebug.h"

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

namespace RTFX
{
    class RTFXAPI RTFXSession : public RTFXParticipant, public boost::enable_shared_from_this<RTFXSession>
    {
        public:

            RTFXSession( boost::asio::io_service &_ioService, RTFXPostOffice &_postOffice );

            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;
            }

        private:
            bool isP2P;

            boost::uuids::uuid ownerID;

            tcp::socket socket;

            RTFXPostOffice &postOffice;

            RTFXParcel readParcel;

            RTFXParcelQueue writeParcels;
    };
}

#endif