lgrDisSimOutput.h

Go to the documentation of this file.

/******************************************************************************
** Copyright (c) 1992-2025 MAK Technologies, Inc
** All rights reserved.
******************************************************************************/


#pragma once

#if DtDIS

#include <lgrSim/lgrSim.h>
#include <lgrCore/lgrSimOutput.h>
#include <map>
#include <lgrUtil/virtualConstructor.h>

#include <vl/objectId.h>

class DtEntityPublisher;
class DtAggregatePublisher;
class DtPdu;
class DtExerciseConn;

namespace MAKLogger
{

   class DtLgrDisSimulationManager;
   class DtLgrDisMessageIOInfo;
   class DtMessageIOInfo;
   class DtConstLgrDisMessage;
   class DtLgrPublisherInterface;

   class DT_DLL_LGRSIM DtLgrDisSimOutput : public DtLgrSimOutput
   {
   public:

      DT_VIRTUAL_CTR(DtLgrDisSimOutput,(DtLgrDisSimulationManager* manager))
      DT_VIRTUAL_BASE_CTR(DtLgrSimOutput,(DtLgrDisSimulationManager* manager))

      virtual ~DtLgrDisSimOutput();

   private:
      DtLgrDisSimOutput(const DtLgrDisSimOutput&);
      DtLgrDisSimOutput& operator=(const DtLgrDisSimOutput&);
   public:


      virtual DtLgrSimOutput::PacketSenderType packetSenderType(const DtPacket&) const;

      virtual void disconnecting();

      virtual void activateImplementation();

      virtual void deactivateImplementation();

      virtual const DtMessageIOInfo* info() const;

      virtual void flush();

      virtual void setOutputScaling(double scaling, bool enableStatic, bool isPaused=false);

      using DtLgrSimOutput::setOutputScaling;

      virtual void filterMessage(DtPacket* packet);

      virtual void removeEntity(const DtString& name);
      virtual void removeEntity(DtPduKind kind, DtObjectId id);
      virtual void removeEntity(DtConstLgrDisMessage&);


      virtual void setExConnSimTime(DtTime time);
      virtual DtTime exConnSimTime() const;

      virtual DtExerciseConn* exerciseConn();

      virtual const DtExerciseConn* exerciseConn() const;

   protected:

      virtual void retainedSend(const DtPacket&);

      virtual void immediateSend(const DtPacket&) const;

      virtual void sendPacket(const DtPacket& packet);

      virtual void parsePdu(const DtPdu* pdu) const;

      virtual void parsePacket(const DtPacket& packet);

      virtual void updateEntity(DtConstLgrDisMessage&);

      virtual void clearPublishers();

      virtual void getUpdates(DtMessageBuffer& stateBuffer, const DtAbsoluteTime& time);

      virtual void rescalePublishers(double oldScale,double newScale,
         bool wasStatic, bool isStatic);

      //If no DIS override version is set, adjust DIS version to send to match DIS version of PDU from tape.
      virtual void adjustProtocolVersionToSend(int pduDisVersion);
      
      //If no DIS override version is set, reset DIS version to default version.
      virtual void resetProtocolVersionToSend();

      typedef std::pair<DtPduKind,DtObjectId> UniqueObjectId;

      typedef std::map<UniqueObjectId,DtLgrPublisherInterface*> ObjectPublisherMap;

      DtLgrDisSimulationManager& myDisManager;

      ObjectPublisherMap myObjectPublisherMap;

      DtLgrDisMessageIOInfo*     myMessageInfo;

      bool myOutputStatic;

      bool myIsPaused;

      mutable int mySendCount;

      //Save default DIS version
      int myDefaultDISVersion;
   };

}

#endif