Processor.h

Go to the documentation of this file.

#ifndef MARLINMT_PROCESSOR_h
#define MARLINMT_PROCESSOR_h 1

// -- marlinmt headers
#include <marlinmt/Component.h>
#include <marlinmt/EventStore.h>
#include <marlinmt/RunHeader.h>
#include <marlinmt/MarlinMTConfig.h>  // for Marlin version macros

// -- std headers
#include <map>
#include <string>
#include <memory>
#include <iostream>
#include <sstream>

namespace marlinmt {

  class Application ;
  class ProcessorApi ;

  class Processor : public Component {
    friend class ProcessorApi ;

  private:
    // prevent users from making (default) copies of processors
    Processor() = delete ;
    Processor(const Processor&) = delete ;
    Processor& operator=(const Processor&) = delete ;

  public:
    virtual ~Processor() = default ;

    enum class ERuntimeOption {
      eCritical,     
      eClone         
    };

    using RuntimeOptions = std::map<ERuntimeOption, bool> ;

  public:
    Processor( const std::string& t ) ;

    virtual void init() { /* nop */ }

    virtual void processRunHeader( RunHeader * ) { /* nop */ }

    virtual void processEvent( EventStore * ) { /* nop */ }

    virtual void end() { /* nop */ }

    std::optional<bool> runtimeOption( ERuntimeOption option ) const ;

  protected:
    void setRuntimeOption( ERuntimeOption option, bool value ) ;
    
  private:
    void initialize() override ;

  private:
    RuntimeOptions                     _forcedRuntimeOptions {} ;
  };

} // end namespace marlinmt

#endif