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:
typedef boost::signals2::signal<void(ddt::DdtDataTransferLib::ConnectionState)>
    ConnectionStateSignalT;
    
  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();

  ConnectionStateSignalT* ConnectionStateSignal();

  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;
  ConnectionStateSignalT connection_state_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;
  boost::signals2::connection connection_state_connection;
};
 
}  // namespace ddt
 
#endif /* DATAACQUISITION_HPP */