resourceMonitor.h

Go to the documentation of this file.

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



#pragma once

#include "vrfobjcore/vrfobjcoreDefines.h"
#include "vrfobjcore/resourceMonitorInfo.h"
#include <vlutil/vlMachineTypes.h>
#include <vlutil/vlString.h>
#include <vrfutil/rwUUID.h>
#include <tbb/spin_mutex.h>

#include <set>

class DtSimulationServices;
class DtSimMessage;
class DtSimInterfaceMessage;
class DtLocalObject;
class DtIfResourceMonitorResponse;
class DtSimResource;
class DtIfResourceNamesResponse;
class DtSimulationAddress;
class DtSimCondExpr;
class DtSimObject;
class DtLocalObjectManager;

#include <list>

typedef std::map<DtUUID, DtResourceMonitorInfo> DtResourceMonitorList;

class DT_DLL_vrfobjcore DtResourceMonitor
{
private:

   DtResourceMonitor(const DtResourceMonitor & orig);

   const DtResourceMonitor & operator=(const DtResourceMonitor & orig);

   DtResourceMonitor();

public:
   DtResourceMonitor(DtSimulationServices * simManager, DtLocalObjectManager*);

   virtual ~DtResourceMonitor();

   virtual bool init();

   virtual bool registerInterfaceCallbacks();

   virtual void tick(double simTime);

   virtual void restart();

   virtual void setEnabled(bool b);
   bool enabled() const { return myEnabled; };

public:
   static void resourceMonitorRequestCallback(DtSimMessage* msg, void* usr);
   virtual void processResourceMonitorRequest(DtSimInterfaceMessage* msg);

   static void currentResourceRequestCallback(DtSimMessage* msg, void* usr);
   virtual void processCurrentResourceRequest(DtSimInterfaceMessage* msg);

   static void resourceNamesRequestCallback(DtSimMessage* msg, void* usr);
   virtual void processResourceNamesRequestCallback(DtSimInterfaceMessage* msg);

   virtual void processSimObjectAboutToBeRemoved(const DtSimObject* msg);

   void setUpdateOnTick(bool b) { myUpdateOnTick = b; };
   bool updateOnTick() const { return myUpdateOnTick; };

   virtual void resourcesChangedFor(const DtSimObject*);
   const std::set<DtUUID>& resourcesChangedList() const;

protected:
   virtual void publishResourcesFor(DtIfResourceMonitorResponse& response,
      const DtLocalObject* obj, const std::list<DtString>& resources);

   virtual void publishResourceNamesFor(DtIfResourceNamesResponse& response,
      const DtLocalObject* obj);

   virtual void addMonitorResource(DtLocalObject*,
      const DtString& resourceName, const DtSimulationAddress& sender,
      int iMonitorBy, const DtFloat64& iMonitorPeriod, bool stopMonitoring);

   virtual DtResourceMonitorList::iterator resourceMonitorInfo(const DtUUID&);

   virtual void removeMonitorReference(const DtUUID&, const DtString& resourceName,
      const DtSimulationAddress& sender);

   virtual void removeMonitorReference(const DtUUID&);

   virtual void removeAllMonitorReferencesTo(const DtSimulationAddress& addr);

   virtual bool shouldAddResource(const DtSimResource* resourceItem);

   virtual bool resourceChanged(const DtUUID&) const;

   DtSimulationServices* simulationServices() const { return mySimulationServices; };

protected:
   DtSimulationServices*  mySimulationServices;
   DtResourceMonitorList myMonitoringResources;
   bool      myEnabled;
   bool      myUpdateOnTick;

   std::set<DtUUID>  myResourcesChangedList;
   tbb::spin_mutex myMonitoringResourcesMutex;

   DtLocalObjectManager* myObjectManager;
};

inline const std::set<DtUUID>& DtResourceMonitor::resourcesChangedList() const
{
   return myResourcesChangedList;
}