DtMessageDispatcher.h

Go to the documentation of this file.

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


#pragma once

#include <map>
#include <list>
#include <string>
#include <vector>
#include <vrvUtil/DtMessage.h>

#include <vrvCore/vrvCore.h>

namespace makVrv
{

   class DtDe;
   class DtProctor;
   class DtProxy;
   class DtMessage;
   class DtMessageClient;
   class DtUdpMessageClient;

   class DT_DLL_VRVCORE DtMessageDispatcher
   {
   public:

      enum
      {
         theInternalControlId = 1
      };

      enum 
      {
         id_AddInterfaceMap = 1
      };

      DtMessageDispatcher(bool isMaster);

      typedef unsigned short IGIInterfaceID;

      virtual ~DtMessageDispatcher();    

      void registerProctor(int classId, DtProctor* handler);

      DtProctor* findProctor(int classId);

      void deliverFromClients();

      void deliverToClients();

      void queueForDelivery(DtMessage* msg, bool toClients = true,bool toLocalInterface = false);

      void addClient(DtMessageClient* client);

      void removeClient(DtMessageClient* client);

      void setUdpClient(DtUdpMessageClient* udpClient);

      void removeUdpClient();


      bool hasClients() const;

      bool isMaster() const;

      void setIsMaster(bool isMaster);

   protected:
     
      void sendInterfaceMapToClients(IGIInterfaceID id, const std::string& name);      

      bool myIsMasterFlag;

      IGIInterfaceID myFreeInterfaceId;

      typedef std::list<DtMessageClient*> ClientList;
      ClientList myClients;

      DtUdpMessageClient* myUdpClient;

      typedef std::map<std::string,IGIInterfaceID> NameIdMap;
      NameIdMap myIdLookUp;

      typedef std::map<IGIInterfaceID,DtProxy*> IdInterfaceMap;
      IdInterfaceMap myInstanceLookUp;

      typedef std::list<DtProxy*> InterfaceList;
      InterfaceList myUnknownInterfaceList;

      typedef std::map<int, DtProctor*> ProctorTable;
      ProctorTable myProctors;

      typedef std::vector<DtMessage*> MessageList;
      MessageList myMessageQueue;
   };

}