jaus++/2.0/include/jaus/core/transport/largedataset.h

Go to the documentation of this file.

#ifndef __JAUS_CORE_LARGE_DATA_SET__H
#define __JAUS_CORE_LARGE_DATA_SET__H

#include "jaus/core/header.h"
#include "jaus/core/time.h"
#include <map>

namespace JAUS
{
    class JAUS_CORE_DLL LargeDataSet
    {
    public:        
        class JAUS_CORE_DLL Key
        {
        public:
            Key(const Address& src = Address(),
                const UShort code = 0,
                const UInt pv = 0);
            Key(const Key& key);
            ~Key();
            void Update() const;
            bool operator<(const Key& key) const;
            bool operator<=(const Key& key) const;
            Key& operator=(const Key& key);
            Address mSourceID;           
            UShort mMessageCode;    
            ULong mPresenceVector;  
            Byte mIdentifier;       
            Packet mKey;            
        };
        typedef std::map<UShort, Packet> Stream;
        typedef std::map<LargeDataSet::Key, LargeDataSet*> Map;
        LargeDataSet();
        ~LargeDataSet();
        void Clear();
        bool AddPacket(const Packet& message);
        bool AddPacket(const Header& header, 
                       const UShort messageCode, 
                       const Packet& packet);
        static void CreateLargeDataSet(const Header& header,
                                       const UShort messageCode,
                                       const Packet& payload,
                                       Packet::List& stream,
                                       Header::List& streamHeaders,
                                       const Packet* transportHeader = NULL,
                                       const UShort maxPayloadSize = 1437,
                                       const UShort startingSequenceNumber = 0);
        static bool MergeLargeDataSet(Header& header,
                                      UShort& messageCode,
                                      Packet& payload,
                                      const Packet::List& stream,
                                      const Packet* transportHeader = NULL);
        static bool MergeLargeDataSet(Header& header,
                                      UShort& messageCode,
                                      Packet& payload,
                                      const Stream& stream,
                                      const Packet* transportHeader = NULL);
        Header mHeader;                 
        UShort mMessageCode;            
        bool mHaveLastFlag;             
        bool mCompleteFlag;             
        Stream mStream;                 
        std::set<UShort> mMissing;      
        Time::Stamp mUpdateTimeMs;      
    };
}

#endif

/* End of File */