dataAcquisition.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 dataAcquisition.hpp
// @brief Data acquisition class, offers access to data stream acquisition
// functions.
//
// This file is part of the DDT Image Handling Library and
// provides a class that offers access to the data stream acquisition functions.
//
// @author Christoph Bortlisz, CGI
// @since  2020/08/19
//
 
#ifndef DATAACQUISITION_HPP
#define DATAACQUISITION_HPP
 
#include <sys/stat.h>
 
#include <algorithm>
#include <boost/bind/bind.hpp>
#include <boost/signals2/signal.hpp>
#include <boost/tokenizer.hpp>
#include <cctype>
 
// Subscriber Library
#include "ddt/ddtDataSubscriber.hpp"
#include "ddt/ddtDataTransferFactory.hpp"
#include "ddt/ddtLogger.hpp"
 
typedef boost::signals2::signal<void()> signal_t;
 
namespace ddt {
 
class DataAcquisition {
 public:
  DataAcquisition();
 
  virtual ~DataAcquisition();
 
  void set_logger(ddt::DdtLogger* const in_logger);
 
  void AttachDataStream(const std::string data_stream_id);
 
  void DetachDataStream(const std::string data_stream_id);
 
  void ProcessNewData();
 
  signal_t* DataAvailableSignal();
 
  ddt::DataSample* get_DataSample();
 
  bool get_AttachedToStream() const;
 
 protected:
  ddt::DdtLogger* logger;
 
 private:
  void initialize();
 
  signal_t data_available_signal;
  ddt::DataSample* data_sample;
 
  std::unique_ptr<ddt::DdtDataSubscriber> subscriber;
 
  bool attached_to_stream;
  std::string current_stream_id;
  boost::signals2::connection connection;
};
 
}  // namespace ddt
 
#endif /* DATAACQUISITION_HPP */