tGridDataInterface.h

Go to the documentation of this file.

//********************************************************************
//********************************************************************
//********************************************************************
//********************************************************************

#ifndef tGridDataInterface_H_
#define tGridDataInterface_H_

#if DtTENA

#include "makLromMapExport.h"
#include <vlutil/vlMachineTypes.h>
#include <vl/tObjectInterface.h>
#include <vl/gridDataSR.h>
#include <vl/globalObjDes.h>

#include <MAK/GriddedData/ServantPtr.h>
#include <MAK/GriddedData/ProxyPtr.h>
#include <MAK/GriddedData/ImmutablePublicationStatePtr.h>
#include <MAK/GriddedData/SubscriptionInfoPtr.h>
#include <TENA/GeocentricSpatialReferenceFrame/Pointer.h>

#include <map>
#include <list>


//
class DT_DLL_MAKLROM DtGriddedDataInterface: public DtObjectInterface
{
protected:
   class DtGriddedDataServantObject : public DtTenaServantObject
   {
   public:
      DtGriddedDataServantObject( MAK::GriddedData::ServantPtr sp):myServantPtr(sp){}

      virtual ~DtGriddedDataServantObject() {}

      virtual const MAK::GriddedData::ServantPtr servant() const { return myServantPtr;}

      virtual MAK::GriddedData::ServantPtr servant() { return myServantPtr;}

   protected:
       MAK::GriddedData::ServantPtr myServantPtr;
   };

public:
   DtGriddedDataInterface(DtExerciseConn* exConn);

   virtual ~DtGriddedDataInterface();

private:
   DtGriddedDataInterface(const DtGriddedDataInterface &other);

   DtGriddedDataInterface& operator=(const DtGriddedDataInterface &other);

public:
   virtual DtTenaServantObject* createServantObject(DtExerciseConn* exConn);

   virtual void processServantCleanup(DtTenaServantObject* servantObject);

   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(MAK::GriddedData::ProxyPtr const &proxy);

   virtual void processUpdate(MAK::GriddedData::ProxyPtr const &proxy);

   virtual void processRemoval(MAK::GriddedData::ProxyPtr const &proxy);


protected:
   virtual void decode(const MAK::GriddedData::ImmutablePublicationStatePtr pubStatePtr,
                       DtStateRepository* stateRep)const;

   virtual bool needGridAxisInfo(const DtGriddedDataRepository& stateRep,
      const DtGriddedDataRepository& asSeenByRemote, int index) const;

   virtual bool needGridDataInfo(const DtGriddedDataRepository& stateRep,
      const DtGriddedDataRepository& asSeenByRemote, int index) const;
protected:

   MAK::GriddedData::SubscriptionInfoPtr mySubscriptionInfoPtr;
   typedef std::map<MAK::GriddedData::ProxyPtr, DtReflectedObject *> ProxyToRefObjMap;
   ProxyToRefObjMap myRefGriddedDataMap;
   ProxyToRefObjMap myGriddedDataWaitList;
   TENA::GeocentricSpatialReferenceFrame::Pointer myGeocSrf;
};


#endif
#endif