ddtDataBroker.hpp

Go to the documentation of this file.

// @copyright
// (c) Copyright ESO 2020
// All Rights Reserved
// ESO (eso.org) is an Intergovernmental Organization, and therefore special
// legal conditions apply.
//
// @file ddtDataBroker.hpp
// @brief Data Broker.
//
// A Data Broker is the access point in the system for data producer
// applications to inject data into the system and for data consumer
// applications to receive data produced by the system. It therefore creates a
// MAL Server waiting for connections.
//
// @author Carsten Mannel, CGI
// @since  2020/09/25
//
 
#ifndef DDTDATABROKER_HPP_
#define DDTDATABROKER_HPP_
 
#include <condition_variable>
#include <csignal>
#include <fstream>
 
#include "ddt/commandLineParserBuilder.hpp"
#include "ddt/ddtConnectionManager.hpp"
#include "ddt/ddtLogger.hpp"
 
class DdtDataBroker {
 public:
  DdtDataBroker();
 
  virtual ~DdtDataBroker();
 
  int Run();
 
  bool Init(int argc, char** argv);
 
 private:
  const std::string ExtractPort(const std::string uri, int& string_index) const;
 
  bool CheckPath(std::string& uri, const int string_index);
 
  ddt::DdtLogger* logger;
  std::string uri_string;
  std::string config_file;
  const std::string URI_PATH{"/broker"};
};
 
#endif /* DDTDATABROKER_HPP_ */