tEntityInterface.h

Go to the documentation of this file.

//********************************************************************
//********************************************************************
//********************************************************************
//********************************************************************
#ifndef tEntityInterface_H_
#define tEntityInterface_H_


#if DtTENA

#include "coLromMapExport.h"
#include <vl/tObjectInterface.h>
#include <vl/tReflectedEnt.h>
#include <vl/entitySR.h>
#include <TENA/Time/Pointer.h>
#include <TENA/GeocentricSpatialReferenceFrame/Pointer.h>
#include <TENA/UniqueID/Includes.h>
#include <TENA/PlatformType/Includes.h>
#include <TENA/Platform/Proxy.h>
#include <TENA/Platform/ProxyPtr.h>
#include <TENA/Platform/ServantPtr.h>
#include <TENA/Platform/Servant.h>

#include <TENA/PlatformDetails/Proxy.h>
#include <TENA/PlatformDetails/ProxyPtr.h>
#include <TENA/PlatformDetails/ServantPtr.h>
#include <TENA/PlatformDetails/Servant.h>

#include <TENA/GeocentricSpatialReferenceFrame/Pointer.h>
#include <vlpi/entityType.h>
#include <vl/globalObjDes.h>

#include <map>
#include <list>

class DT_DLL_COMMONLROM DtEntityInterface: public DtObjectInterface
{
protected:

   class DtEntityServantObject : public DtTenaServantObject
   {
   public:
      DtEntityServantObject( TENA::Platform::ServantPtr sp,
         TENA::PlatformDetails::ServantPtr dp):
            myServantPtr(sp),
            myDetailsServantPtr(dp){}

      virtual ~DtEntityServantObject() {}

      virtual const TENA::Platform::ServantPtr servant() const { return myServantPtr;}

      virtual TENA::Platform::ServantPtr servant() { return myServantPtr;}

      virtual const TENA::PlatformDetails::ServantPtr detailsServant() const 
         { return myDetailsServantPtr; }

      virtual TENA::PlatformDetails::ServantPtr detailsServant() 
         { return myDetailsServantPtr;}

   protected:
       TENA::Platform::ServantPtr myServantPtr;
       TENA::PlatformDetails::ServantPtr myDetailsServantPtr;
   };


public:

   DtEntityInterface(DtExerciseConn* exConn);

   virtual ~DtEntityInterface();

private:

   DtEntityInterface(const DtEntityInterface &other);

   DtEntityInterface& operator=(const DtEntityInterface &other);

public:

   virtual DtTenaServantObject* createServantObject(DtExerciseConn* exConn);

   virtual void processServantCleanup(DtTenaServantObject* servant);

   virtual void subscribe();

   virtual bool needUpdate(const DtStateRepository& stateRep, 
                           const DtStateRepository& asSeenByRemote,
                           bool useThresholding = true);


   virtual void decode(const DtTenaServantObject* servant,
                       DtStateRepository* stateRep)const;

   virtual void encode(DtTenaServantObject* servant, 
                       const DtStateRepository* stateRep,
                       TENA::Time::Pointer timeForStamping,
                       bool forceUpdate = false);

   virtual DtReflectedObject *createReflectedObject()const;

   virtual void processAddition(TENA::Platform::ProxyPtr const &proxy);

   virtual void processUpdate(TENA::Platform::ProxyPtr const &proxy);

   virtual void processRemoval(TENA::Platform::ProxyPtr const &proxy);

   virtual void processAddition(TENA::PlatformDetails::ProxyPtr const &proxy);

   virtual void processUpdate(TENA::PlatformDetails::ProxyPtr const &proxy);

   virtual void processRemoval(TENA::PlatformDetails::ProxyPtr const &proxy);

protected:
   virtual void decode(const TENA::Platform::ImmutablePublicationStatePtr pubStatePtr,
                       DtStateRepository* stateRep)const;

   virtual void decodeDetails(const TENA::PlatformDetails::ImmutablePublicationStatePtr pubStatePtr,
      DtStateRepository* stateRep) const;
   
   virtual bool needDetailsUpdate(const DtEntityStateRepository& stateRep,
      const DtEntityStateRepository& asSeenByRemote);

   virtual void encodeDetails(DtTenaServantObject* servant,
      const DtEntityStateRepository* esr,
      TENA::Time::Pointer timeForStamping) const;

   virtual void checkForWaitingDetails(TENA::Platform::ProxyPtr const &proxy);

   virtual DtForceType tenaForceToVrlinkForce(TENA::Force tenaForce) const;
   virtual TENA::Force vrlinkForceToTenaForce(DtForceType vrlinkForce) const;
protected:

   TENA::GeocentricSpatialReferenceFrame::Pointer myGeocSRF;

   TENA::Platform::SubscriptionInfoPtr mySubscriptionInfoPtr;
   TENA::PlatformDetails::SubscriptionInfoPtr myDetailsSubscriptionInfoPtr;

   typedef std::map<TENA::Platform::ProxyPtr, DtReflectedObject *> PlatProxyToRefObjMap;
   typedef std::map<TENA::PlatformDetails::ProxyPtr, DtReflectedObject*> DetailsProxyToRefObjMap;
   PlatProxyToRefObjMap myRefEntMap;
   DetailsProxyToRefObjMap myRefDetailsMap;

   PlatProxyToRefObjMap myEntityWaitList;
   std::list<TENA::PlatformDetails::ProxyPtr> myDetailsWaitList;
   bool myNeedPlatformUpdate;
   bool myNeedDetailsUpdate;
};


#endif
#endif