aggregatePublisherDIS.h

Go to the documentation of this file.

/*********************************************************************
** Copyright (c) 1992-2025 MAK Technologies, Inc
** All rights reserved.
*********************************************************************/
#pragma once
#if DtDIS


#include "aggregateStateRepository.h"
#include "objectPublisherDIS.h"
#include "aggregateStateEncoder.h"
#include "aggregateStateDecoder.h"
#include "relativeLocationPdu.h"

class DT_DLL_VL DtExerciseConn;

class DT_DLL_VL DtAggregatePublisher : public DtObjectPublisher
{
public:

   typedef DtAggregateStateRepository* (*DtStateRepCreator)();

   DtAggregatePublisher(
      DtAggregateStateRepository *stateRepToUse,
      DtExerciseConn* conn,
      const DtObjectId& id = DtObjectId::nullId());

   DtAggregatePublisher(
      DtExerciseConn* conn,
      const DtObjectId& id = DtObjectId::nullId());

   DtAggregatePublisher(
      const DtEntityType& type,
      DtExerciseConn* conn,
      const DtObjectId& id = DtObjectId::defaultId());

   DtAggregatePublisher(
      const DtEntityType& type,
      DtExerciseConn* conn,
      DtDeadReckonTypes algorithm,
      DtForceType forceId,
      const DtObjectId& id = DtObjectId::defaultId());

   virtual ~DtAggregatePublisher();

   virtual bool tick();

   virtual void forceUpdate();

   virtual DtAggregateStateRepository* aggregateStateRep();

   virtual DtAggregateStateRepository* asr();

   virtual const DtObjectId& id() const;

   virtual const DtObjectId& localId() const;

   virtual const DtGlobalObjectDesignator& globalId() const;   

   DtTime entityTypeHeartbeat(int type, int domain);
    
public:

   static void setStateRepCreator(DtStateRepCreator creator);
   static DtStateRepCreator setStateRepCreator(void);

   static void setClassDfltTimeThreshold(DtTime threshold);
   static void setStationaryDfltTimeThreshold(DtTime threshold);
   static void setEntityTypeDfltTimeThreshold(int type, int domain, DtTime threshold);

protected:

   void init(const DtEntityIdentifier& vehId);

   DtAggregatePublisher(const DtAggregatePublisher& orig);

   DtAggregatePublisher& operator=(const DtAggregatePublisher& orig);

protected:

   DtObjectId myId;
   DtAggregateStateDecoder* myAggregateDecoder;
   DtAggregateStateEncoder* myAggregateEncoder;
   DtRelativeLocationPdu    myLastSentRelLocPdu;
   DtTime                   myLastSentRelLocPduTime;

protected:
   static DtStateRepCreator theStateRepCreator;
   static DtTime            theClassDfltTimeThreshold;
   static bool              theClassDfltIsSetFlag;
   static DtTime            theStationaryDfltTimeThreshold;
   static bool              theStationaryDfltIsSetFlag;
   static std::map<std::pair<int,int>,DtTime> theEntityTypeHeartbeat;
};


inline DtAggregateStateRepository* DtAggregatePublisher::asr()
{
   return static_cast<DtAggregateStateRepository*>(myStateRep);
}

inline  const DtObjectId& DtAggregatePublisher::localId() const
{
   return id();
}


#endif