simInternalCommunicationManager.h

Go to the documentation of this file.

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

#pragma once

#include "vrfobjcore/vrfobjcoreDefines.h"
#include <set>
#include "vrfmsgs/vrfObjectMessage.h"
#include <deque>
#include <tbb/spin_mutex.h>
#include <boost/signals2.hpp>

class DtSimulationServices;
class DtSimInternalCommunicationInterface;
class DtLocalObject;
struct DtVrfObjectUUIDChangedCallbackInfo;

class DT_DLL_vrfobjcore DtSimInternalCommunicationManager
{
private:
   DtSimInternalCommunicationManager();
   DtSimInternalCommunicationManager(const DtSimInternalCommunicationManager& orig);
   DtSimInternalCommunicationManager& operator=(const DtSimInternalCommunicationManager& orig);

public:
   DtSimInternalCommunicationManager(DtSimulationServices* simMgr);

   virtual bool init();

public:
   virtual ~DtSimInternalCommunicationManager();


   virtual void registerCommunicationInterface(DtSimInternalCommunicationInterface* commIf);
   virtual void unregisterCommunicationInterface(DtSimInternalCommunicationInterface* commIf);

   virtual void deliverMessage(const DtVrfObjectMessage* message);

   virtual void tick();

   virtual void clearQueue();

   DtSimulationServices* simulationServices() const
   {
      return mySimulationServices;
   }

   virtual void deliverMessageLocally(const DtVrfObjectMessage* message);

   virtual void deliverMessageRemotely(const DtVrfObjectMessage* message);

protected:

   static void deliverRadioMessageCallback(DtSimMessage* msg, void* usr);
   virtual void processDeliverRadioMessage(DtSimMessage* msg);

   virtual bool objectShouldReceiveMessage(DtLocalObject* vrfObj, const DtVrfObjectMessage* msg);

   virtual void processUUIDChanged(const DtUUID& oldUUID, const DtUUID& newUUID);

protected:

   DtSimulationServices* mySimulationServices;
   typedef boost::unordered_map<DtUUID, std::set<DtSimInternalCommunicationInterface*> > DtCommInterfaceList;
   DtCommInterfaceList myCommInterfaceList;

   typedef std::deque<DtVrfObjectMessage*> DtMessageDeque;
   DtMessageDeque myMessagesToDeliver;

   typedef tbb::spin_mutex Mutex;
   mutable Mutex myMessageMutex;
 
   mutable tbb::spin_mutex myInterfaceMutex;

   boost::signals2::scoped_connection myUUIDChangedConnection;
};