simTerrainRequestManager.h

Go to the documentation of this file.

/*******************************************************************************
** Copyright (c) 2013 MAK Technologies, Inc.
** All rights reserved.
*******************************************************************************/


#pragma once

#include "vrfobjcore/vrfobjcoreDefines.h"
#include <vrfutil/asyncJobMapEntry.h>
#include <vrfmsgs/ifComputeRoute.h>
#include <vrfmsgs/ifRequestIntersectionInformation.h>
#include <vrfmsgs/ifIntersectionInformationResponse.h>
#include <vrfmsgs/ifRequestDynamicTerrainInformation.h>
#include <vrfmsgs/ifDynamicTerrainInformationResponse.h>
#include <terrainInterface/terrainInterface.h>
#include <vrfmsgs/ifOsgEarthCacheProgress.h>
#include <tbb/spin_mutex.h>

#include <list>

class DtSimManager;
class DtIfComputeRoute;
class DtSimulationAddress;
class DtSimMessage;
class DtIfOsgEarthCacheRequest;
class DtIfOsgEarthCacheInformationRequest;
class DtIfOsgEarthCacheCancelRequest;

class DT_DLL_vrfobjcore DtSimTerrainRequestManager
{
protected:
   struct PendingIntersection;
   class PendingDynamicTerrainInformation;

public:
   static DtSimTerrainRequestManager* create(DtSimManager*);

   explicit DtSimTerrainRequestManager(DtSimManager* mgr);

   virtual ~DtSimTerrainRequestManager();

   virtual void init();

   virtual void tick();

   virtual void process(const DtIfComputeRoute& msg, const DtSimulationAddress& from);

   virtual void setIntersectionRecheckPeriod(double);
   double intersectionRecheckPeriod() const
   {
      return myIntersectionRecheckPeriod;
   }

   virtual void setVectorFeatureLookup(const DtString&);
   const DtString& vectorFeatureLookup() const
   {
      return myVectorFeatureLookup;
   }

   virtual void terrainClosed();

protected:
   static void intersectionRequestCallback(DtSimMessage*, void* usr);
   virtual void processIntersectionRequest(DtIfRequestIntersectionInformation*);

   virtual bool processPendingIntersection(PendingIntersection&);

   static void osgEarthCacheRequestCallback(DtSimMessage*, void* usr);
   virtual void processOsgEarthCacheRequest(DtIfOsgEarthCacheRequest*);

   static void osgEarthCacheInformationRequestCallback(DtSimMessage*, void* usr);
   virtual void processOsgEarthCacheInformationRequest(DtIfOsgEarthCacheInformationRequest*);

   static void osgEarthCacheCancelRequestCallback(DtSimMessage*, void* usr);
   virtual void processOsgEarthCacheCancelRequest(DtIfOsgEarthCacheCancelRequest*);

   static void cacheProgressCallback(int reqeustId, int mapNodeId, int current, const DtString& layer, double elapsedTime, void*);
   virtual void processCacheProgress(int reqeustId, int mapNodeId, int current, const DtString& layer, double elapsedTime);

protected:
   DtSimManager* mySimManager;

   typedef boost::shared_ptr<DtAsyncJobMapEntry> EntryPtr;

   struct Record
   {
      Record(const EntryPtr& entry, const DtSimulationAddress& addr, const DtIfComputeRoute& msg)
         : entry(entry), address(addr), message(msg) { }

      EntryPtr entry;
      DtSimulationAddress address;
      DtIfComputeRoute message;
   };

   bool processRecord(const Record&);

   typedef std::list<Record> Records;
   Records myComputeRouteJobs;

   struct PendingIntersection
   {
      std::vector<bool> awaiting;
      DtIfRequestIntersectionInformation request;
      DtIfIntersectionInformationResponse response;
      double nextCheckTime;
   };

   typedef std::vector<PendingIntersection> PendingIntersectionRequest;

   PendingIntersectionRequest myPendingIntersectionRequests;

   double myIntersectionRecheckPeriod;
   DtString myVectorFeatureLookup;

   tbb::spin_mutex myOsgEarthCacheInfoProgress;
   typedef std::map<int, std::map<int, DtIfOsgEarthCacheProgress> > OsgEarthProgressReports;
   OsgEarthProgressReports myOsgEarthProgressReports;
};