radarFxConnector.h

Go to the documentation of this file.

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



#pragma once

#include <radarFxConnector/export.h>

#include <radarFxShared/locklessQueue.h>
#include <radarFxShared/rfxMessageHandler.h>
#include <radarFxShared/rfxMessageFactory.h>

#include <vlutil/vlInetTcpSocket.h>

#include <list>
#include <string>

class DtExerciseConnection;
class DtThread;

namespace makRadarFx
{
   const int DtRadarFXPort = 4567;

   class DtBaseMessage;

   template <typename Ret, typename Param0>
   class DtDelegate;

   class RFX_CONNECTOR_DLL DtRadarFxConnector
   {
   public:
      typedef DtDelegate<void, DtRadarFxConnector*> DtConnectionDelegate;

      DtRadarFxConnector();
      virtual ~DtRadarFxConnector();

      virtual void connect(const std::string& address, int port = DtRadarFXPort, 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;
      int myPort;

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

      static double theDefaultHeatbeatTimeout;
      static double theDefaultRetryTimeout;
   };
}