vrfDebugDrawConnector.h

Go to the documentation of this file.

#pragma once

#include <vrfDebugDrawConnector/export.h>
#include <vrfDebugDrawConnector/locklessQueue.h>
#include <vrfDebugDrawConnector/vrfMessageHandler.h>
#include <vrfDebugDrawConnector/vrfMessageFactory.h>

#include <vlutil/vlInetTcpSocket.h>

#include <list>
#include <string>

class DtThread;

namespace makVrf
{
   const int DtDisplayPort = 4580;
   
   class DtBaseMessage;

   template <typename Ret, typename Param0>
   class DtDelegate;

   class DT_DLL_DEBUGDRAWCONNECTOR DtDebugDrawConnector
   {
   public:
      typedef DtDelegate<void, DtDebugDrawConnector*> DtConnectionDelegate;

      DtDebugDrawConnector();
      virtual ~DtDebugDrawConnector();

      virtual void connect(const std::string& address, int port = DtDisplayPort, const std::string& simAddress = "", bool attemptRetry=true);

      virtual void disconnect();

      virtual bool isOk();

      virtual void tick();

      virtual void sendMessage(DtBaseMessage& request);

      virtual DtMessageHandler& messageHandler() {return myMessageHandler;}

      virtual void addConnectedCallback(const DtConnectionDelegate& delegate);
      virtual void removeConnectedCallback(const DtConnectionDelegate& delegate);

      virtual void addDisconnectedCallback(const DtConnectionDelegate& delegate);
      virtual void removeDisconnectedCallback(const DtConnectionDelegate& delegate);

      virtual DtMessageFactory& messageFactory() { return myMessageFactory; }

      virtual unsigned int nextId();

      virtual std::string& requesterName();

      static double defaultRetryTimeout();
      static void setDefaultRetryTimeout(double val);

      static double defaultHeartbeatTimeout();
      static void setDefaultHeatbeatTimeout(double val);

   protected:
      DtInetAddr findFirstNetworkDeviceAddress(bool& found) const;

      DtMessageHandler myMessageHandler;

      std::list<DtConnectionDelegate> myConnectionCallbacks;
      std::list<DtConnectionDelegate> myDisconnectionCallbacks;

      DtMessageFactory myMessageFactory;
      unsigned int myNextId;
      std::string myRequestorName;

      DtLocklessQueue<DtBaseMessage*> myOutgoingQueue;
      DtLocklessQueue<DtBaseMessage*> myIncomingQueue;
      DtThread* myWorkerThread;
      DtInetTcpSocket* mySocket;

      bool myShouldRetryConnect;
      double myRetryTimeout;
      std::string myAddress;
      std::string mySimAddress;
      int myPort;

      static void workerFunction(void* data, volatile bool* stop);
      bool myShouldQuit;

      static double theDefaultHeatbeatTimeout;
      static double theDefaultRetryTimeout;
   };
}