navGeneration.h

Go to the documentation of this file.

/*******************************************************************************
** Copyright (c) 2015 MaK Technologies, Inc.
** All rights reserved.
*******************************************************************************/


#pragma once

#include <vrfNavigation/vrfNavigationDefines.h>
#include <vrfNavigation/navigationGeneratorInput.h>
#include <vrfNavigation/navSectorName.h>
#include <vrfutil/rwNavRuntimeConfig.h>
#include <terrainInterface/terrainProcessPolygonsBox.h>
#include <features/featureGeometry.h>

#include <matrix/vlVector.h>

#include <tbb/queuing_rw_mutex.h>
#include <tbb/mutex.h>
#include <tbb/tbb_thread.h>

#include <string>
#include <list>

class DtRwNavigationProfile;
class DtRwNavigationProfileList;
class DtTerrainInterface;
class DtFeatureTagVolumeGenerator;
class DtRwDynamicTerrainInformation;

namespace MAKVRinTerra
{
   class DtFeature;
   class DtFeatureGeometry;
}

namespace Kaim
{
   class GeneratorInputOutput;
   class GeneratorSector;
}

struct DT_DLL_vrfNavigation DtNavTagColor
{
   DtNavTagColor() : red(0), green(0), blue(0) {};
   unsigned int red;
   unsigned int green;
   unsigned int blue;
};

struct DT_DLL_vrfNavigation DtInputNavTag
{
   DtInputNavTag() : isExclusive(false) {};
   std::vector<unsigned long> navTagData;
   DtNavTagColor color;
   bool isExclusive; 
   bool uniquelyIdentify; 
};

struct DT_DLL_vrfNavigation DtInputNavTagVolume
{
   std::vector<DtVector> points;
   unsigned int navTagDataIndex;
};

struct DT_DLL_vrfNavigation DtNavTagVolumeSet
{
   std::vector<DtInputNavTag> navTagDataList;
   std::vector<DtInputNavTagVolume> navTagVolumeList;
};

class DT_DLL_vrfNavigation DtTagVolumeGenerator
{
public:
   virtual bool generateTagVolumes(const MAKVRinTerra::DtFeatureGeometry& extentBox,
      bool pruneNoGo, const DtRwNavigationProfile* navProfile, DtNavTagVolumeSet& tagVolumes) = 0;
};

class DT_DLL_vrfNavigation DtNavDataGenerator
{
public:

   enum SectorGenerationStatus
   {
      GenerationNotRequested,
      GenerationInProgress,
      GenerationSucceeded,
      GenerationFailed,
      GenerationStopped
   };

   typedef tbb::queuing_rw_mutex RwMutex;
   typedef tbb::mutex Mutex;

   typedef std::map<DtNavSectorDataType, std::vector<char> > NavDataOutputMap;

   struct SectorGenerationThreadInfo
   {
      SectorGenerationThreadInfo(const DtNavSectorName& sn)
         : sectorName(sn) 
         , timeToComplete(-1)
      {
         stop = false;
         status = GenerationNotRequested;
      }

      DtNavSectorName sectorName;
      NavDataOutputMap outputData;
      tbb::atomic<SectorGenerationStatus> status;
      DtString statusMsg;
      std::auto_ptr<tbb::tbb_thread> thread;
      tbb::atomic<bool> stop;
      DtTime timeToComplete;
   };
   typedef std::map<DtNavSectorName, SectorGenerationThreadInfo*> SectorGenerationThreadMap;

   struct TriangleCallbackInfo
   {
      DtNavDataGenerator* generator;
      DtNavTriangles      triangles;
   };


   typedef std::map<DtString, DtString> ProfileRandomIdMap;

   typedef DtNavDataGenerator* (*DtNavDataGeneratorCreatorFcn)();

   struct EdgePoints
   {
      EdgePoints(const DtVector& p1 = DtVector::zero(),
         const DtVector& p2 = DtVector::zero(), unsigned t = 0)
         : point1(p1), point2(p2), tag(t) {};

