globalPlanManager.h

Go to the documentation of this file.

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



#pragma once

#include "vrfplanmgr/vrfplanmgrDefines.h"
#include <map>
#include <vector>
#include <vlutil/vlString.h>
#include <vrfutil/rwUUID.h>

#include <boost/unordered_map.hpp>

class DtVrfObject;
class DtPlan;
class DtSimStatement;
class DtIfPlan;
class DtString;
class DtSimManager;
class DtSimMessage;
class DtlInputStream;

class DT_DLL_vrfplanmgr DtGlobalPlanManager
{
public:
   typedef boost::unordered_map<DtUUID, DtVrfObject*> GlobalPlans;

public:
   DtGlobalPlanManager(DtSimManager* 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(DtVrfObject* object, void* usr);

   virtual void objectAdded(DtVrfObject* object);

   static void objectAboutToBeRemovedCallback(DtVrfObject* object, void* usr);

   virtual void objectAboutToBeRemoved(DtVrfObject* 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:
   GlobalPlans myGlobalPlans;

   DtSimManager* mySimManager;
   bool myReadingPlanFile;
};