DtDeCommunicator.h

Go to the documentation of this file.

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

#pragma once

#include <vrvUtil/DtVirtualBaseClass.h>
#include <vrvCore/DtDeRecord.h>
#include <boost/signal.hpp>
#include <list>
#include <string>

namespace makVrv
{
   class DtDe;
   class DtTcpServer;
   class DtUdpServer;
   class DtTcpMessageClient;
   class DtMessageDispatcher;
   class DtDriverConfiguration;
   class DtIgCommunicatorSignaler;
   class DtDeRemoteDisplayReconnector;

   class DT_DLL_VRVCORE DtDeCommunicator
   {
   public:

      friend class DtDeCommunicatorCreator;
      friend class DtDeRemoteDisplayReconnector;
      friend class DtThreadedDisplayReconnector;

      typedef std::list<DtDeRecord> IgRecords;

      virtual ~DtDeCommunicator();

      virtual bool initialize();

      virtual void listenForMasterIg();

      virtual bool hasMasterIg() const;

      virtual void disconnectMasterIg(const std::string& masterName);

      bool connectToSlaveIg(const std::string& slaveAddr,int port, std::string& igNameOut);

      void disconnectSlaveIg(const std::string& name, bool lostConnection=false);

      virtual void tick();

      /*virtual const DtDriverConfiguration& configuration() const;*/

      virtual void addIgRecord(const DtDeRecord& record);

      virtual void removeIgRecord(const DtDeRecord& record, bool lostConnection=false );

      DtDeRecord& hostIgRecord();

      DtDeRecord* findRecordByIgName(const std::string& igName);

      DtDeRecord* findRecordByDisplayName(const std::string& displayName);

      bool masterIgOnly() const;

      const IgRecords& connectedIgs() const;

      virtual const std::string& name() const;

      static const char* className();    

   protected:

      DtDeCommunicator(DtDe& de, DtDriverConfiguration& config);     
      
      bool validateSlaveConnection( const std::string& ipAddr );

      void invalidateSlaveConnection( const std::string& ipAddr );

      virtual void addSlave(DtTcpMessageClient* client, std::string& igNameOut );
     
   protected:

      static const char* myClassName;

      bool myUseUdpForUpdates;
      DtDe& myDe;
      DtDriverConfiguration& myConfiguration;      
      std::string myName;
      IgRecords myIgRecords;
      DtTcpServer* myTcpServer;
      DtUdpServer* myUdpServer;
      DtIgCommunicatorSignaler& mySignaler;
      DtDeRemoteDisplayReconnector* myDeRemoteDisplayReconnector;
   };

   class DT_DLL_VRVCORE DtIgCommunicatorSignaler : public DtVirtualBaseClass
   {

   public:

      static DtIgCommunicatorSignaler& instance(DtDe& de);

      virtual ~DtIgCommunicatorSignaler();



      boost::signal<void (const std::string&)> signal_masterIgConnected;

      boost::signal<void (const std::string&)> signal_masterIgLost;

      boost::signal<void (const DtDeRecord&)> signal_clientAdded;

      boost::signal<void (const std::string& clientName, bool lostConnection)> signal_clientToByDeleted;

      boost::signal<void (const std::string&)> signal_clientModified;


   protected:

      DtIgCommunicatorSignaler();

   };


   class DT_DLL_VRVCORE DtDeCommunicatorCreator : public DtVirtualBaseClass
   {
   public:

      static DtDeCommunicatorCreator& instance(DtDe&);

      static void registerInstance(DtDe& de,DtDeCommunicatorCreator*);

      virtual DtDeCommunicator* create(DtDe& de, DtDriverConfiguration& config);
   };

}