ARTDAQConsumer.h

#ifndef _ots_ARTDAQConsumer_h_
#define _ots_ARTDAQConsumer_h_
 
#include "otsdaq/ARTDAQReaderCore/ARTDAQReaderProcessorBase.h"
 
// #include "artdaq/Application/BoardReaderApp.hh"
// #include "otsdaq/Configurable/Configurable.h"
#include "otsdaq/DataManager/DataConsumer.h"
 
// #include <future>
// #include <memory>
// #include <string>
 
namespace ots
{
class ARTDAQConsumer
    : public DataConsumer,
      public ARTDAQReaderProcessorBase  
{
  public:
    ARTDAQConsumer(std::string              supervisorApplicationUID,
                   std::string              bufferUID,
                   std::string              processorUID,
                   const ConfigurationTree& theXDAQContextConfigTree,
                   const std::string&       configurationPath);
    virtual ~ARTDAQConsumer(void);
 
    //  void initLocalGroup(int rank);
    //  // void destroy          (void);
    //
    //  // void configure         (fhicl::ParameterSet const& pset);
    //  void configure(int rank);
    //  void halt(void);
    void pauseProcessingData(void) override;
    void resumeProcessingData(void) override;
    void startProcessingData(std::string runNumber) override;
    void stopProcessingData(void) override;
    //  // int universalRead      (char *address, char *returnValue) override {;}
    //  // void universalWrite    (char *address, char *writeValue) override {;}
  private:
    bool workLoopThread(toolbox::task::WorkLoop* /*workLoop*/) override { return false; }
    
    //  std::unique_ptr<artdaq::BoardReaderApp> fragment_receiver_ptr_;
    //  std::string                             name_;
    //
};
 
}  // namespace ots
 
#endif