vrfEntityPublisher.h

Go to the documentation of this file.

/****************************************************************************
 * Copyright (c) 2017 VT MAK
 * All rights reserved.
 ****************************************************************************/


#pragma once

#include <vrfExtObjects/dllExport.h>
#include <vrfExtObjects/vrfObjectIdGenerator.h>
#include <vl/dataInteraction.h>
#include <vl/entityPublisher.h>

#ifdef DtDIS
#  include <vl/diGuyCustomPduEncoder.h>
#endif

#ifdef DtDIS
typedef DtEntityStateEncoder DtEntPublisherEncoder;
typedef DtEntityStateDecoder DtEntPublisherDecoder;
#elif DtHLA
typedef DtHlaStateEncoder DtEntPublisherEncoder;
typedef DtHlaStateDecoder DtEntPublisherDecoder;
#endif

class DtExtEntityStateRepository;
class DtEntityType;
class DtBaseEntityStateRepository;
class DtSimulationAddress;
class DtSimInterfaceContent;

class DT_DLL_vrfExtObjects DtVrfEntityPublisher
{

public:
   DtVrfEntityPublisher(
      const DtEntityType& type,
      DtExerciseConn* conn,
#if DtHLA
      const DtGlobalObjectDesignator& glId = DtGlobalObjectDesignator::nullId(),
#endif
      const DtEntityIdentifier& entId = DtEntityIdentifier::nullId());

   virtual ~DtVrfEntityPublisher();

public:
   virtual void tick();

   virtual DtExtEntityStateRepository* entityProcessStateRep();
   virtual DtExtEntityStateRepository* entityStateRep();

   virtual DtExtEntityStateRepository* ensr();

#ifdef DtHLA



   virtual DtEntPublisherDecoder* decoder();

   virtual DtEntPublisherEncoder* encoder();
#endif

   virtual void setPublishesDiGuyInfo(bool has);
   virtual bool publishesDiGuyInfo();

#ifdef DtDIS

   virtual void setSendDiGuyPdus(bool yesNo);

   virtual bool sendDiGuyPdus() const;

   virtual void createAndSendDiGuyPdus();
#endif

   DtStateRepository* sr()
   {
      return myPublisher->sr();
   }

#if DtHLA
   const DtString& name() const
   {
      return myPublisher->name();
   }
#endif

   virtual const DtObjectId& id() const;

   virtual const DtObjectId& localId() const;

   virtual const DtGlobalObjectDesignator& globalId() const;

   virtual void forceUpdate();

   virtual bool sendVrfObjectData();

   virtual DtEntityPublisher* entityPublisher();

   virtual void setSendVrfObjectDataRecord(bool shouldSend);

public:
   // Sets the time to update the vrf data message.  The message will
   // be sent on this time (default is five seconds) or if the data
   // as seen by remote is different that the current time.  If time
   // is set to be -1, it will only be sent if the data is different
   static void setVrfDataTimeThreshold(DtTime time);
   static DtTime vrfDataTimeThreshold();

private:
   DtVrfEntityPublisher(const DtVrfEntityPublisher&);
   DtVrfEntityPublisher& operator=(const DtVrfEntityPublisher&);

protected:

   DtVrfEntityPublisher();

   void initialize(const DtEntityType& type, DtExerciseConn* conn,
#if DtHLA
      const DtGlobalObjectDesignator& glId,
#endif
      const DtEntityIdentifier& entId);

   virtual bool sendVrfDataUpdate();

   virtual bool needsVrfObjectDataUpdate();

   virtual bool sendMessage(const DtSimulationAddress& receiver,
      DtSimInterfaceContent* message);
   virtual bool setContentForNet(DtDataInteraction* dataInter,
      DtSimInterfaceContent* content) const;
   virtual void sendMessageInteraction(const DtSimulationAddress& receiver,
      DtDataInteraction& data);

protected:

   static void dataInteractionCallback(DtDataInteraction* i, void* usr);

   virtual void processSendVrfObjectDataMessage(DtDataInteraction* interaction);

public:

   virtual void processDataInteraction(DtDataInteraction* i);

protected:

   DtEntityPublisher*   myPublisher;

   // For heartbeating for DtIfVrfObjectData messages
   DtTime myTimeLastVrfDataSend;
   static DtTime theVrfDataTimeThreshold;
   bool                 myPublishesDIGuyInfo; // true if there is DI-Guy info to be published

   static bool          myDiGuyEncodersSetup;

};