DtThreadedDisplayReconnector.h

Go to the documentation of this file.

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


#pragma once

#include <vrvCore/vrvCore.h>

#include <vrvCore/DtTcpMessageClient.h>

#include <vrvUtil/DtLocklessQueue.h>
#include <vrvUtil/DtDisplayConfiguration.h>

#include <vlutil/vlRunnable.h>

#include <string>
#include <list>

class DtThread;

namespace makVrv
{
   class DtDe;
   class DtDisplayConfiguration;
   class DtDeCommunicator;

   class DtThreadedDisplayReconnector : protected DtRunnable
   {
   private:
      DtThreadedDisplayReconnector();

   public:
      DtThreadedDisplayReconnector( DtDe& de, DtDeCommunicator& deCommunicator, double retryPeriod );

      virtual ~DtThreadedDisplayReconnector();

      virtual void addLostClient( const std::string& ipAddr, int port, 
         const DtDisplayConfiguration& displayConfig );

      const std::string& ipAddr() const;

      int port() const;

      const DtDisplayConfiguration& displayConfig() const;

      DtLocklessQueue<DtTcpMessageClient*>* getQueue();

      virtual void run();


   protected:
      DtDe& myDe;
      DtDeCommunicator& myDeCommunicator;
      std::string myIpAddr;
      int myPort;
      DtDisplayConfiguration myDisplayConfig;
      DtLocklessQueue<DtTcpMessageClient*>* myClientReturnQueue;
      DtThread* myReconnectThread;
      double myLastRetry;
      double myRetryPeriod;
      bool myReconnected;
   };
}