IncomingMessage.h

#ifndef _dcl_dis_incoming_message_
#define _dcl_dis_incoming_message_

#include <dis6/utils/IBufferProcessor.h>   // for base class
#include <dis6/utils/IPduBank.h> 
#include <map>                      // for member
#include <dis6/utils/Endian.h>             // for internal type
#include <dis6/opendis6_export.h>         // for library symbols
#include <dis6/utils/PDUType.h>

namespace DIS
{
   class Pdu;
   class IPacketProcessor;
   class DataStream;

   class OPENDIS6_EXPORT IncomingMessage : public IBufferProcessor
   {
   public:
      typedef std::multimap<unsigned char,IPacketProcessor*> PacketProcessorContainer;
      
      typedef std::multimap<unsigned char,IPduBank*> PduBankContainer;

      IncomingMessage();
      ~IncomingMessage();

      void Process(const char* buf, unsigned int size, Endian e);

      bool AddProcessor(unsigned char id, IPacketProcessor* pp);

      bool RemoveProcessor(unsigned char id, const IPacketProcessor* pp);

      bool AddPduBank(unsigned char pdu_type, IPduBank* pduBank);

      bool RemovePduBank(unsigned char pdu_type, const IPduBank* pduBank);

      PacketProcessorContainer& GetProcessors();
      const PacketProcessorContainer& GetProcessors() const;

      PduBankContainer& GetPduBanks();
      const PduBankContainer& GetPduBanks() const;

   private:
      typedef std::pair<PacketProcessorContainer::iterator, PacketProcessorContainer::iterator> PacketProcessIteratorPair;
      PacketProcessorContainer _processors;
      
      typedef std::pair<PduBankContainer::iterator, PduBankContainer::iterator> PduBankIteratorPair;
      PduBankContainer _pduBanks;

      void SwitchOnType(DIS::PDUType pdu_type, DataStream& ds);

      bool FindProccessorContainer(unsigned char id, const IPacketProcessor* pp, PacketProcessorContainer::iterator &containerIter);

      bool FindPduBankContainer(unsigned char pdu_type, const IPduBank* pduBank, PduBankContainer::iterator &containerIter);
   };

}

#endif  // _dcl_dis_incoming_message_