hlaSimOutput.h

Go to the documentation of this file.

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



#pragma once

#if DtHLA

#include <lgrSim/lgrSim.h>
#include <lgrCore/lgrSimOutput.h>
#include <lgrSim/lgrHlaAttribute.h>
#include <lgrUtil/virtualConstructor.h>
#include "hlaMessageFactory.h"

#include <map>

#include <vl/region.h>

class DtInteractionFactory;
class DtBaseEntityStateRepository;
class DtHlaTAFilter;

namespace MAKLogger
{

   class DtLgrHlaSimulationManager;
   class DtLgrPublisherInterface;
   class DtHLAGenericPublisher;
   class DtLgrHlaMessageIOInfo;
   class DtMessageIOInfo;
   class DtLgrOnlineFomDesc;
   class DtConstLgrHlaMessage;

   class DT_DLL_LGRSIM DtLgrHlaSimOutput : public DtLgrSimOutput
   {
   public:

      DT_VIRTUAL_CTR(DtLgrHlaSimOutput, (DtLgrHlaSimulationManager& manager))

      virtual ~DtLgrHlaSimOutput();

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

      virtual void disconnecting();

      virtual void activateImplementation();
      virtual void deactivateImplementation();

      virtual void flush();

      virtual const DtMessageIOInfo* info() const;

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

      using DtLgrSimOutput::setOutputScaling;

      virtual void filterMessage(DtPacket* packet);

      virtual bool applyTrafficAnalyzerFilter(DtHLAGenericPublisher& genPub);

      virtual void removeEntity(const DtLgrHlaHandle handle);

      virtual unsigned int getInteractionConveyedRegionSet(const DtConstLgrHlaMessage& info, DtDDMRegionSet& regionSet);

      virtual unsigned int getInteractionRegionSetFromData(const DtConstLgrHlaMessage& info,
         const DtInteraction* interaction, DtDDMRegionSet& regionSet);

      virtual unsigned int getInteractionRegionSet(const DtConstLgrHlaMessage& info,
         DtInteraction* interaction, DtDDMRegionSet& regionSet);

      virtual bool getPublisherRegionSetFromData(const DtPacket& info,
         DtDDMRegionSet& regionSet);

      virtual unsigned int getObjectConveyedRegionSet(const DtConstLgrHlaMessage& info, DtDDMRegionSet& regionSet);

      bool cacheInteractionRegionsEnabled() const;
      void setCacheInteractionRegionsEnabled(bool val);

      bool cacheObjectRegionsEnabled() const;
      void setCacheObjectRegionsEnabled(bool val);


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

      virtual DtExerciseConn* exerciseConn();

      virtual const DtExerciseConn* exerciseConn() const;

   public:
      static void encodeIsPartOf_RPR_20014( const DtBaseEntityStateRepository& stateRep,
         RTI::AttributeHandleValuePairSet* pAvList,
         RTI::AttributeHandle attrHandle );

   protected:

      virtual void retainedSend(const DtPacket&);

      virtual void immediateSend(const DtPacket&) const;

      const DtLgrOnlineFomDesc& fom() const;

      virtual void sendInteractionWithRegion(const DtInteraction& interaction, const DtDDMRegionSet& regionSet) const;

      virtual void updateEntity(const DtPacket&);

      virtual void removeEntity(const DtPacket&);

      virtual void tick();

      virtual void clearPublishers();

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

      virtual DtLgrPublisherInterface* createPublisher(const DtPacket& info);

      virtual DtLgrPublisherInterface* doPublish(DtLgrHlaHandle loggerObjectId,
         DtLgrHlaHandle  loggerClassHandle, RTI::ObjectClassHandle classHandle,
         const char* objName, const DtDDMRegionSet* regionSetToUse, bool silent);

      virtual void printRegion(DtDDMRegionSP region) const;

   protected:

      typedef std::map<DtString,DtLgrHlaHandle> DtObjectNameMap;
      typedef std::map<DtLgrHlaHandle,DtLgrPublisherInterface*> DtObjectPublisherMap;

      DtLgrHlaSimulationManager& myHlaManager;
      DtObjectNameMap myObjectNameMap;
      DtObjectPublisherMap myObjectPublisherMap;
      DtLgrHlaMessageIOInfo* myMessageInfo;
      double myPublisherScaling;
      bool myPublisherStatic;
      bool myIsPaused;
      DtInteractionFactory* myFactory;
      DtIDRegionMap myRegionHandleMap;
      bool myCacheInteractionRegionsEnabled;
      bool myCacheObjectRegionsEnabled;

      std::set<DtLgrPublisherInterface*> myFilteredPublishers;
   };

}

#endif