GlobalProcHandler.h

/**************************************************************************
 * BASF2 (Belle Analysis Framework 2)                                     *
 * Copyright(C) 2018  Belle II Collaboration                              *
 *                                                                        *
 * Author: The Belle II Collaboration                                     *
 * Contributors: Soohyung Lee, Anseln Baur, Nils Braun                    *
 *                                                                        *
 * This software is provided "as is" without any warranty.                *
 **************************************************************************/
#pragma once
 
#include <framework/pcore/ProcHelper.h>
#include <vector>
#include <string>
#include <map>
 
namespace Belle2 {
  class GlobalProcHandler {
  public:
    static void initialize(unsigned int nWorkerProc);
 
    static bool startInputProcess();
    static bool startWorkerProcesses(unsigned int numProcesses);
    static bool startOutputProcess(bool local = false);
    static bool startProxyProcess();
    static bool startMonitoringProcess();
 
    static void waitForAllProcesses();
 
    static bool parallelProcessingUsed();
 
    static bool isInputProcess();
    static bool isWorkerProcess();
    static bool isOutputProcess();
 
    static int numEventProcesses();
    static int EvtProcID();
 
    static std::string getProcessName();
    static void killAllProcesses();
    static const std::vector<int>& getPIDList();
 
    static bool isProcess(ProcType procType);
 
    static ProcType getProcType(int pid);
  private:
    static bool startProc(ProcType procType, int id);
 
    static ProcType s_procType;
    static int s_processID;
    static int s_numEventProcesses;
 
    static std::vector<int> s_pidVector;
    static std::map<int, ProcType> s_startedPIDs;
 
    static void addPID(int pid);
    static bool findPID(int pid);
    static void removePID(int pid);
    static void clearPIDs();
    static bool pidListEmpty();
    static void childSignalHandler(int);
  };
}