hlaGenericPublisher.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 <vl/objectPublisherHLA.h>
#include <vl/rtiCompatibility.h>
#include "lgrPublisherInterface.h"
#include <lgrUtil/absoluteTime.h>

class DtStateRepository;

namespace MAKLogger
{

   class DtLgrHlaSimulationManager;

   class DT_DLL_LGRSIM DtHLAGenericPublisher : public DtObjectPublisher ,
                                 public DtLgrPublisherInterface
   {
   public:

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

      
      virtual ~DtHLAGenericPublisher();

   private:

      DtHLAGenericPublisher(const DtHLAGenericPublisher &other);

      DtHLAGenericPublisher &operator=(const DtHLAGenericPublisher &other);

   public:

      virtual DtStateRepository* genericStateRep();

      virtual DtStateRepository* gsr();

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

      virtual DtObjectPublisher* objPublisher();

      virtual void tick(double scaling, bool isStatic);

      virtual void setPublish(bool makePublished);

      virtual bool isPublished();

      virtual void sendRequestedAttrs(double scaling, bool isStatic);

      virtual void send(const DtStateMsg& msg);

      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 DtHlaObjectWithStateRep* pubHlaObject();

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

      virtual bool makeObjectPublished(RTI::ObjectClassHandle classHandle, const char* objName);

      virtual void makeObjectUnpublished(RTI::ObjectClassHandle classHandle, const char* objName);


   protected:

      bool myPublished;

      double myHeartbeatInterval;

      double myLastHeartbeatTime;

      RTI::AttributeHandleSet* myAttrsToSend;
   };

}

#endif