In This Package:

TestFileStatSvc.py

Go to the documentation of this file.

#!/usr/bin/env python

from GaudiPython.GaudiAlgs import GaudiAlgo
from GaudiPython import SUCCESS, FAILURE, Bindings, gbl
import ROOT

class PollFileStatSvc(GaudiAlgo):
    def __init__(self,name='PollFileStatSvc'):
        GaudiAlgo.__init__(self,name)
        self.fss = None
        self.closed = []
        self.opened = []
        return

    def initialize(self):
        self.fss = self.svc('IRootIOFileStateSvc','RootIOFileStateSvc')
        return SUCCESS

    def _listify(self,vector):
        l = []
        siz = vector.size()
        print siz
        for ind in range(siz):
            l.append(vector[ind])
        return l

    def execute(self):
        closed = self._listify(self.fss.closedOutput())
        opened = self._listify(self.fss.openOutput())

        for fn in closed:
            if fn not in self.closed:
                print 'Got new closed file:',fn
                self.closed.append(fn)
                pass
            continue
        
        for fn in opened:
            if fn not in self.opened:
                print 'Got new opened file:',fn
                pass
            continue
        self.opened = opened

        return SUCCESS

def configure(argv=None):
    from RootIOSvc.RootIOSvcConf import RootIOFileStateSvc
    fss = RootIOFileStateSvc()

    from Gaudi.Configuration import ApplicationMgr
    theApp = ApplicationMgr()
    theApp.ExtSvc.append(fss)

def run(app):
    alg = PollFileStatSvc()
    app.addAlgorithm(alg)

---