embeddedEntityInfoManager.h

Go to the documentation of this file.

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


#pragma once

#include "vrfobjcore/scriptedTaskManager.h"
#include "vrfobjcore/vrfobjcoreDefines.h"

#include "vrftasks/radioMessageTypes.h"
#include "vrfmsgs/messageTypes.h"

#include <list>
#include <map>

#include <tbb/spin_rw_mutex.h>

class DtObjectType;
class DtPrintInfoCacheCommand;
class DtSimulationServices;
class DtSimMessage;
class DtLocalObject;
class DtLocalObjectManager;

struct DtEmbeddedEntity;

class DT_DLL_vrfobjcore DtEmbeddedEntityInfoManager
{
public:
   DtEmbeddedEntityInfoManager(DtSimulationServices* simManager, DtLocalObjectManager*);
   ~DtEmbeddedEntityInfoManager();

   virtual bool init();

   virtual bool hasCachedDataFor(const DtObjectType& objType) const;

   virtual bool typeIsQueuedForUpdate(const DtObjectType& objType) const;

   virtual const std::vector<DtEmbeddedEntity> embeddedEntityListFor(const DtObjectType& objType)const;
   virtual const std::vector<DtSetMessageType> availableSetsFor(const DtObjectType& objType)const;
   virtual const std::vector<DtSimTaskMessageType> availableTasksFor(const DtObjectType& objType) const;

   virtual void performCacheUpdates();

   virtual void suspend();

   virtual void resume();

   virtual void resetCache();

   static void eeInfoCacheRequestCallback(DtSimMessage* msg, void* usrData);
   virtual void processEeInfoCacheRequest(DtSimMessage* msg);

   virtual std::string toString();

   virtual void tick();

protected:

   virtual bool isCachableType(const DtObjectType&) const;

   virtual void queueCacheUpdateFor(const std::vector<DtEmbeddedEntity>& entities, const DtVector& position);

   virtual DtLocalObject* createPrototypeObject(const DtObjectType& objType, bool& created);

   virtual std::vector<DtEmbeddedEntity> retrieveEmbeddedEntityList(const DtLocalObject* const obj);
   virtual std::vector<DtSetMessageType> retrieveAvailableSets(const DtLocalObject* const obj);
   virtual std::vector<DtSimTaskMessageType> retrieveAvailableTasks(const DtLocalObject* const obj);

   virtual void populateCacheUsing(const DtLocalObject* const obj, bool suppressRecursion);

   virtual void processObjectAdded(const DtLocalObject& obj);

   static void scriptUpdatedCallback(const DtScriptedTaskManagerCallbackInfo& info, void* usrData);
   virtual void processScriptUpdatedCallback(const DtScriptedTaskManagerCallbackInfo& info);

   virtual void sendCacheResponseFor(const DtObjectType& requestedType);

   virtual void addTaskBinding(const DtObjectType& objType, const DtSimTaskMessageType& taskType);
   virtual void removeTaskBinding(const DtObjectType& objType, const DtSimTaskMessageType& taskType);

   virtual bool cannotBeEmbedded(const DtLocalObject&) const;

   virtual void cachePrototype(const DtObjectType& objType);

private:
   DtEmbeddedEntityInfoManager(const DtEmbeddedEntityInfoManager& orig);

   DtEmbeddedEntityInfoManager& operator=(const DtEmbeddedEntityInfoManager& orig);

protected:

   DtSimulationServices* mySimulationServices;
   DtLocalObjectManager* myObjectManager;
   
   std::vector<DtLocalObject*> myPrototypesToDelete;
   std::map<DtObjectType, std::vector<DtEmbeddedEntity> > myEmbeddedEntityListCache;
   std::map<DtObjectType, std::vector<DtSetMessageType> > myAvailableSetsCache;
   std::map<DtObjectType, std::vector<DtSimTaskMessageType> > myAvailableTasksCache;

   std::set<DtObjectType> myTypesToCache;

   DtPrintInfoCacheCommand* myPrintInfoCacheCommand;

   mutable tbb::spin_rw_mutex myMutex;

   bool mySuspended;
};