ARTDAQReaderProcessorBase.h

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