python.POOL2EI_Lib.POOL2EISvc Class Reference

Inheritance diagram for python.POOL2EI_Lib.POOL2EISvc:

Collaboration diagram for python.POOL2EI_Lib.POOL2EISvc:

Public Member Functions
def	__init__ (self, name='POOL2EISvc', **kw)
def	initialize (self)
def	finalize (self)
def	handle (self, incident)
virtual StatusCode	initialize () override
	Gaudi Service Implementation. More...
virtual StatusCode	reinitialize () override
virtual StatusCode	start () override
virtual StatusCode	stop () override
virtual StatusCode	finalize () 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 More...
virtual PyObject *	self () override
	return associated python object. More...
virtual void	handle (const Incident &incident) override
	callback method for the IIncidentSvc More...

Public Attributes
	insideInputFile
	algo

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

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

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__()

def 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() [1/2]

StatusCode PyAthena::Svc::finalize ( )

overridevirtualinherited

Definition at line 71 of file PyAthenaSvc.cxx.

{
  ATH_MSG_INFO("Finalizing " << name() << "...");
  return PyAthena::callPyMethod( m_self, "sysFinalize" );
}

finalize() [2/2]

def 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() [1/2]

void PyAthena::Svc::handle ( const Incident &  incident )

overridevirtualinherited

callback method for the IIncidentSvc

Definition at line 122 of file PyAthenaSvc.cxx.

{
  RootUtils::PyGILStateEnsure ensure;
  if (0 == PyObject_HasAttrString (m_self, (char*)"handle")) {
    // python side does not implement 'handle'. Fair enough.
    // XXX FIXME: could say something though: we have been registered as 
    //            listener, so there might be some kind of inconsistency...
    return;
  }
 
  PyObject *o = TPython::CPPInstance_FromVoidPtr ((void*)(&inc), "Incident");
  if (0 == o) {
    Py_XDECREF (o);
    PyAthena::throw_py_exception();
  }
    
  PyObject *res = PyObject_CallMethod (m_self, 
                       (char*)"handle",
                       (char*)"O", o);
  if (0 == res) {
    Py_XDECREF (res);
    Py_DECREF  (o);
    PyAthena::throw_py_exception();
  }
 
  Py_DECREF (res);
  Py_DECREF (o);
  return;
}

handle() [2/2]

def 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() [1/2]

StatusCode PyAthena::Svc::initialize ( )

overridevirtualinherited

Gaudi Service Implementation.

Definition at line 57 of file PyAthenaSvc.cxx.

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

initialize() [2/2]

def 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

Definition at line 1026 of file POOL2EI_Lib.py.

insideInputFile

python.POOL2EI_Lib.POOL2EISvc.insideInputFile

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