rfxServer.h

Go to the documentation of this file.

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


#pragma once

#include <radarFxServer/export.h>

#include <radarFxShared/locklessQueue.h>
#include <radarFxShared/rfxMessage.h>

#include <map>
#include <string>
#include <vrvUtil/DtVirtualBaseClass.h>

class DtThread;
class DtInetSocket;
class DtInetTcpSocket;
class DtInetSocketMgr;

namespace makVrv
{
   class DtDe;
}

namespace makRadarFx
{
   class DtRadarFxDriver;

   //default port
   const int DtRadarFXPort = 4567;

   class DT_DLL_RFXSERVER DtRadarFxServer
   {
   public:
      //CTOR/DTOR
      DtRadarFxServer(DtRadarFxDriver& driver, int port = 4567, bool allowMultiple=false);
      virtual ~DtRadarFxServer();

      virtual void initializeServer();
      virtual void shutdownServer();

      virtual void setPort(int port);

      virtual int port() const;

      virtual void sendMessage(DtBaseMessage& request);

      virtual DtBaseMessage* nextMessage();

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

   protected:
      virtual bool handleSocketAddition(DtInetSocket* socket);
      virtual bool handleSocketRemoval(DtInetSocket* socket);

      static bool socketAdditionCallback(DtInetSocket* sock, void* usr);
      static bool socketRemovalCallback(DtInetSocket* sock, void* usr);

      DtRadarFxDriver& myDriver;

      DtLocklessQueue<DtBaseMessage*> myOutgoingQueue;
      DtLocklessQueue<DtBaseMessage*> myIncomingQueue;
      DtInetSocketMgr* mySocketManager;
      int myPort;

      bool myAllowMultipleClients;

      static void workerFunction(void* usr, volatile bool* stop);
      DtThread* myWorkerThread;
      bool myShouldQuit;

      static double theDefaultHeatbeatTimeout;

      typedef std::map<std::string, DtInetTcpSocket*> ClientRequestMap;
      ClientRequestMap myClientRequestMap;

      typedef std::list<DtInetTcpSocket*> ClientSocketList;
      ClientSocketList myClientSockets;
   };

   class DT_DLL_RFXSERVER DtRadarFxServerCreator : public makVrv::DtVirtualBaseClass
   { 
   public:
      static DtRadarFxServerCreator& instance(makVrv::DtDe& de);

      static void registerInstance(makVrv::DtDe& de, DtRadarFxServerCreator* instance);     

      virtual DtRadarFxServer* create(DtRadarFxDriver& driver, 
         int port = 4567, bool allowMultiple=false);
   };

}