python.PyComps.PyStorePayloadMon Class Reference

Inheritance diagram for python.PyComps.PyStorePayloadMon:

Collaboration diagram for python.PyComps.PyStorePayloadMon:

Public Member Functions
def	__init__ (self, name='PyStorePayloadMon', **kw)
def	initialize (self)
def	handle (self, incident)
def	execute (self)
def	process_proxy (self, p)
def	finalize (self)
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
	sg_name
	init base class More...
	oname
	display_mall_infos
	heph_stats
	sg
	clidsvc
	ostream

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...

Private Attributes
	_sg_clear

Detailed Description

Definition at line 14 of file Control/PerformanceMonitoring/PerfMonComps/python/PyComps.py.

Constructor & Destructor Documentation

__init__()

def python.PyComps.PyStorePayloadMon.__init__	(		self,
			name = 'PyStorePayloadMon',
		**	kw
	)

Definition at line 16 of file Control/PerformanceMonitoring/PerfMonComps/python/PyComps.py.

    def __init__(self, name='PyStorePayloadMon', **kw):
        
        super(PyStorePayloadMon, self).__init__(name, **kw)
 
        
        self.sg_name = kw.get('sg_name', 'StoreGateSvc/StoreGateSvc')
        """StoreGateSvc instance to monitor for DataProxy payload sizes"""
        
        self.oname = kw.get('oname', 'pmon_payload.ascii')
        """Name of the output file where the monitoring data will be stored"""
 
        self.display_mall_infos = kw.get(
            'display_mall_infos', False)
        """display mallinfos stats after each event"""
 
        import Hephaestus.MemoryTracker as memtrack
        from Hephaestus.MemoryTracker import FreeStatistics as heph_stats
        self.heph_stats = heph_stats
 
        mask = memtrack.configure()
        memtrack.configure( mask | memtrack.FREESTAT )
        return
 

Member Function Documentation

execute()

def python.PyComps.PyStorePayloadMon.execute

(

self

)

Definition at line 88 of file Control/PerformanceMonitoring/PerfMonComps/python/PyComps.py.

    def execute(self):
        proxies = list(self.sg.proxies())
        data = []
        fs = self.heph_stats
        fd = self.ostream
        
        mem_store_0, ncalls_0 = fs.stat()
        data = map(self.process_proxy, proxies)
        mem_store_1, ncalls_1 = fs.stat()
 
        clid2name = self.clidsvc.typename
        fmt = "   (%10i, %10i, %10i, \"%s\", \"%s\"),"
        
        print(" [ ## new-event", file=fd)
        for p, mem_0, mem_1 in data:
            tp_name = clid2name(p.clID())
            print(fmt, (mem_0, mem_1, mem_0 - mem_1, tp_name, p.name()), file=fd)
            pass
        mem_store_0 = int(mem_store_0)
        mem_store_1 = int(mem_store_1)
        
        print(fmt, (
            mem_store_0, mem_store_1, mem_store_0 - mem_store_1,
            "StoreGateSvc", self.sg_name
            ), file=fd)
        print(" ],", file=fd)
 
        self.msg.info('flush-store: %10d -> %10d -- delta= %10d',
                      mem_store_0, mem_store_1, mem_store_0 - mem_store_1)
        return StatusCode.Success
 

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.PyComps.PyStorePayloadMon.finalize

(

self

)

Definition at line 136 of file Control/PerformanceMonitoring/PerfMonComps/python/PyComps.py.

    def finalize(self):
        self.msg.info('==> finalize...')
        print("] # data", file=self.ostream)
        self.heph_stats.stop()
        
        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.PyComps.PyStorePayloadMon.handle	(		self,
			incident
	)

Definition at line 74 of file Control/PerformanceMonitoring/PerfMonComps/python/PyComps.py.

    def handle(self, incident):
        tp = incident.type()
        if tp == 'BeginEvent':
            self.heph_stats.reset()
            #self.heph_stats.start()
            pass
        elif tp == 'EndEvent':
            #self.heph_stats.stop()
            self.execute()
            #self.heph_stats.reset()
        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.PyComps.PyStorePayloadMon.initialize

