vrfEntityPub.h

Go to the documentation of this file.

/*******************************************************************************
** Copyright (c) 2006 MAK Technologies, Inc.
** All rights reserved.
*******************************************************************************/
/*******************************************************************************
** $RCSfile: vrfEntityPub.h,v $ $Revision: 1.11 $ $State: Exp $
*******************************************************************************/

#ifndef VRFENTITYPUB_H
#define VRFENTITYPUB_H

#include <vl/entityPub.h>
#include <vrfExtObjects/vrfExtObjectsDefines.h>
#include <vrfExtObjects/vrfObjIdGen.h>
#include <vl/dataInter.h>

#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,
      const DtGlobalObjectDesignator& id = DtVrfObjectIdGenerator::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

#ifdef DtDIS

   virtual void setSendDiGuyPdus(bool yesNo);

   virtual bool sendDiGuyPdus() const;
#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();
   
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:
   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;
};

#endif