PythonEventProcessor Class Reference

#include "PythonEventProcessor.h"

Public Member Functions
const PythonEventProcessor &	operator= (const PythonEventProcessor &)=delete
	PythonEventProcessor (const PythonEventProcessor &)=delete
	PythonEventProcessor (PyBind11ProcessDesc const &)
void	run ()
int	totalEvents () const
int	totalEventsFailed () const
int	totalEventsPassed () const
	~PythonEventProcessor ()

Private Attributes
int	forcePluginSetupFirst_
edm::EventProcessor	processor_

Detailed Description

Description: [one line class summary]

Usage: <usage>

Definition at line 30 of file PythonEventProcessor.h.

Constructor & Destructor Documentation

PythonEventProcessor() [1/2]

PythonEventProcessor::PythonEventProcessor

(

PyBind11ProcessDesc const &

iDesc

)

Definition at line 83 of file PythonEventProcessor.cc.

    : forcePluginSetupFirst_(setupPluginSystem()),
      processor_(addDefaultServicesToProcessDesc(setupThreading(iDesc.processDesc())),
                 createJobReport(),
                 edm::serviceregistry::kOverlapIsError) {}

PythonEventProcessor() [2/2]

PythonEventProcessor::PythonEventProcessor ( const PythonEventProcessor &  )

delete

~PythonEventProcessor()

PythonEventProcessor::~PythonEventProcessor

(

)

Definition at line 100 of file PythonEventProcessor.cc.

                                            {
  auto gil = PyEval_SaveThread();
  // Protects the destructor from throwing exceptions.
  CMS_SA_ALLOW try {
    tbb::task_arena{nThreads}.execute([this]() {
      TaskCleanupSentry s(&processor_);
      processor_.endJob();
    });
  } catch (...) {
  }
  PyEval_RestoreThread(gil);
}

References CMS_SA_ALLOW, edm::EventProcessor::endJob(), runTheMatrix::nThreads, processor_, and alignCSCRings::s.

Member Function Documentation

operator=()

const PythonEventProcessor& PythonEventProcessor::operator= ( const PythonEventProcessor &  )

delete

run()

void PythonEventProcessor::run

(

)

Definition at line 113 of file PythonEventProcessor.cc.

                               {
  auto gil = PyEval_SaveThread();
  try {
    tbb::task_arena{nThreads}.execute([this]() { (void)processor_.runToCompletion(); });
  } catch (...) {
  }
  PyEval_RestoreThread(gil);
}

References runTheMatrix::nThreads, processor_, edm::EventProcessor::runToCompletion(), and funct::void.

Referenced by PYBIND11_MODULE().

totalEvents()

int PythonEventProcessor::totalEvents ( ) const

inline

Return the number of events this EventProcessor has tried to process (inclues both successes and failures, including failures due to exceptions during processing).

Definition at line 40 of file PythonEventProcessor.h.

{ return processor_.totalEvents(); }

References processor_, and edm::EventProcessor::totalEvents().

Referenced by PYBIND11_MODULE().

totalEventsFailed()

int PythonEventProcessor::totalEventsFailed ( ) const

inline

Return the number of events that have not passed any trigger. (N.B. totalEventsFailed() + totalEventsPassed() == totalEvents()

Definition at line 48 of file PythonEventProcessor.h.

{ return processor_.totalEventsFailed(); }

References processor_, and edm::EventProcessor::totalEventsFailed().

Referenced by PYBIND11_MODULE().

totalEventsPassed()

int PythonEventProcessor::totalEventsPassed ( ) const

inline

Return the number of events processed by this EventProcessor which have been passed by one or more trigger paths.

Definition at line 44 of file PythonEventProcessor.h.

{ return processor_.totalEventsPassed(); }

References processor_, and edm::EventProcessor::totalEventsPassed().

Referenced by PYBIND11_MODULE().

Member Data Documentation

forcePluginSetupFirst_

int PythonEventProcessor::forcePluginSetupFirst_

private

Definition at line 57 of file PythonEventProcessor.h.

processor_

edm::EventProcessor PythonEventProcessor::processor_

private

Definition at line 58 of file PythonEventProcessor.h.

Referenced by run(), totalEvents(), totalEventsFailed(), totalEventsPassed(), and ~PythonEventProcessor().