include/vrfGuiCore/DtNetworkMessageCallbackManager.h

Go to the documentation of this file.

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



#pragma once

#include <vrfGuiCore/vrfGuiCore.h>
#include <vrfGuiCore/DtQueuedManager.h>
#include <vrfGuiCore/DtGuiThreadVrfRemoteController.h>
#include <vrfGuiCore/DtCommentInteractionInterface.h>

#include <vrvUtil/signalslib.h>
#include <vrvCore/DtDe.h>

#include <vrfplan/plan.h>

class DtSimMessage;


#define CONNECT_FOR_SIM_MESSAGE(_type, _function) makVrf::DtNetworkMessageCallbackManager::instance(myDe).simMessageSignal(_type).connect(_function);
#define DISCONNECT_FOR_SIM_MESSAGE(_type, _function) makVrf::DtNetworkMessageCallbackManager::instance(myDe).simMessageSignal(_type).disconnect(_function);

#define CONNECT_FOR_OBJECT_MESSAGE(_type, _function) makVrf::DtNetworkMessageCallbackManager::instance(myDe).objectMessageSignal(_type).connect(_function);
#define DISCONNECT_FOR_OBJECT_MESSAGE(_type, _function) makVrf::DtNetworkMessageCallbackManager::instance(myDe).objectMessageSignal(_type).disconnect(_function);

#define CONNECT_FOR_COMMENT_INTERACTION(_function) makVrf::DtNetworkMessageCallbackManager::instance(myDe).networkInterfaceMessageSignal(DtCommentInteractionInterface::theName()).connect(_function);
#define DISCONNECT_FOR_COMMENT_INTERACTION(_function) makVrf::DtNetworkMessageCallbackManager::instance(myDe).networkInterfaceMessageSignal(DtCommentInteractionInterface::theName()).disconnect(_function);

#define CONNECT_FOR_INTERFACE_MESSAGE(_type, _function) makVrf::DtNetworkMessageCallbackManager::instance(myDe).networkInterfaceMessageSignal(_type).connect(_function);
#define DISCONNECT_FOR_INTERFACE_MESSAGE(_type, _function) makVrf::DtNetworkMessageCallbackManager::instance(myDe).networkInterfaceMessageSignal(_type).disconnect(_function);

#define CONNECT_FOR_RADIO_MESSAGE(_type, _function) makVrf::DtNetworkMessageCallbackManager::instance(myDe).radioMessageSignal(_type).connect(_function);
#define DISCONNECT_FOR_RADIO_MESSAGE(_type, _function) makVrf::DtNetworkMessageCallbackManager::instance(myDe).radioMessageSignal(_type).disconnect(_function);

namespace makVrf
{
   class DtNetworkMessageInterface;

   typedef boost::signal<void (DtSimMessage*)> SimMessageSignal;
   typedef boost::signal<void (const DtVrfObjectMessage*)> ObjectMessageCallbackSignal;
   typedef boost::signal<void (DtNetworkMessageInterface*)> NetworkInterfaceCallbackSignal;

   class DT_DLL_VRFGUICORE DtNetworkMessageCallbackManager : public DtQueuedManager
   {
   public:
      typedef std::map<int, SimMessageSignal*> DtVrfMessageCallbackMap;
      typedef std::map<int, ObjectMessageCallbackSignal*> DtVrfObjectMessageCallbackMap;
      typedef std::map<std::string, NetworkInterfaceCallbackSignal*> DtNetworkCallbackMap;

   public:
      DtNetworkMessageCallbackManager(makVrv::DtDe&);
      virtual ~DtNetworkMessageCallbackManager();

      static DtNetworkMessageCallbackManager& instance(makVrv::DtDe& de);

   public:

      virtual SimMessageSignal& simMessageSignal(int type);


      virtual ObjectMessageCallbackSignal& objectMessageSignal(int type);


      virtual ObjectMessageCallbackSignal& radioMessageSignal(int type);


      virtual NetworkInterfaceCallbackSignal& networkInterfaceMessageSignal(std::string messageName);

      virtual void messageReceived(DtNetworkMessageInterface*);

   protected:
      virtual void registerSimMessageCallbackWithDriver(int t);

      virtual void unregisterSimMessageCallbackWithDriver(int t);

      virtual void processSimMessageCallback(DtNetworkMessageInterface*);

      virtual void vrfObjectMessageCallback(DtSimMessage* msg);

      virtual void processVrfObjectMessageInterfaceCallback(DtNetworkMessageInterface* msg);

      virtual void processVrfObjectMessageCallback(DtVrfObjectMessage* msg, bool forFrontEndOnly = true);

      virtual void registerForCommentInteraction();

      virtual void unregisterForCommentInteraction();

   protected:

      virtual void registerRadioMessageCallbackFor(int type);
      virtual void unregisterRadioMessageCallbackFor(int type);

      virtual void registerObjectMessageCallbackFor(int type);
      virtual void unregisterObjectMessageCallbackFor(int type);

   protected:
      DtVrfMessageCallbackMap          myCallbacks;
      DtVrfObjectMessageCallbackMap    myVrfObjectMessageCallbacks;
      DtNetworkCallbackMap             myNetworkCallbackMap;
   };
}