dataAcquisition.hpp

Go to the documentation of this file.

 
#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()> SignalT;
 
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();
 
  SignalT* DataAvailableSignal();
 
  ddt::DataSample* get_DataSample();
 
  ddt::DdtStatistics* get_DataStatistics();
 
  bool get_AttachedToStream() const;
 
  void set_RetrieveStatsFlag(bool value);
 
 protected:
  ddt::DdtLogger* logger;
 
 private:
  void Initialize();
 
  SignalT data_available_signal;
  ddt::DataSample* data_sample;
  ddt::DdtStatistics statistics_sample;
 
  std::unique_ptr<ddt::DdtDataSubscriber> subscriber;
 
  bool retrieve_stats;
  bool attached_to_stream;
  std::string current_stream_id;
  boost::signals2::connection connection;
};
 
}  // namespace ddt
 
#endif /* DATAACQUISITION_HPP */