rfxDriver.h

Go to the documentation of this file.

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


#pragma once

#include <radarFxServer/export.h>

#include <radarFxShared/rfxMessageFactory.h>

#include <vrvCore/DtDriver.h>

#include <string>
#include <queue>
#include <chrono>

namespace makVrv
{
   class DtDebugLog;
}

namespace makRadarFx
{
   class DtBaseProcess;
   class DtRadarFxServer;

   class DT_DLL_RFXSERVER DtRadarFxDriver : public makVrv::DtDriver
   {
   public:
      DtRadarFxDriver(makVrv::DtAgentManager& am);

      virtual ~DtRadarFxDriver();

      virtual const std::string& className() const;

      virtual bool onStart();
      virtual bool onStop();
      virtual bool onTick();

      virtual DtBaseProcess* currentProcess() {return myCurrentProcess;}
      
      virtual bool isReadyToProcess();

      virtual DtRadarFxServer* server() {return myServer;}

      virtual makVrv::DtDe& de() {return myDe;}

   protected:

      virtual void logMessageIfNecessary(DtBaseMessage* message, const std::vector<std::pair<std::string, std::string>>* additionalInfo = nullptr);

   protected:
      DtRadarFxServer* myServer;
      makVrv::DtDe& myDe;

      std::map<unsigned int, std::string> myRequestTypeToDisplayName;
      std::map<unsigned int, makVrv::DtDebugLog*> myRequestTypeToLogStream;

      std::chrono::system_clock::time_point myRequestStartTime;

      typedef std::list<DtBaseProcess*> DtBaseProcessQueue;
      DtBaseProcessQueue myProcessQueue;

      DtBaseProcess* myCurrentProcess;

      std::string myClassName;
   };

}