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>
#include <boost/signals2.hpp>

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

#include <list>

namespace makVrfEvents
{
   class DtEvent;
}

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:
   virtual void processResourceMonitorRequest(const makVrfEvents::DtEvent&);

   virtual void processSimObjectAboutToBeRemoved(const DtSimObject* msg);

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

   virtual void resourcesChangedFor(const DtSimObject*, bool nextSendIsFullSend = false);
   const std::map<DtUUID, bool>& resourcesChangedList() const;

protected:
   virtual void publishResourcesFor(const DtLocalObject* entity, std::vector<DtEntityType> resources, bool includeFull = false, unsigned requestId = 0);

   virtual void addMonitorResource(DtLocalObject*, const std::vector<DtEntityType>& resourceName, const DtEntityIdentifier& sender,
      int iMonitorBy, const DtFloat64& iMonitorPeriod, bool stopMonitoring);

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

   virtual void removeMonitorReference(const DtUUID&, const std::vector<DtEntityType>& resourceName,
      const DtEntityIdentifier& sender);

   virtual void removeMonitorReference(const DtUUID&);

   virtual void removeAllMonitorReferencesTo(const DtEntityIdentifier& addr);

   virtual bool resourceChanged(const DtUUID&, bool& fullSend) const;

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

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

   std::map<DtUUID, bool>  myResourcesChangedList;
   tbb::spin_mutex myMonitoringResourcesMutex;
   mutable tbb::spin_mutex myResourcesChangedListMutex;

   DtLocalObjectManager* myObjectManager;
   boost::signals2::scoped_connection myResourceRequestConnection;
};

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