      DtVector point1;
      DtVector point2;
      unsigned tag;
   };
   typedef bool(*DynamicTerrainNavEdgeFunction)(const DtRwDynamicTerrainInformation& dynTerrInfo,
      std::list<EdgePoints>* edges, int sectorX, int sectorY, unsigned edgeTag, void* usr);
   typedef bool(*FeatureDataNavEdgeFunction)(const MAKVRinTerra::DtFeature& feature,
      std::list<EdgePoints>* edges, int sectorX, int sectorY, unsigned edgeTag, void* usr);
   typedef std::pair<DynamicTerrainNavEdgeFunction, void*> DynamicTerrainNavEdgeFunctionInfo;
   typedef std::pair<FeatureDataNavEdgeFunction, void*> FeatureDataNavEdgeFunctionInfo;

   static DtNavDataGenerator* create();

   virtual ~DtNavDataGenerator();

   virtual bool initialize(DtTerrainInterface* terrainInterface,
      const DtFilename& navGenConfigFile,
      const DtFilename& runtimeConfigFile,
      const DtFilename& outputPath,
      const DtFilename& terrainFile,
      bool generateFeatureTagVolumes);

   void addNavEdgeFromDynamicTerrainFunction(const DtString& name, DynamicTerrainNavEdgeFunction fcn, void* usr);

   void addNavEdgeFromFeatureDataFunction(const DtString& name, FeatureDataNavEdgeFunction fcn, void* usr);

   virtual void setTransitionPointSpacing(double spacing);

   virtual double transitionPointSpacing() const;

   virtual bool generate();

   virtual bool generateSector(const DtNavSectorName& sectorName);

   virtual SectorGenerationStatus getGenerateSectorStatus(const DtNavSectorName& sectorName,
      NavDataOutputMap& outputNavData);

   virtual const DtRwNavigationProfile* profileConfig(const DtString& profileName) const;

   virtual const DtRwNavGenConfig* navGenConfig() const;

   static void setCreator(DtNavDataGeneratorCreatorFcn creatorFcn);

   static void setNavDataDirectory(const DtFilename& navDataDir);

   static const DtFilename& navDataDirectory();

   static DtFilename replaceSubstrings(const DtFilename& original);

protected:

   DtNavDataGenerator();

   virtual void doGenerateSector(SectorGenerationThreadInfo* sectorGenInfo);

   virtual bool shouldStop(SectorGenerationThreadInfo* sectorGenInfo);

   static void triangleCallback(DtTerrainTriangleStruct& triangle, void* usr);
   virtual void processTriangle(DtTerrainTriangleStruct& triangle, DtNavTriangles& triangles);

   static void trianglesFinalizeCallback(int status, void* usr);
   virtual void processTrianglesFinalize(int status, DtNavTriangles& triangles);

   virtual std::list<DtVector> calculateTransitionPointLocations();

   virtual void getProfileRandomIds(DtRwStringList& profiles, ProfileRandomIdMap& randomIds);

   virtual bool generateProfileNavData(
      const DtRwNavigationProfile* profile,
      DtString randomId);
   
   virtual bool generateSectorNavData(
      const DtRwNavigationProfile* profile,
      const DtNavSectorName& sectorName,
      NavDataOutputMap& outputData,
      SectorGenerationThreadInfo* sectorGenInfo = 0);

   virtual bool generateTransitionPoints(const DtRwNavigationProfile* profile,
      Kaim::GeneratorInputOutput& generatorInputOutput,
      const DtString& randomId, const DtFilename& navDataOutputDir);

   virtual bool generateSectorTransitionPoints(const DtRwNavigationProfile* profile,
      Kaim::GeneratorSector* sector, const DtString& randomId,
      const DtFilename& navDataOutputDir = DtFilename::nullFilename(),
      std::vector<char>* buffer = 0,
      SectorGenerationThreadInfo* sectorGenInfo = 0);

