python.FilePeekerLib.FilePeekerSvc Class Reference

Inheritance diagram for python.FilePeekerLib.FilePeekerSvc:

Collaboration diagram for python.FilePeekerLib.FilePeekerSvc:

Public Member Functions
def	__init__ (self, name='FilePeekerSvc', **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...

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

a service to spy for file meta-data and store this collected data into
the pool file, in a python-pickle friendly format

Definition at line 675 of file FilePeekerLib.py.

Constructor & Destructor Documentation

__init__()

def python.FilePeekerLib.FilePeekerSvc.__init__	(		self,
			name = 'FilePeekerSvc',
		**	kw
	)

Definition at line 680 of file FilePeekerLib.py.

    def __init__(self, name='FilePeekerSvc', **kw):
        kw['name'] = name
        super(FilePeekerSvc, self).__init__(**kw)
 
 

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.FilePeekerLib.FilePeekerSvc.finalize

(

self

)

Definition at line 699 of file FilePeekerLib.py.

    def finalize(self):
        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.FilePeekerLib.FilePeekerSvc.handle	(		self,
			incident
	)

Definition at line 702 of file FilePeekerLib.py.

    def handle(self, incident):
        tp = incident.type()
        if tp == 'EndEvent':
            pass
        elif tp == 'BeginInputFile':
            self.msg.info('input file name: [%s]', incident.fileName())
            pass
        else:
            pass
        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.FilePeekerLib.FilePeekerSvc.initialize

(

self

)

Definition at line 685 of file FilePeekerLib.py.

    def initialize(self):
        # register with the incident svc
        svc = PyAthena.py_svc('IncidentSvc', iface='IIncidentSvc')
        if not svc:
            self.msg.error('unable to get the incident svc')
            return StatusCode.Failure
 
        for incident in ('EndEvent',
                         'BeginInputFile',):
            svc.addListener(self, incident)
            pass
        
        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

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:

• FilePeekerLib.py