hlaSimInput.h

Go to the documentation of this file.

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


#ifndef hlaSimInput_H_
#define hlaSimInput_H_

#if DtHLA

#include <lgrSim/lgrSim.h>
#include <lgrCore/lgrSimInput.h>
#include <lgrSim/lgrHlaAttribute.h>
#include "hlaMessageFactory.h"

#include <vl/rtiNamespace.h>
#include <vl/rtiCompatibility.h>

#include <list>
#include <map>

class DtHlaObject;
class DtInteraction;
class DtStateMsg;
class DtBaseEntityStateRepository;
class DtGenericAttributeDecoder;
class DtStateRepository;

namespace MAKLogger
{
   class DtLgrHlaSimulationManager;
   class DtMessageBuffer;
   class DtLgrHlaMessageIOInfo;

   class DT_DLL_LGRSIM DtLgrHlaSimInput : public DtLgrSimInput
   {
   public:

      DT_VIRTUAL_CTR(DtLgrHlaSimInput, (DtLgrHlaSimulationManager& manager))

      virtual ~DtLgrHlaSimInput();

      virtual void activateImplementation();

      virtual void deactivateImplementation();

      virtual void connecting();

      virtual void disconnecting();

      virtual const DtMessageIOInfo* info() const;

      virtual void tick();

      static void decodeIsPartOf_RPR_20014( DtBaseEntityStateRepository* stateRep,
         const RTI::AttributeHandleValuePairSet& attrs,
         int pairSetIndex );

      virtual void subscribe();

      virtual void unsubscribe();

   protected:


      static void discoverObjCb(DtHlaObject* object,void* usr);
      virtual void discoverObject(DtHlaObject* object);


      static void removeObjCb(DtHlaObject* object,void* usr);
      virtual void removeObject(DtHlaObject* object, bool updateTimeout=true);


      static void reflectCb(const DtStateMsg& msg, DtHlaObject* obj, void* usr );
      virtual void reflect(const DtStateMsg& msg, DtHlaObject* obj);


      static void receiveInterCb( DtInteraction* inter, void* usr );
      virtual void receiveInteraction(const DtInteraction * interaction);

      virtual int getInteractionRegionSet(const DtInteraction *interaction, DtRegionDescSet& regionSet);

      virtual int getObjectRegionSet(DtRegionDescSet& regionSet);

      virtual void startListening();

      virtual void stopListening();

      virtual bool evaluateTrafficAnalyzerFilters(const DtHlaObject& obj) const;

      virtual void localDeleteObjectForRefresh(DtHlaObject* object);

      void checkRefresh();

      void checkTimeouts();

      void removeTimeout(DtHlaObject* object);

   protected:

#if DtHLA_1516
      typedef std::map<RTI::ObjectInstanceHandle,DtLgrHlaHandle> ObjectInstanceMap;
      typedef std::map<DtString, RTI::ObjectInstanceHandle> NameObjectInstanceMap;
#else
      typedef std::map<RTI::ObjectHandle,DtLgrHlaHandle> ObjectInstanceMap;
      typedef std::map<DtString, RTI::ObjectHandle> NameObjectInstanceMap;
#endif
      typedef std::map<DtHlaObject*, DtAbsoluteTime> TimeoutByObjectMap;
      typedef std::set<DtHlaObject*> HlaObjectSet;
      typedef std::map<DtAbsoluteTime, HlaObjectSet> TimeoutByTimeMap;

      DtLgrHlaSimulationManager& myHlaManager;

      TimeoutByObjectMap myTimeoutTimeByObject;
      TimeoutByTimeMap myTimeoutByTime;

      typedef std::shared_ptr<DtStateRepository> DtStateRepositorySP;
      typedef std::shared_ptr<DtGenericAttributeDecoder> DtGenericAttributeDecoderSP;
      class DtStateAndDecoder 
      {
      public:
         DtStateAndDecoder();
         virtual ~DtStateAndDecoder();
         virtual void initialize(DtExerciseConn* exConn, DtObjClassDesc* classDesc);
         virtual DtStateRepository* state();
         virtual DtGenericAttributeDecoder* decoder();
      protected:
         DtStateRepositorySP myState;
         DtGenericAttributeDecoderSP myDecoder;
      };

      std::map<DtHlaObject*, DtStateAndDecoder> myStateAndDecoders;

      ObjectInstanceMap myObjectInstanceMap;
      NameObjectInstanceMap myNameObjectInstanceMap;
      DtLgrHlaHandle myFreeInstanceHandle;

      DtLgrHlaMessageIOInfo* myInfo;
      bool myListening;
   };

}

#endif
#endif