vrfDatabaseLogger.h

Go to the documentation of this file.

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

#include <vrfMsgTransport/vrfMsgTransportDefines.h>
#include <vrfMsgTransport/vrfDatabaseLoggerInterface.h>
#include <vrfMsgTransport/vrfDatabaseEvent.h>
#include <tbb/concurrent_queue.h>

class DT_DLL_vrfMsgTransport DtVrfDatabaseLogger : public DtVrfDatabaseLoggerInterface
{
public:

   const static DtString theScenarioNameParamName;
   const static DtString theScenarioRunIdParamName;
   const static DtString theScenarioSimTimeParamName;
   const static DtString theScenarioSimAddressParamName;
   const static DtString theScenarioDateAndTimeAtStartParamName;
   const static DtString theScenarioRealWorldTimeStartParamName;

   virtual ~DtVrfDatabaseLogger() override;

   virtual void initialize(const DtRwDatabaseLoggerConfig& config,
      const DtSimulationAddress& simAddress,
      std::unique_ptr<DtVrfDatabaseConnection> conn) override;

   virtual bool isEnabled() const override { return true; };

   virtual bool isEventEnabled(DtVrfDatabaseEvent::EventType eventType) const override;

   virtual bool logEvent(DtVrfDatabaseEvent::EventType eventType, const DtVrfDatabaseEvent& event) override;

   virtual bool logEvent(DtVrfDatabaseEvent::EventType eventType, DtVrfDatabaseEvent&& event) override;

   virtual bool logEvent(DtVrfDatabaseEvent::EventType eventType, std::function<DtVrfDatabaseEvent()> f) override;

   virtual std::unique_ptr<DtVrfDatabaseEvent> popEvent() override;

   virtual void setScenarioLoadInformation(int runId, const DtFilename& scenarioName,
      DtTime simTime) override;

   virtual void setScenarioRunInformation(const DtFilename& scenarioName,
      DtTime simTime, DtTime dateAndTimeOfDay, DtTime realWorldTime) override;

   virtual unsigned queueSize() override { return myEventQueue.size(); };

   virtual void forceDatabaseUpdate() override;

   static DtVrfDatabaseLoggerInterface* create() { return new DtVrfDatabaseLogger(); };

   static DtString type() { return "standard-database-logger"; };

protected:

   DtVrfDatabaseLogger();

private:

   DtVrfDatabaseLogger(const DtVrfDatabaseLogger& other);

   DtVrfDatabaseLogger& operator=(const DtVrfDatabaseLogger& other);

protected:

   tbb::concurrent_bounded_queue<DtVrfDatabaseEvent*> myEventQueue;
   std::vector<bool> myEnabledEventTypes;
};