include/vrfGuiCore/DtVrfCurrentTaskManager.h

Go to the documentation of this file.

/******************************************************************************
** Copyright (c) 2009 MAK Technologies, Inc.
** All rights reserved.
******************************************************************************/
/******************************************************************************
** $RCSfile: DtVrfCurrentTaskManager.h,v $ $Revision: 1.1 $ $State: Exp $
******************************************************************************/



#pragma once

#include <vrfGuiCore/vrfGuiCore.h>

#include <vrvUtil/DtVirtualBaseClass.h>
#include <vrvCore/DtStateView.h>
#include <vrvCore/DtEntityState.h>

#include <vrftasks/simTask.h>

#include <boost/signal.hpp>
#include <boost/function.hpp>

class DtSimTask;
class DtVrfObjectMessage;

namespace makVrv
{
   class DtDe;
   class DtSimObjectEntry;
}

namespace makVrf
{
   class DT_DLL_VRFGUICORE DtVrfCurrentTaskManager : public makVrv::DtVirtualBaseClass
   {
   public:

      typedef std::vector<int> Conflicting;
      typedef DtBoost::shared_ptr<DtSimTask> DtSimTaskSharedPtr;
      typedef std::pair<DtSimTaskSharedPtr, Conflicting> TaskInformation;
      typedef std::vector<TaskInformation> EntityTaskInformation;

   public:
      DtVrfCurrentTaskManager(makVrv::DtDe&);
      virtual ~DtVrfCurrentTaskManager();

      static DtVrfCurrentTaskManager& instance(makVrv::DtDe& de);

   public:
      boost::signal<void (const std::string& entityName)> signal_currentTaskChanged;

      virtual void subscribeForTaskInformation(const makVrv::DtUniqueID& simId);
      virtual void unsubscribeForTaskInformation(const makVrv::DtUniqueID& simId, bool all = false);

      typedef boost::function<void (std::string, const EntityTaskInformation&)> DtRequestTaskCallbackFcn;

      virtual void requestCurrentTasksFor(const makVrv::DtUniqueID& simId, DtRequestTaskCallbackFcn);

      virtual const EntityTaskInformation* tasksFor(const makVrv::DtUniqueID& simId) const;

   protected:
      virtual void slot_simObjectEntryAboutToBeRemoved(makVrv::DtSimObjectEntry& entry);
      virtual void processEntityCurrentTaskCallback(const DtVrfObjectMessage* msg);

      virtual makVrv::DtUniqueID isMonitoring(const std::string& e) const;
      virtual makVrv::DtUniqueID isRequesting(const std::string& e) const;

   protected:
      makVrv::DtDe&  myDe;

      typedef std::pair<EntityTaskInformation, int> EntityTasks;

      typedef std::map<makVrv::DtUniqueID, EntityTasks>  DtEntityTaskMap;
      DtEntityTaskMap myTasks;

      typedef std::vector<DtRequestTaskCallbackFcn> DtRequestCallbackVector;
      typedef std::map<makVrv::DtUniqueID, DtRequestCallbackVector> DtRequestCallbackMap;

      DtRequestCallbackMap myTaskRequestCallbacks;
   };
}