debugDrawRenderer.h

Go to the documentation of this file.

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


#pragma once

#include <debugDrawRenderer/debugDrawRendererExport.h>
#include <vrfDebugDrawConnector/locklessQueue.h>
#include <vrfDebugDrawConnector/vrfMessage.h>
#include <vrfDebugDrawConnector/vrfDebugDrawConnector.h>
#include <map>
#include <string>
#include <list>
#include <vrvUtil/DtVirtualBaseClass.h>

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

namespace makVrv
{
   class DtDe;
}

namespace makVrf
{
   class DtDebugDrawRendererDriver;

   class DT_DLL_DEBUGDRAWRENDERER DtDebugDrawRenderer
   {
   public:
      //CTOR/DTOR
      DtDebugDrawRenderer(DtDebugDrawRendererDriver& driver, int port = DtDisplayPort, bool allowMultiple=false);
      virtual ~DtDebugDrawRenderer();

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

      DtDebugDrawRendererDriver& 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_DEBUGDRAWRENDERER DtDebugDrawRendererCreator : public makVrv::DtVirtualBaseClass
   { 
   public:
      static DtDebugDrawRendererCreator& instance(makVrv::DtDe& de);

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

      virtual DtDebugDrawRenderer* create(DtDebugDrawRendererDriver& driver,
         int port = DtDisplayPort, bool allowMultiple=false);
   };
}