lgrHlaEntityPublisher.h

Go to the documentation of this file.

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


#pragma once

#if DtHLA

#include <lgrUtil/virtualConstructor.h>
#include <lgrSim/lgrPublisherInterface.h>

#include <vl/rtiCompatibility.h>
#include <vl/entityPublisherHLA.h>
#include <vl/entityStateRepository.h>


namespace MAKLogger
{
   class DtLgrHlaEntityStateRepository;

   class DT_DLL_LGRSIM DtLgrHlaEntityPublisher : public DtEntityPublisher, public DtLgrPublisherInterface
   {
   public:

      DT_VIRTUAL_CTR_DEFAULTS(DtLgrHlaEntityPublisher,
                              (DtLgrHlaSimulationManager& simMgr, DtLgrHlaHandle loggerObjectId,
                               DtLgrHlaHandle  loggerClassHandle, RTI::ObjectClassHandle classHandle,
                               const char* objName, const DtDDMRegionSet* regionSetToUse,
                               double hbtime, bool waitForRegionData, bool stat),
                              (DtLgrHlaSimulationManager& simMgr,
                               DtLgrHlaHandle loggerObjectId, DtLgrHlaHandle  loggerClassHandle,
                               RTI::ObjectClassHandle classHandle,
                               const char* objName, const DtDDMRegionSet* regionSetToUse,
                               double hbtime=0.0, bool waitForRegionData=false, bool stat=true))

      
      virtual ~DtLgrHlaEntityPublisher();

      virtual void update(const DtStateMsg& msg, const DtAbsoluteTime& updateTime,
         bool isTimeFromPast, bool isStateUpdate, double scaling, bool isStatic, bool sendFlag);

      virtual DtObjectPublisher* objPublisher();

      virtual void tick(double scale, bool isStatic);

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

      virtual void setRegion(const DtDDMRegionSet& region);
      
      virtual const DtDDMRegionSet& publishingRegions() const;

      virtual bool publishingToRegion( DtDDMRegionSP region );

   protected:

      virtual void setPauseUpdateAttributes(double &scale);

      virtual DtHlaObjectWithStateRep* pubHlaObject();

      virtual void scaleArticulatedParts(double scale);

      virtual void generateScaledUpdate(const RTI::AttributeHandleSet& attrs, double scale,
         bool isStatic, DtStateMsg& msg);

      virtual void sendRequestedAttrs(double scale, bool isStatic);

      virtual void sendTheseAttrs(const RTI::AttributeHandleSet& attrs, double scale, bool isStatic);

      virtual void send(DtStateMsg& msg);

      DtLgrHlaEntityPublisher(const DtLgrHlaEntityPublisher &other);

      DtLgrHlaEntityPublisher &operator=(const DtLgrHlaEntityPublisher &other);

   protected:

      RTI::AttributeHandleSet* myAttrsToSend;

      DtBaseEntityStateRepository* mySeenByAttrs;
      DtDeadReckoner* myDeadReckoner;

      // Reference to entity state rep. as it instantiated logger derivation.
      DtLgrHlaEntityStateRepository *myLgrEsr;

      double myLastTimeScale;

      double myHeartbeatInterval;
      double myLastHeartbeatTime;

      DtVector32 myLastUpdateVelocity;
      DtVector32 myLastUpdateAcceleration;
      DtVector32 myLastUpdateRotVel;
      DtTaitBryan myLastUpdateOrientation;
      DtVector myLastUpdateLocation;

      // Frozen state saved when scale goes to 0 (i.e. paused) and is restored when unpaused.
      bool myFrozenBeforePause;

      // Flag to set when the tape is paused
      bool myPaused;
      bool myUnpausedOnThisSend;

      DtDeadReckonTypes myOldDRType;
      bool myDRTypeChanged;

   };

}

#endif