BaseDaq.hh

Go to the documentation of this file.

#ifndef BASEDAQ_h
#define BASEDAQ_h

#include <queue>
#include <string>
#include <stdexcept>
#include "boost/thread/thread.hpp"
#include "boost/thread/condition.hpp"
#include "boost/thread/mutex.hpp"
#include "RawEvent.hh"


class BaseDaq 
{
public:
  enum STATUS{ 
    NORMAL=0, 
    INIT_FAILURE, 
    BUS_ERROR, 
    COMM_ERROR, 
    GENERIC_ERROR 
  };
  

  BaseDaq() throw(std::runtime_error);
  
  virtual ~BaseDaq();
  
  STATUS GetStatus(){ return _status; }
  
  void ResetStatus(){ _status=NORMAL; }

  virtual int Initialize() = 0;
  
  virtual int Update() = 0;
  
  virtual int Calibrate() {return 0;}
  
  virtual int StartRun();
   
  RawEventPtr GetNextEvent(int timeout=-1);
  
  int GetEventsReady(){ return _events_queue.size(); }
  
  virtual int EndRun(bool force=false);


  void operator()(){ DataAcquisitionLoop(); }

protected:
  
  virtual void DataAcquisitionLoop()=0;
  void PostEvent(RawEventPtr event);
  
  static bool _is_constructed; 
  STATUS _status; 
  
  bool _is_running; 
  boost::thread _daq_thread; 
  std::queue<RawEventPtr> _events_queue; 
  boost::mutex _queue_mutex; 
  boost::condition_variable _event_ready; 
  boost::condition_variable _event_taken; 
  static const size_t MAX_QUEUE_SIZE = 10; 
  int _n_queuesize_warnings;   
};

#endif