simInternalCommunicationManager.h

Go to the documentation of this file.

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



#ifndef simInternalCommunicationManager_h
#define simInternalCommunicationManager_h

#include "vrfobjcore/vrfobjcoreDefines.h"
#include <list>
#include "vrfmsgs/vrfObjectMessage.h"
#include <deque>
#include <tbb/spin_mutex.h>

class DtSimManager;
class DtSimInternalCommunicationInterface;
class DtVrfObject;

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

public:
   static DtSimInternalCommunicationManager* create(DtSimManager* simMgr);

   typedef tbb::spin_mutex Mutex;

protected:
   DtSimInternalCommunicationManager(DtSimManager* 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();

protected:

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

   virtual void deliverMessageLocally(const DtVrfObjectMessage* message);

   virtual void deliverMessageRemotely(const DtVrfObjectMessage* message);

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

protected:

   DtSimManager* mySimManager;
   typedef std::list<DtSimInternalCommunicationInterface*> DtCommInterfaceList;
   DtCommInterfaceList myCommInterfaceList;

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

   mutable Mutex myMessageMutex;
};

#endif