python.POOL2EI_Lib.POOL2EISvc Class Reference

Inheritance diagram for python.POOL2EI_Lib.POOL2EISvc:

Collaboration diagram for python.POOL2EI_Lib.POOL2EISvc:

Public Member Functions
	__init__ (self, name='POOL2EISvc', **kw)
	initialize (self)
	finalize (self)
	handle (self, incident)
virtual StatusCode	reinitialize () override
virtual StatusCode	start () override
virtual StatusCode	stop () override
virtual StatusCode	sysInitialize () override
const char *	typeName () const override
	return the std::type_info name of the underlying py-component This is used by concrete implementations to connect a python component to its C++ counter-part
virtual PyObject *	self () override
	return associated python object.

Public Attributes
bool	insideInputFile = False
	algo = kw['algo']

Protected Member Functions
virtual bool	setPyAttr (PyObject *pyobj) override
	attach the C++ component to its python cousin

Protected Attributes
PyObject *	m_self
	Pointer to self (from the python world)

Detailed Description

POOL2EI Service
Registers with the Incident Service so we can deal with:
  - Begin of new input file processing
  - End of input file processing
  - End of the event processing loop
and notify the POOL2EI algorithm accordingly

Definition at line 1005 of file POOL2EI_Lib.py.

Constructor & Destructor Documentation

__init__()

python.POOL2EI_Lib.POOL2EISvc.__init__	(		self,
			name = 'POOL2EISvc',
		**	kw )

Definition at line 1015 of file POOL2EI_Lib.py.

    def __init__(self, name='POOL2EISvc', **kw):
        super(POOL2EISvc, self).__init__(name, **kw)
        _info = self.msg.info
        _info("POOL2EISvc::__init__")
 
        # whether we are inside beginFile ... endFile
        self.insideInputFile = False
 
        # save algorithm to call on incident
        if 'algo' in kw:
            _info("POOL2EISvc::__init__ algo: {}".format(kw['algo']))
            self.algo = kw['algo']
 

Member Function Documentation

finalize()

python.POOL2EI_Lib.POOL2EISvc.finalize

(

self

)

Definition at line 1044 of file POOL2EI_Lib.py.

    def finalize(self):
        _info = self.msg.info
        _info("POOL2EISvc::finalize")
        return StatusCode.Success
 

handle()

python.POOL2EI_Lib.POOL2EISvc.handle	(		self,
			incident )

Definition at line 1049 of file POOL2EI_Lib.py.

    def handle(self, incident):
        # process registered incidents
 
        _info = self.msg.info
        tp = incident.type()
        if tp == 'EndEvent':
            pass
        elif tp == 'BeginInputFile':
            _info('POOL2EISvc::handle BeginInputFile')
            self.insideInputFile = True
            self.algo.beginFile()
        elif tp == 'EndInputFile':
            _info('POOL2EISvc::handle EndInputFile')
            self.insideInputFile = False
            self.algo.endFile()
        elif tp == 'EndEvtLoop':
            _info('POOL2EISvc::handle EndEvtLoop')
            # when maxEvents is reached, we are still insideInputFile
            if self.insideInputFile:
                self.algo.endFile()
        else:
            _info('POOL2EISvc::handle {}. Unknown for POOL2EI'.format(tp))
        return
 

initialize()

python.POOL2EI_Lib.POOL2EISvc.initialize

(

self

)

Definition at line 1028 of file POOL2EI_Lib.py.

    def initialize(self):
        # register with the incident svc
        _info = self.msg.info
        _info("POOL2EISvc::initialize")
        incsvc = PyAthena.py_svc('IncidentSvc', iface='IIncidentSvc')
        if not incsvc:
            self.msg.error('unable to get the incident svc')
            return StatusCode.Failure
 
        incsvc.addListener(self, 'BeginInputFile')
        incsvc.addListener(self, 'EndInputFile')
        incsvc.addListener(self, 'EndEvtLoop')
        incsvc.release()
 
        return StatusCode.Success
 

reinitialize()

StatusCode PyAthena::Svc::reinitialize ( )

overridevirtualinherited

Definition at line 64 of file PyAthenaSvc.cxx.

{
  ATH_MSG_INFO("Re-Initializing " << name() << "...");
  return PyAthena::callPyMethod( m_self, "sysReinitialize" );
}

