lgrDisMessageState.h

Go to the documentation of this file.

/******************************************************************************
** Copyright (c) 1992-2016 VT MAK
** All rights reserved.
******************************************************************************/


#pragma once

#if DtDIS

#include <lgrSim/lgrSim.h>
#include <lgrCore/messageState.h>
#include <lgrUtil/virtualConstructor.h>
#include <lgrUtil/memoryBuffer.h>

#include <list>
#include <set>
#include <vlpi/disEnums.h>

enum DtPduKind;

namespace MAKLogger
{

   class DtLgrDisSimulationManager;

   class DT_DLL_LGRSIM DtLgrDisMessageState : public DtMessageState
   {
   public:

      typedef std::set<DtPduKind> DtPduKindSet;

      struct NetInitialStateUpdateHeader
      {
         DtNetFloat64 arrivalTime;
      };

      DT_VIRTUAL_CTR_DEFAULTS( DtLgrDisMessageState,
         (const DtPduKindSet& statePduKinds, const DtLgrDisSimulationManager* simMgr),
         (const DtPduKindSet& statePduKinds, const DtLgrDisSimulationManager* simMgr=0))

      virtual ~DtLgrDisMessageState();

      virtual void modifyMessages(DtMessageBuffer& messages) const;

      virtual void modifyMessage(DtPacket& packet) const;

      virtual void decodeInitialState(const DtPacket& packet,DtMessageBuffer& buffer);

      virtual void decodeCheckpoint(const DtPacket& packet, DtMessageBuffer& messageBuffer,
         bool includeInteractions);

      virtual void decodeLinkedCheckpoint(const DtPacket& packet, DtMessageBuffer& messageBuffer,
         bool includeInteractions);

      virtual bool isUpdateMessage(const DtPacket& packet) const;

      virtual bool isUpdateMessage(DtPduKind pduKind) const;

      virtual bool isRemovalMessage(const DtPacket& packet) const;

      virtual bool isInteractionMessage(const DtPacket& packet) const;

      virtual bool isInteractionMessage(DtPduKind pduKind) const;

      virtual void createUpdate(const DtStateObject& object,const DtAbsoluteTime* time, std::list<DtPacket*>& packetlist) const;

      virtual DtPacket* createRemoval(const DtStateObject& object,const DtAbsoluteTime& time) const;

      virtual void setInputVersion(int disVersion);
      virtual void setOutputVersion(int disVersion);

   protected:

      DtLgrDisMessageState(const DtLgrDisMessageState&);

      DtLgrDisMessageState& operator=(const DtLgrDisMessageState&);

      virtual int decodeState(const char* data, size_t bufferSize, const DtAbsoluteTime& time,
         DtMessageBuffer& messageBuffer, bool includeInteractions, bool useStateHeader);

      virtual void decodeCheckpoint(const char* checkpointBuffer, size_t bufferSize, const DtAbsoluteTime& time,
         DtMessageBuffer& messageBuffer, bool includeInteractions);

      virtual DtPacket* createInitialStatePacket(const DtMessageBuffer& initialStateBuffer,
         const DtAbsoluteTime& timestamp, double offsetTime);

      virtual DtPacket* createCheckpointPacket(const DtMessageBuffer& checkpointBuffer,
         const DtAbsoluteTime& timestamp);

      virtual void fillWithStateData(const DtMessageBuffer& stateBuffer, char* data, bool includeUpdateHeaders);

      virtual void activateState();
      virtual void deactivateState();

   protected:

      DtPduKindSet myStatePduKinds;

      int myInputVersion;
      int myOutputVersion;
   };

}

#endif