DtGuiThreadNetworkCallbackManager.h

Go to the documentation of this file.

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



#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::DtGuiThreadNetworkCallbackManager::instance(myDe).simMessageSignal(_type).connect(_function);
#define DISCONNECT_FOR_SIM_MESSAGE(_type, _function) makVrf::DtGuiThreadNetworkCallbackManager::instance(myDe).simMessageSignal(_type).disconnect(_function);

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

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

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

#define CONNECT_FOR_RADIO_MESSAGE(_type, _function) makVrf::DtGuiThreadNetworkCallbackManager::instance(myDe).radioMessageSignal(_type).connect(_function);
#define DISCONNECT_FOR_RADIO_MESSAGE(_type, _function) makVrf::DtGuiThreadNetworkCallbackManager::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 DtGuiThreadNetworkCallbackManager : public DtQueuedManager
   {
   public:
      typedef std::map<int, SimMessageSignal*> DtVrfMessageCallbackMap;
      typedef std::map<DtAdminContentMessageType, ObjectMessageCallbackSignal*> DtAdminContentMessageCallbackMap;
      typedef std::map<DtSimReportMessageType, ObjectMessageCallbackSignal*> DtSimReportMessageCallbackMap;
      typedef std::map<DtSimTaskMessageType, ObjectMessageCallbackSignal*> DtSimTaskMessageCallbackMap;
      typedef std::map<DtSetMessageType, ObjectMessageCallbackSignal*> DtSetMessageCallbackMap;
      typedef std::map<std::string, NetworkInterfaceCallbackSignal*> DtNetworkCallbackMap;

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

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

   public:

      virtual SimMessageSignal& simMessageSignal(int type);


      virtual ObjectMessageCallbackSignal& objectMessageSignal(const DtAdminContentMessageType& type);


      virtual ObjectMessageCallbackSignal& radioMessageSignal(const DtSimReportMessageType& type);
      virtual ObjectMessageCallbackSignal& radioMessageSignal(const DtSimTaskMessageType& type);
      virtual ObjectMessageCallbackSignal& radioMessageSignal(const DtSetMessageType& 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 registerAdminMessageCallbackFor(const DtAdminContentMessageType& type);
      virtual void unregisterAdminMessageCallbackFor(const DtAdminContentMessageType& type);

      virtual void registerReportMessageCallbackFor(const DtSimReportMessageType& type);
      virtual void unregisterReportMessageCallbackFor(const DtSimReportMessageType& type);

      virtual void registerTaskMessageCallbackFor(const DtSimTaskMessageType& type);
      virtual void unregisterTaskMessageCallbackFor(const DtSimTaskMessageType& type);

      virtual void registerSetMessageCallbackFor(const DtSetMessageType& type);
      virtual void unregisterSetMessageCallbackFor(const DtSetMessageType& type);

   protected:
      DtVrfMessageCallbackMap myCallbacks;
      DtAdminContentMessageCallbackMap myAdminMessageCallbacks;
      DtSimReportMessageCallbackMap myReportMessageCallbacks;
      DtSimTaskMessageCallbackMap myTaskMessageCallbacks;
      DtSetMessageCallbackMap mySetMessageCallbacks;
      DtNetworkCallbackMap myNetworkCallbackMap;
   };
}