ddtSubscriberSimulator.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 ddtSubscriberSimulator.hpp
// @brief Simulator for receiving data.
//
// This is a simulator for receiving data from a publisher application. The
// simulator connects to a local Broker and either receives data from a remote
// publisher or from a local publisher.
//
// @author Matthias Grimm, CGI
// @since  2020/06/30
//
 
#ifndef DDTSUBSCRIBERSIMULATOR_HPP_
#define DDTSUBSCRIBERSIMULATOR_HPP_
 
#include <boost/algorithm/string.hpp>
#include <boost/bind/bind.hpp>
#include <boost/signals2/signal.hpp>
#include <iostream>
 
#include "ddt/commandLineParserBuilder.hpp"
#include "ddt/ddtDataSubscriber.hpp"
#include "ddt/ddtDataSubscriberApplication.hpp"
#include "ddt/ddtDataTransferFactory.hpp"
#include "ddt/ddtEncDecMultiDim.hpp"
#include "ddt/ddtEncDecMultiLayer.hpp"
#include "ddt/ddtLogger.hpp"
 
namespace mal = ::elt::mal;
namespace datatransfer = ::elt::ddt::datatransfer;
 
namespace ddt {
 
union R4 {
  float i;
 
  unsigned char c[4];
};
 
class DdtSubscriberSimulator : public DdtDataSubscriberApplication {
 public:
  DdtSubscriberSimulator();
 
  virtual ~DdtSubscriberSimulator();
 
  int Run();
 
  bool Init(int argc, char** argv);
 
  int RunImageTransfer();
 
  int RunOscilloscopeTransfer();
 
  int RunMultiDimensionalArrayTransfer();
 
 private:
  void ProcessNewData();
  void ProcessNewDataOsc();
  void ProcessNewDataMultiDim();
 
  std::unique_ptr<DdtDataSubscriber> subscriber;
 
  DdtLogger* logger;
  CommandLineParserBuilder* builder;
 
  std::string broker_uri;
  std::string data_stream_identifier;
  int reading_interval;
  std::string remote_broker_uri;
  int mode;
  bool statistics;
 
  std::atomic<bool> processing_active;
 
  boost::signals2::connection connection;
};
 
}  // namespace ddt
 
#endif /* DDTSUBSCRIBERSIMULATOR_HPP_ */