objectPublisherDIS.h

Go to the documentation of this file.

/*********************************************************************
** Copyright (c) 1992-2010 VT MAK
** All rights reserved.
*********************************************************************/


#if DtDIS 


#ifndef DtDISObjectPublisher_H_
#define DtDISObjectPublisher_H_


#include <vlutil/vlAttributePduStrategy.h>
#include <vlutil/vlMachineTypes.h>
#include "objectId.h"
#include <vlutil/vlTime.h>

class DT_DLL_VL DtStateRepository;
class DT_DLL_VL DtExerciseConn;
class DT_DLL_VL DtPdu;
class DT_DLL_VL DtAttributePdu;
class DT_DLL_VL DtPduWithAttributeRecordSets;


class DT_DLL_VL DtObjectPublisher
{
public:

   typedef DtAttributePdu * (*DtNonCoupledAttributePduCreator)(const DtPduWithAttributeRecordSets*, void*);

   DtObjectPublisher(DtExerciseConn* conn,
      DtStateRepository* stateRep,
      DtStateRepository* asSeenByRemote, 
      bool okToDeleteStateRep = true);

   virtual ~DtObjectPublisher();

private:

   DtObjectPublisher(const DtObjectPublisher& orig);

   DtObjectPublisher& operator= (const DtObjectPublisher& orig);

public:
   
   virtual DtStateRepository* stateRep();

   virtual DtStateRepository* sr();

   virtual DtExerciseConn* exerciseConn();

   virtual const DtObjectId& localId() const = 0;
   virtual const DtObjectId& id() const = 0;
   virtual const DtGlobalObjectDesignator& globalId() const = 0;

   virtual void forceUpdate()=0;

   virtual void tick() = 0;

   virtual void parallelTick();

   virtual void setTimeThreshold(DtTime time);
   virtual DtTime timeThreshold() const; 

   virtual DtStateRepository* approximateRemoteStateRep();

   virtual DtTime lastTimeUpdated() const;

   virtual DtTime lastSimTimeUpdated() const;

   virtual void setUseCustomThreshold(bool useCustom);

   virtual bool useCustomThreshold();

   virtual void setAttributePduStrategy(DtAttributePduStrategy strat);
   virtual DtAttributePduStrategy attributePduStrategy() const;

public:

   static void setDfltTimeThreshold(DtTime time);

   static DtTime dfltTimeThreshold();


   static DtNonCoupledAttributePduCreator setDefaultNonCoupledAttributePduCreator(DtNonCoupledAttributePduCreator creator);
   static DtNonCoupledAttributePduCreator defaultNonCoupledAttributePduCreator(void);

   DtNonCoupledAttributePduCreator setNonCoupledAttributePduCreator(DtNonCoupledAttributePduCreator creator);
   DtNonCoupledAttributePduCreator nonCoupledAttributePduCreator(void);

protected:


   virtual void send(DtPdu* pdu) const;


protected:

   DtExerciseConn    *myExConn;
   DtStateRepository *myStateRep;
   DtStateRepository *myAsSeenByRemote;
   bool               myOkToDeleteStateRepFlag;
   bool               myUseCustomThreshold;

   DtTime             myTimeThreshold;

   mutable DtTime     mySimTimeLastUpdate;

   mutable DtTime     myRealTimeLastUpdate;

   // Publisher instance specific override for non-coupled Attribute PDU creation
   DtNonCoupledAttributePduCreator myNonCoupledAttributePduCreator;

   // Default non-coupled Attribute PDU creator
   static DtNonCoupledAttributePduCreator theDefaultNonCoupledAttributePduCreator;

   // How we should send attribute PDUs
   DtAttributePduStrategy myAttributePduStrategy;

protected:

   static DtTime      theDfltTimeThreshold;

};

inline DtStateRepository* DtObjectPublisher::stateRep()
{
   return myStateRep;
}

inline DtStateRepository* DtObjectPublisher::sr()
{
   return myStateRep;
}

inline DtExerciseConn* DtObjectPublisher::exerciseConn()
{
   return myExConn;
}

inline DtStateRepository* DtObjectPublisher::approximateRemoteStateRep()
{
  return myAsSeenByRemote;
}

#endif   //DtObjectPublisher_H_
#endif   //DtDIS