globalPlanManager.h

Go to the documentation of this file.

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



#pragma once

//vrf includes
#include <vrfplanmgr/vrfplanmgrDefines.h>

#include <vrfutil/rwUUID.h>

#include <boost/signals2.hpp>

#include <vlutil/vlString.h>

#include <mutex>

#include <map>
#include <vector>
#include <unordered_map>

class DtLocalObject;
class DtSimObject;
class DtPlan;
class DtSimStatement;
class DtIfPlan;
class DtString;
class DtSimulationServices;
class DtLocalObjectManager;
class DtSimMessage;
class DtlInputStream;

class DT_DLL_vrfplanmgr DtGlobalPlanManager
{
public:
   typedef std::unordered_map<DtUUID, DtLocalObject*> GlobalPlans;

public:
   DtGlobalPlanManager(DtLocalObjectManager* simManager);
   
   virtual ~DtGlobalPlanManager();

   virtual bool init();

   virtual bool readPlanFile(const DtString& filename);
   virtual bool readPlanFileFromZipFile(const DtFilename& scenarioZipFile, const DtString& filename);

   const GlobalPlans& globalPlans() const { return myGlobalPlans; };

   virtual void sendPlanList();

   virtual void completeInitialization();

   virtual void addOrUpdatePlan(DtPlan* aNewPlan);

protected:
   virtual void registerInterfaceMessageCallbacks();

   static void requestPlanListCallback(DtSimMessage* msg, void* usr);

   static void objectAddedCallback(const DtLocalObject* object, void* usr);

   virtual void objectAdded(const DtLocalObject* object);

   virtual void processObjectAboutToBeRemoved(const DtSimObject* object);
   virtual void processObjectNameChanged(const DtSimObject* object);

   static void setPlanCallback(DtSimMessage* msg, void* usr);
   virtual void processSetPlan(DtSimMessage* msg);

   static void deletePlanCallback(DtSimMessage* msg, void* usr);

   virtual void processDeletePlan(DtSimMessage* msg);

   static void launchGlobalPlanCallback(DtSimMessage* msg, void* usr);

   virtual void processLaunchGlobalPlan(DtSimMessage* msg);

   virtual void setPlan(DtIfPlan* plan);

   virtual void watchPlan(DtPlan*);

   static void planStatementChangedCallback(const DtPlan&, void* usr);
   virtual void processPlanStatementChanged(const DtPlan&);

   virtual bool processPlanStream(DtlInputStream*);

private:
   DtGlobalPlanManager();
   DtGlobalPlanManager(const DtGlobalPlanManager& orig);
   DtGlobalPlanManager& operator=(const DtGlobalPlanManager& orig);

protected:
   std::recursive_mutex myMutex;
   GlobalPlans myGlobalPlans;

   DtSimulationServices* mySimulationServices;
   DtLocalObjectManager* myObjectManager;
   bool myReadingPlanFile;

   struct Signals
   {
      boost::signals2::connection removalConnection;
      boost::signals2::connection nameChangedConnection;
   };

   typedef std::map<DtUUID, Signals> SignalsMap;
   SignalsMap mySignalsMap;
};