EventProcessor.h

/**************************************************************************
 * BASF2 (Belle Analysis Framework 2)                                     *
 * Copyright(C) 2010-2015  Belle II Collaboration                         *
 *                                                                        *
 * Author: The Belle II Collaboration                                     *
 * Contributors: Andreas Moll, Christian Pulvermacher, Martin Ritter      *
 *                                                                        *
 * This software is provided "as is" without any warranty.                *
 **************************************************************************/
 
#pragma once
 
#include <framework/core/Path.h>
#include <framework/core/Module.h>
#include <framework/core/PathIterator.h>
#include <framework/core/ProcessStatistics.h>
#include <framework/datastore/StoreObjPtr.h>
#include <framework/dataobjects/EventMetaData.h>
 
#include <stdexcept>
 
namespace Belle2 {
  class EventProcessor {
  public:
 
    EventProcessor();
 
    virtual ~EventProcessor();
 
    void process(const PathPtr& startPath, long maxEvent = 0);
 
    void setProfileModuleName(const std::string& name) { m_profileModuleName = name; }
 
    static void writeToStdErr(const char msg[]);
 
    static void installSignalHandler(int sig, void (*fn)(int));
 
    static void installMainSignalHandlers(void (*fn)(int) = nullptr);
 
  protected:
    class StoppedBySignalException : public std::runtime_error {
    public:
      explicit StoppedBySignalException(int signal);
      int signal; 
    };
 
 
    void processInitialize(const ModulePtrList& modulePathList, bool setEventInfo = true);
 
    void processCore(const PathPtr& startPath, const ModulePtrList& modulePathList, long maxEvent = 0, bool isInputProcess = true);
 
    bool processEvent(PathIterator moduleIter, bool skipMasterModule);
 
    void callEvent(Module* module);
 
    void processTerminate(const ModulePtrList& modulePathList);
 
    void processBeginRun(bool skipDB = false);
 
    void processEndRun();
 
    long getMaximumEventNumber(long maxEvent) const;
 
    const Module* m_master;  
    ModulePtrList m_moduleList; 
    std::string m_profileModuleName;
 
    Module* m_profileModule = nullptr;
 
    StoreObjPtr<EventMetaData> m_eventMetaDataPtr;
 
    EventMetaData m_previousEventMetaData;
 
    StoreObjPtr<ProcessStatistics> m_processStatisticsPtr;
 
    bool m_inRun;
 
    double m_lastMetadataUpdate;
 
    double m_metadataUpdateInterval;
  };
 
}