(

self

)

Definition at line 39 of file Control/PerformanceMonitoring/PerfMonComps/python/PyComps.py.

    def initialize(self):
        self.msg.info('==> initialize...')
        self.sg = PyAthena.py_svc(self.sg_name)
        if not self.sg:
            self.msg.error('could not retrieve sg instance [%s]', self.sg_name)
            return StatusCode.Failure
 
        ns = PyAthena.AthenaInternal
        self._sg_clear = ns.py_sg_clearProxyPayload
 
        self.clidsvc = PyAthena.py_svc('ClassIDSvc/ClassIDSvc',
                                       iface='IClassIDSvc')
        if not self.clidsvc:
            self.msg.error('could not retrieve clidsvc')
            return StatusCode.Failure
     
        self.heph_stats.start()
 
        import os
        import os.path
        if os.path.exists(self.oname):
            os.remove(self.oname)
        self.ostream = open(self.oname, 'w')
 
        # describe data format
        print("#data format: [[(bytes_0, bytes_1, delta, clid, sg_key),]]", file=self.ostream)
        print("data = [", file=self.ostream)
        
        # register incident handles
        incsvc = PyAthena.py_svc('IncidentSvc', iface='IIncidentSvc')
        incsvc.addListener(self, 'BeginEvent')
        incsvc.addListener(self, 'EndEvent')
 
        return StatusCode.Success
 

process_proxy()

def python.PyComps.PyStorePayloadMon.process_proxy	(		self,
			p
	)

Definition at line 119 of file Control/PerformanceMonitoring/PerfMonComps/python/PyComps.py.

    def process_proxy(self, p):
        fs = self.heph_stats
        mem_0 = -1
        mem_1 = -1
        if p.clID() == 2101: # event-info
            return (p, mem_0, mem_1)
        
        mem_0, ncalls_0 = fs.stat()
        self._sg_clear(self.sg, p)
        mem_1, ncalls_1 = fs.stat()
        
        
        return (p, int(mem_0), int(mem_1))
    

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

_sg_clear

python.PyComps.PyStorePayloadMon._sg_clear

private

Definition at line 47 of file Control/PerformanceMonitoring/PerfMonComps/python/PyComps.py.

clidsvc

python.PyComps.PyStorePayloadMon.clidsvc

Definition at line 49 of file Control/PerformanceMonitoring/PerfMonComps/python/PyComps.py.

display_mall_infos

python.PyComps.PyStorePayloadMon.display_mall_infos

Definition at line 27 of file Control/PerformanceMonitoring/PerfMonComps/python/PyComps.py.

heph_stats

python.PyComps.PyStorePayloadMon.heph_stats

Definition at line 33 of file Control/PerformanceMonitoring/PerfMonComps/python/PyComps.py.

m_self

PyObject* PyAthena::Svc::m_self

protectedinherited

Pointer to self (from the python world)

Definition at line 89 of file PyAthenaSvc.h.

oname

python.PyComps.PyStorePayloadMon.oname

Definition at line 24 of file Control/PerformanceMonitoring/PerfMonComps/python/PyComps.py.

ostream

python.PyComps.PyStorePayloadMon.ostream

Definition at line 61 of file Control/PerformanceMonitoring/PerfMonComps/python/PyComps.py.

sg

python.PyComps.PyStorePayloadMon.sg

Definition at line 41 of file Control/PerformanceMonitoring/PerfMonComps/python/PyComps.py.

sg_name

python.PyComps.PyStorePayloadMon.sg_name

init base class

properties and data members

Definition at line 21 of file Control/PerformanceMonitoring/PerfMonComps/python/PyComps.py.

---

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

• Control/PerformanceMonitoring/PerfMonComps/python/PyComps.py