self()

virtual PyObject * PyAthena::Svc::self ( )

inlineoverridevirtualinherited

return associated python object.

BORROWED reference.

Definition at line 68 of file PyAthenaSvc.h.

{ return m_self; }

setPyAttr()

bool PyAthena::Svc::setPyAttr ( PyObject * pyobj )

overrideprotectedvirtualinherited

attach the C++ component to its python cousin

Definition at line 154 of file PyAthenaSvc.cxx.

{
  // now we tell the PyObject which C++ object it is the cousin of.
  RootUtils::PyGILStateEnsure ensure;
  PyObject* pyobj = TPython::CPPInstance_FromVoidPtr
    ( (void*)this, this->typeName() );
  if ( !pyobj ) {
    PyErr_Clear();
    // try PyAthena::Svc
    pyobj = TPython::CPPInstance_FromVoidPtr ((void*)this, "PyAthena::Svc");
    ATH_MSG_INFO
      ("could not dyncast component [" << name() << "] to a python "
       << "object of type [" << this->typeName() << "] (probably a missing "
       << "dictionary)" << endmsg
       << "fallback to [PyAthena::Svc]...");
  }
  if ( !pyobj ) {
    PyErr_Clear();
    ATH_MSG_WARNING
      ("Could not dyncast component [" << name() << "] to a pyobject of type [" 
       << this->typeName() << "]");
  } else {
    if ( -1 == PyObject_SetAttrString(o, "_cppHandle", pyobj) ) {
      PyErr_Clear();
      ATH_MSG_WARNING
        ("Could not attach C++ handle [" << name() << "] to its python "
         << "cousin !");
      if ( -1 == PyObject_SetAttrString(o, "_cppHandle", Py_None) ) {
        PyErr_Clear();
        ATH_MSG_WARNING
          ("could not attach a dummy C++ handle [" << name() << "] to its "
           << "python cousin !");
      }
    } else {
      return true;
    }
  }
  return false;
}

start()

StatusCode PyAthena::Svc::start ( )

overridevirtualinherited

Definition at line 78 of file PyAthenaSvc.cxx.

{
  return PyAthena::callPyMethod( m_self, "sysStart" );
}

stop()

StatusCode PyAthena::Svc::stop ( )

overridevirtualinherited

Definition at line 84 of file PyAthenaSvc.cxx.

{
  return PyAthena::callPyMethod( m_self, "sysStop" );
}

sysInitialize()

StatusCode PyAthena::Svc::sysInitialize ( )

overridevirtualinherited

Definition at line 90 of file PyAthenaSvc.cxx.

{
  ServiceHandle<IPyComponentMgr> pyMgr
    ( "PyAthena::PyComponentMgr/PyComponentMgr", name() );
  if ( !pyMgr.retrieve().isSuccess() ) {
    ATH_MSG_ERROR
      ("Could not retrieve service [" << pyMgr.typeAndName() << "] !!");
    return StatusCode::FAILURE;
  }
 
  // first retrieve our python object cousin...
  m_self = pyMgr->pyObject( this );
 
  if ( m_self == Py_None ) {
    ATH_MSG_ERROR("Wrapped PyObject is NONE !");
    return StatusCode::FAILURE;
  }
 
  // re-route to usual sysInit...
  return SvcBase_t::sysInitialize();
}

typeName()

const char * PyAthena::Svc::typeName ( ) const

overrideinherited

return the std::type_info name of the underlying py-component This is used by concrete implementations to connect a python component to its C++ counter-part

Definition at line 114 of file PyAthenaSvc.cxx.

{ 
  static const std::string tname = System::typeinfoName(typeid(*this));
  return tname.c_str();
}

Member Data Documentation

algo

python.POOL2EI_Lib.POOL2EISvc.algo = kw['algo']

Definition at line 1026 of file POOL2EI_Lib.py.

insideInputFile

bool python.POOL2EI_Lib.POOL2EISvc.insideInputFile = False

Definition at line 1021 of file POOL2EI_Lib.py.

m_self

PyObject* PyAthena::Svc::m_self

protectedinherited

Pointer to self (from the python world)

Definition at line 89 of file PyAthenaSvc.h.

---

The documentation for this class was generated from the following file:

• POOL2EI_Lib.py