RTFXMailbox.h

#ifndef __RTFX_MAILBOX__
#define __RTFX_MAILBOX__

#include <iostream>
#include <sstream>
#include <vector>
#include <deque>
#include <map>

#include "RTFXCamera.h"
#include "RTFXLight.h"
#include "RTFXGeometry.h"
#include "RTFXData.h"
#include "RTFXParcel.h"

namespace RTFX
{
    class RTFXAPI RTFXMailbox
    {
        public:

            RTFXMailbox() 
            {
                // Create the storage graph, and turn locks on since multiple threads will be accessing this graph
                data = new RTFXData();
                data->SetLocks( true );

                updater = new RTFXData();

                compressionType = NONE;
                isNewRawDataAvailable = false;
            }

            ~RTFXMailbox()
            {
                delete data;
                delete updater;
                waitingList.clear();
            }

            void AddMessage( RTFXData * _newMessage )
            {
                // Merge this update with the raw data (ignore updater for now);
                verbose( ostringstream().flush() << "RTFXMailbox::AddMessage: there are - " << data->GetNumObjects() << " objects." << endl );
                data->Merge( _newMessage ); 
            }

            RTFXData * GetPointerToMailbox()
            {
            //  boost::lock_guard<boost::mutex> lock( mailLock );
                return data;
            }

            void GetSerializedMailbox( string &_sdata );

            void AcceptDataParcel( RTFXParcel _parcel );

            void ParseBody( string &_message );
                     
            void DecodeBody( boost::uuids::uuid _messageID, string &_result );              

            char * GetMailboxName() { return mailboxName; }

            void SetMailboxName( char * _mailboxName )
            {
                strcpy( mailboxName, _mailboxName );
            }

            void SetDefaultCompressionType( COMPRESSIONTYPE _tmp )
            {
                compressionType = _tmp;
            }

            COMPRESSIONTYPE GetDefaultCompressionType() { return compressionType; }     

            RTFXBIGINT GetCustomDataCount();

            void AddCustomData( string _data );

            string GetCustomData();

            bool IsNewCustomDataAvailable();

        private:

            COMPRESSIONTYPE compressionType;

            boost::mutex mailLock;

            char mailboxName[16];

            vector< pair<clock_t, RTFXData *> > waitingList;

            RTFXData * updater;

            RTFXData * data;

            std::map<boost::uuids::uuid, vector<RTFXParcel> > parcelCollection;

            deque<string> rawDataStorage;
            
            bool isNewRawDataAvailable;

            bool isBinaryData;
    };
}

#endif