In This Package:

HoldOn.py

Go to the documentation of this file.

#!/usr/bin/env python
'''
Add an alg that holds on to readout headers for a little while
'''

from DybPython.DybPythonAlg import DybPythonAlg, gbl, SUCCESS, FAILURE, irange, units

class QueueueueUp(DybPythonAlg):
    
    def __init__(self, name = None):
        DybPythonAlg.__init__(self,name)
        self.queue = []
        self.size = 4
        self.oldho = None
        self.execNum = 0
        return
        

    def _newhos(self,hos):
        'Return any new hos not yet seen'

        if not hos: return []

        if self.oldho is None:
            self.oldho = hos[0]
            return list(hos)    # fresh list

        try:                    # sometimes the ho escapes
            ind = hos.index(self.oldho)
        except ValueError:
            self.oldho = hos[0]
            return list(hos)

        self.oldho = hos[0]
        return hos[:ind]

    def execute(self):
        self.execNum += 1
        rohs = self.getAES('/Event/Readout/ReadoutHeader')

        print 'Execution# %d %s' % (self.execNum,'-'*70)
        print 'AES holds %d RoHs' % len(rohs)

        rohs = self._newhos(rohs)

        def rohstr(roh): return '%s [%d]' % (roh.context().AsString(), id(roh))
            
        print 'New RoHs: (%d)' % len(rohs)
        for roh in rohs: print '\t%s'%rohstr(roh)

        self.queue = rohs + self.queue
        loss = self.queue[self.size:]

        print 'Lost RoHs: (%d)' % len(loss)
        for roh in loss: print '\t%s'%rohstr(roh)

        self.queue = self.queue[:self.size]

        print 'Queued RoHs: (%d)' % len(self.queue)
        for roh in self.queue: print '\t%s'%rohstr(roh)

        print 'Execution# %d %s' % (self.execNum,'-'*70)
        return SUCCESS

    pass

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

---