griddedDataInterface.h

Go to the documentation of this file.

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


#if DtTENA

#pragma once

#include <makLromMapper/makLromMapExport.h>
#include <vl/globalObjectDesignator.h>
#include <vl/griddedDataRepository.h>
#include <vlTena/objectInterface.h>
#include <vlTena/griddedDataPdu.h>
#include <vlutil/vlMachineTypes.h>

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

#include <list>
#include <map>

namespace MAKVrExchange
{

   namespace DtTenaBroker
   {

      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();

         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;

      private:

         DtGriddedDataInterface( const DtGriddedDataInterface& other );

         DtGriddedDataInterface& operator = ( const DtGriddedDataInterface& other );

      protected:

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

      };

   }
}

#endif // DtTENA