ddtPublisherSimulator.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 ddtPublisherSimulator.hpp
// @brief Simulator for sending data.
//
// This is a simulator for publishing data. Data is read from a directory
// containing FITS files.
//
// @author Carsten Mannel, CGI
// @since  2020/09/25
//
 
#ifndef DDTPUBLISHERSIMULATOR_HPP_
#define DDTPUBLISHERSIMULATOR_HPP_
 
#include <boost/bind/bind.hpp>
#include <boost/filesystem.hpp>
#include <boost/signals2/signal.hpp>
#include <random>
 
#include "ddt/commandLineParserBuilder.hpp"
#include "ddt/ddtDataPublisher.hpp"
#include "ddt/ddtDataPublisherApplication.hpp"
#include "ddt/ddtDataTransferFactory.hpp"
#include "ddt/ddtEncDecBiDim.hpp"
#include "ddt/ddtEncDecMultiDim.hpp"
#include "ddt/ddtEncDecMultiLayer.hpp"
#include "ddt/ddtLogger.hpp"
 
#include <cpl.h>
 
namespace datatransfer = ::elt::ddt::datatransfer;
 
using namespace ddt;
using namespace boost::filesystem;
 
namespace ddt {
 
class DdtPublisherSimulator : public DdtDataPublisherApplication {
 public:
  DdtPublisherSimulator();
 
  virtual ~DdtPublisherSimulator();
 
  int Run();
 
  bool Init(int argc, char** argv);
 
  int RunImageTransfer();
 
  int RunOscilloscopeTransfer();
 
  int RunMultiDimensionalArrayTransfer();
 
  int RunNumericalSampleArrayTransfer();
 
  int RunSegmentedImageTransfer();
 
 private:
  DdtLogger* logger;
  CommandLineParserBuilder* builder;
 
  std::string broker_uri;
  std::string data_stream_identifier;
  int publishing_interval;
  int num_samples_in_buffer;
  std::string image_folder;
  int mode;
  bool checksum;
 
  const int LATENCY = 10000;  
  const int DEADLINE = 10;    
};
 
}  // namespace ddt
 
#endif /* DDTPUBLISHERSIMULATOR_HPP_ */