ZMQEventProcessor.h

/**************************************************************************
 * BASF2 (Belle Analysis Framework 2)                                     *
 * Copyright(C) 2018 - Belle II Collaboration                             *
 *                                                                        *
 * Author: The Belle II Collaboration                                     *
 * Contributors: Anselm Baur, Nils Braun                                  *
 *                                                                        *
 * This software is provided "as is" without any warranty.                *
 **************************************************************************/
#pragma once
 
#include <framework/core/Module.h>
#include <framework/core/EventProcessor.h>
#include <framework/core/Path.h>
#include <framework/pcore/ProcessMonitor.h>
 
namespace Belle2 {
  class ZMQEventProcessor : public EventProcessor {
  public:
 
    ZMQEventProcessor();
 
    virtual ~ZMQEventProcessor();
 
    void process(const PathPtr& spath, long maxEvent);
 
    void cleanup();
 
  private:
    void initialize(const ModulePtrList& moduleList, const ModulePtr& histogramManager);
 
    void forkAndRun(long maxEvent, const PathPtr& inputPath, const PathPtr& mainPath, const PathPtr& outputPath,
                    const ModulePtrList& terminateGlobally);
 
    void terminateAndCleanup(const ModulePtr& histogramManager);
 
    void runMonitoring(const PathPtr& inputPath, const PathPtr& mainPath, const ModulePtrList& terminateGlobally, long maxEvent);
 
    void runInput(const PathPtr& inputPath, const ModulePtrList& terminateGlobally, long maxEvent);
 
    void runOutput(const PathPtr& outputPath, const ModulePtrList& terminateGlobally, long maxEvent);
 
    void runWorker(unsigned int numProcesses, const PathPtr& inputPath, const PathPtr& mainPath, const ModulePtrList& terminateGlobally,
                   long maxEvent);
 
    void processPath(const PathPtr& localPath, const ModulePtrList& terminateGlobally, long maxEvent);
 
    ProcessMonitor m_processMonitor;
  };
}