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 <list>

class DtSimManager;
class DtIfComputeRoute;
class DtSimulationAddress;
class DtIfRequestIntersectionInformation;
class DtSimMessage;

class DT_DLL_vrfobjcore DtSimTerrainRequestManager
{
protected:
   struct PendingIntersection;

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

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;
};