   virtual bool generateCoverPoints(const DtRwNavigationProfile* profile,
      Kaim::GeneratorInputOutput& generatorInputOutput,
      const DtString& randomId, const DtFilename& navDataOutputDir);

   virtual bool generateSectorCoverPoints(const DtRwNavigationProfile* profile,
      Kaim::GeneratorSector* sector, const DtString& randomId,
      const DtFilename& navDataOutputDir = DtFilename::nullFilename(),
      std::vector<char>* buffer = 0,
      SectorGenerationThreadInfo* sectorGenInfo = 0);

   virtual bool generateNavEdges(const DtRwNavigationProfile* profile,
      Kaim::GeneratorInputOutput& generatorInputOutput,
      const DtString& randomId, const DtFilename& navDataOutputDir);

   virtual bool generateSectorNavEdges(const DtRwNavigationProfile* profile,
      Kaim::GeneratorSector* sector, const DtString& randomId,
      const DtFilename& navDataOutputDir = DtFilename::nullFilename(),
      std::vector<char>* buffer = 0,
      SectorGenerationThreadInfo* sectorGenInfo = 0);

   virtual void registerDefaultNavEdgeGenerationFunctions();


   static bool edgeFromIntersectionNormal(const DtRwDynamicTerrainInformation& dynTerrInfo,
      std::list<EdgePoints>* edges, int sectorX, int sectorY, unsigned edgeTag, void* usr);



   static bool edgeFromPathFeature(const MAKVRinTerra::DtFeature& feature,
      std::list<EdgePoints>* edges, int sectorX, int sectorY, unsigned edgeTag, void* usr);


   MAKVRinTerra::DtFeatureGeometry& extentFeatureGeometry();

   MAKVRinTerra::DtFeatureGeometry& extentFeatureGeometry(int sectorX, int sectorY);

   virtual bool terrainHeight(const DtPoint& p, double& height, double* min=0, double* max=0) const;

   virtual void setNumberOfProgressSteps(int steps);
   virtual void nextProgressStep(const DtString& stepName, int numSubSteps = 0);
   virtual void nextProgressSubStep();
   virtual void progressComplete();
   virtual void outputProgress(const DtString& stepName = DtString::nullString());


   virtual DtOutputStream& detailOutput();

   virtual DtOutputStream& milestoneOutput();

   virtual DtOutputStream& notableOutput();

   virtual DtOutputStream& errorOutput();



private:

   DtNavDataGenerator(const DtNavDataGenerator&);

   DtNavDataGenerator& operator=(const DtNavDataGenerator& orig);

protected:

   DtRwNavRuntimeConfig myNavRuntimeConfig;

   DtTerrainInterface* myTerrainInterface;

   DtNavigationGeneratorInput myNavGenInput;

   mutable RwMutex myNavGenInputMutex;

   mutable Mutex myNavDataGenMutex;

   DtFilename myNavGenConfigFile;

   DtFilename myRuntimeConfigFile;

   DtFilename myOutputPath;

   DtFilename myTerrainFile;

   DtFeatureTagVolumeGenerator* myFeatureTagVolumeGenerator;

   mutable RwMutex myFeatureTagVolumeGeneratorMutex;

   double myTransitionPointSpacing;

   SectorGenerationThreadMap mySectorThreads;

   MAKVRinTerra::DtFeatureGeometry myExtentFeatureGeometry;

   bool myIsInitialized;

   int myNumberOfProgressSteps;
   int myNumberOfProgressSubSteps;
   int myCurrentProgressStep;
   int myCurrentProgressSubStep;

   std::map<DtString, DynamicTerrainNavEdgeFunctionInfo> myDynamicTerrainNavEdgeFunctions;

   std::map<DtString, FeatureDataNavEdgeFunctionInfo> myFeatureDataNavEdgeFunctions;

   DtClock myClock;

   static DtFilename theNavDataDir;
   static DtNavDataGeneratorCreatorFcn theCreatorFcn;
};