DtDeCommunicator.h

Go to the documentation of this file.

/******************************************************************************
** Copyright (c) 2010 MAK Technologies, Inc.
** All rights reserved.
******************************************************************************/
/******************************************************************************
** $RCSfile: DtDeCommunicator.h,v $ $Revision: 1.39 $ $State: Exp $
******************************************************************************/


#ifndef DtDeCommunicator_H_
#define DtDeCommunicator_H_

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

namespace makVrv
{
   class DtDe;
   class DtTcpServer;
   class DtMessageDispatcher;
   class DtDriverConfiguration;
   class DtIgCommunicatorSignaler;

   class DT_DLL_VRVCORE DtDeCommunicator
   {
   public:

      friend class DtDeCommunicatorCreator;

      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);

      virtual void tick();

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

      virtual void addIgRecord(const DtDeRecord& record);

      virtual void removeIgRecord(const DtDeRecord& record);

      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);     
      
   protected:

      static const char* myClassName;

      DtDe& myDe;
      DtDriverConfiguration& myConfiguration;      
      std::string myName;
      IgRecords myIgRecords;
      DtTcpServer* myTcpServer;
      DtIgCommunicatorSignaler& mySignaler;
   };

   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&)> 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);
   };

}

#endif