python.MultipleStreamManager.AugmentedPoolStreamExtension Class Reference

Inheritance diagram for python.MultipleStreamManager.AugmentedPoolStreamExtension:

Collaboration diagram for python.MultipleStreamManager.AugmentedPoolStreamExtension:

Public Member Functions
def	__init__ (self, StreamName, FileName, Parent, asAlg, isVirtual, noTag=True)
def	AddItem (self, item)
	Items & MetaDataItems. More...
def	AddMetaDataItem (self, item)
def	GetEventStream (self)
def	GetMetaDataStream (self)
def	SetOutputFileName (self, name)
def	RemoveItem (self, item)
def	GetItems (self)
def	RemoveMetaDataItem (self, item)
def	GetMetaDataItems (self)
def	AcceptAlgs (self, AlgsList)
	Accept Algs. More...
def	RequireAlgs (self, AlgsList)
	Require Algs. More...
def	VetoAlgs (self, AlgsList)
	Veto Algs (ignored by prescaler for now) More...
def	Print (self)
def	AddAcceptAlgs (self, algs)
	Accept Algs. More...
def	RemoveAcceptAlgs (self, algs)
def	GetAcceptAlgs (self)
def	AddRequireAlgs (self, algs)
	Require Algs. More...
def	RemoveRequireAlgs (self, algs)
def	GetRequireAlgs (self)
def	AddVetoAlgs (self, algs)
	Veto Algs (ignored by prescaler for now) More...
def	RemoveVetoAlgs (self, algs)
def	GetVetoAlgs (self)
def	AddOtherAlgsToBookkeep (self, algs)
	Other Algs (e.g. More...
def	RemoveOtherAlgsToBookkeep (self, algs)
def	GetOtherAlgsToBookkeep (self)
def	GetSkimDecisionsWriter (self)
	Skim decisions writer. More...
def	SetPrescale (self, value)
	Master prescale. More...
def	GetPrescale (self)

Public Attributes
	parentIndex
	Stream
	Name
	OtherAlgs

Private Member Functions
def	_ItemInList (self, item, aList)
def	_AddValidItemToList (self, item, aList)
def	_RemoveValidItemFromList (self, item, aList)

Private Attributes
	_Prescaler

Detailed Description

Definition at line 259 of file MultipleStreamManager.py.

Constructor & Destructor Documentation

__init__()

def python.MultipleStreamManager.AugmentedPoolStreamExtension.__init__	(		self,
			StreamName,
			FileName,
			Parent,
			asAlg,
			isVirtual,
			noTag = True
	)

Definition at line 260 of file MultipleStreamManager.py.

    def  __init__(self, StreamName, FileName, Parent, asAlg, isVirtual, noTag=True):
        AugmentedPoolStream.__init__(self, StreamName, FileName, asAlg, isVirtual, noTag)
        index=0
        try:
            #Check wheter a StreamDAOD_PHYS stream exists
            index=MSMgr.StreamDict[Parent]
        except KeyError:
            index=-1
        self.parentIndex = index
        return
 
 

Member Function Documentation

_AddValidItemToList()

def python.MultipleStreamManager.AugmentedStreamBase._AddValidItemToList (   self,   item,   aList  )

privateinherited

Definition at line 35 of file MultipleStreamManager.py.

    def _AddValidItemToList(self,item,aList):
        #Recursive loop if item is a list
        if isinstance(item,list):
            for i in item:
                self._AddValidItemToList(i,aList)
        #Add to list if item is a string and not already in the list
        elif isinstance(item, str):
            if not self._ItemInList(item,aList):
                aList += [item]
        else:
            raise TypeError("AugmentedPoolStream._AddValidItemToList() does not support item of type %s"%type(item))
        return
 

_ItemInList()

def python.MultipleStreamManager.AugmentedStreamBase._ItemInList (   self,   item,   aList  )

privateinherited

Definition at line 24 of file MultipleStreamManager.py.

    def _ItemInList(self,item,aList):
        #Make sure aList is a list
        if not isinstance(aList, list):
            raise TypeError("AugmentedPoolStream._ItemInList() does not support aList of type %s"%type(aList))
 
        isInList=False
        for i in aList:
            if i==item:
                isInList=True
        return isInList
 

_RemoveValidItemFromList()

def python.MultipleStreamManager.AugmentedStreamBase._RemoveValidItemFromList (   self,   item,   aList  )

privateinherited

Definition at line 48 of file MultipleStreamManager.py.

    def _RemoveValidItemFromList(self,item,aList):
        #Recursive loop if item is a list
        if isinstance(item,list):
            for i in item:
                self._RemoveValidItemFromList(i,aList)
        #Remove from list if item is a string and already in list
        elif isinstance(item, str):
            if self._ItemInList(item,aList):
                aList.remove(item)
            else:
                print(self.Name,": WARNING you asked to remove item '%s' but this item is not present",item)
        else:
            raise TypeError("AugmentedPoolStream._RemoveValidItemFromList() does not support item of type %s"%type(item))
        return
 

AcceptAlgs()

def python.MultipleStreamManager.AugmentedPoolStream.AcceptAlgs (   self,   AlgsList  )

inherited

Accept Algs.

Definition at line 217 of file MultipleStreamManager.py.

    def AcceptAlgs(self, AlgsList):
        #Keep this function for now... but we may get rid of it.
        self.Stream.AcceptAlgs=AlgsList
        return
 

AddAcceptAlgs()

def python.MultipleStreamManager.AugmentedStreamBase.AddAcceptAlgs (   self,   algs  )

inherited

Accept Algs.

Definition at line 65 of file MultipleStreamManager.py.

    def AddAcceptAlgs(self, algs):
        self._AddValidItemToList(algs, self.Stream.AcceptAlgs)
        return
 

AddItem()

def python.MultipleStreamManager.AugmentedPoolStreamExtension.AddItem	(		self,
			item
	)

Items & MetaDataItems.

Reimplemented from python.MultipleStreamManager.AugmentedPoolStream.

Definition at line 274 of file MultipleStreamManager.py.

    def AddItem(self, item):
        if self.parentIndex >= 0:
            if item in MSMgr.StreamList[self.parentIndex].Stream.ItemList:
                return
        self._AddValidItemToList(item, self.Stream.ItemList)
        return
 

AddMetaDataItem()

def python.MultipleStreamManager.AugmentedPoolStreamExtension.AddMetaDataItem	(		self,
			item
	)

Reimplemented from python.MultipleStreamManager.AugmentedPoolStream.

Definition at line 281 of file MultipleStreamManager.py.

    def AddMetaDataItem(self, item):
        return
 

AddOtherAlgsToBookkeep()

def python.MultipleStreamManager.AugmentedStreamBase.AddOtherAlgsToBookkeep (   self,   algs  )

inherited

Other Algs (e.g.

those used by a FilterCombiner, but ignored by everybody else)

Definition at line 104 of file MultipleStreamManager.py.

    def AddOtherAlgsToBookkeep(self, algs):
        self._AddValidItemToList(algs, self.OtherAlgs)
        return
 

AddRequireAlgs()

def python.MultipleStreamManager.AugmentedStreamBase.AddRequireAlgs (   self,   algs  )

inherited

Require Algs.

Definition at line 78 of file MultipleStreamManager.py.

    def AddRequireAlgs(self, algs):
        self._AddValidItemToList(algs, self.Stream.RequireAlgs)
        return
 

AddVetoAlgs()

def python.MultipleStreamManager.AugmentedStreamBase.AddVetoAlgs (   self,   algs  )

inherited

Veto Algs (ignored by prescaler for now)

Definition at line 91 of file MultipleStreamManager.py.

    def AddVetoAlgs(self, algs):
        self._AddValidItemToList(algs, self.Stream.VetoAlgs)
        return
 

GetAcceptAlgs()

def python.MultipleStreamManager.AugmentedStreamBase.GetAcceptAlgs (   self )

inherited

Definition at line 73 of file MultipleStreamManager.py.

    def GetAcceptAlgs(self):
        return self.Stream.AcceptAlgs
 

GetEventStream()

def python.MultipleStreamManager.AugmentedPoolStream.GetEventStream (   self )

inherited

Definition at line 178 of file MultipleStreamManager.py.

    def GetEventStream(self):
        #This is the stream that's written at each event
        return self.Stream
 

GetItems()

def python.MultipleStreamManager.AugmentedPoolStream.GetItems (   self )

inherited

Definition at line 201 of file MultipleStreamManager.py.

    def GetItems(self):
        return self.Stream.ItemList
 

GetMetaDataItems()

def python.MultipleStreamManager.AugmentedPoolStream.GetMetaDataItems (   self )

inherited

Definition at line 212 of file MultipleStreamManager.py.

    def GetMetaDataItems(self):
        return self.Stream.MetadataItemList
 

GetMetaDataStream()

def python.MultipleStreamManager.AugmentedPoolStream.GetMetaDataStream (   self )

inherited

Definition at line 183 of file MultipleStreamManager.py.

    def GetMetaDataStream(self):
        #This is the stream that's written once per multiple events
        return self.Stream
 

GetOtherAlgsToBookkeep()

def python.MultipleStreamManager.AugmentedStreamBase.GetOtherAlgsToBookkeep (   self )

inherited

Definition at line 112 of file MultipleStreamManager.py.

    def GetOtherAlgsToBookkeep(self):
        return self.OtherAlgs
 

GetPrescale()

def python.MultipleStreamManager.AugmentedStreamBase.GetPrescale (   self )

inherited

Definition at line 156 of file MultipleStreamManager.py.

    def GetPrescale(self):
        if hasattr(self,"_Prescaler"):
            return self._Prescaler.Prescale
        else:
            return "NONE"
 
 
 

GetRequireAlgs()

def python.MultipleStreamManager.AugmentedStreamBase.GetRequireAlgs (   self )

inherited

Definition at line 86 of file MultipleStreamManager.py.

    def GetRequireAlgs(self):
        return self.Stream.RequireAlgs
 

GetSkimDecisionsWriter()

def python.MultipleStreamManager.AugmentedStreamBase.GetSkimDecisionsWriter (   self )

inherited

Skim decisions writer.

Definition at line 117 of file MultipleStreamManager.py.

    def GetSkimDecisionsWriter(self):
        from EventBookkeeperTools.BookkeepingInfoWriter import SkimDecisionsWriter
        sdw=SkimDecisionsWriter(self.Name+"_SkimDecisionsWriter")
        newContainerName=self.Name+"_"+sdw.SkimDecisionsContainerName
        sdw.SkimDecisionsContainerName=newContainerName
        #sdw.OutputLevel=2
        for a in self.GetRequireAlgs():
            sdw.addRequireAlg(a)
        for a in self.GetAcceptAlgs():
            sdw.addAcceptAlg(a)
        for a in self.GetVetoAlgs():
            sdw.addVetoAlg(a)
        for a in self.GetOtherAlgsToBookkeep():
            sdw.addOtherAlg(a)
        return sdw
 

GetVetoAlgs()

def python.MultipleStreamManager.AugmentedStreamBase.GetVetoAlgs (   self )

inherited

Definition at line 99 of file MultipleStreamManager.py.

    def GetVetoAlgs(self):
        return self.Stream.VetoAlgs
 

Print()

def python.MultipleStreamManager.AugmentedPoolStream.Print (   self )

inherited

Definition at line 237 of file MultipleStreamManager.py.

    def Print(self):
        print("**** AugmentedPoolStream",self.Name,"****")
        print("Output file:")
        print(self.Stream.OutputFile)
        print("AcceptAlgs:")
        print(self.Stream.AcceptAlgs)
        print("RequireAlgs:")
        print(self.Stream.RequireAlgs)
        print("VetoAlgs:")
        print(self.Stream.VetoAlgs)
        print("OtherAlgs to bookkeep (but not directly used by the Stream):")
        print(self.OtherAlgs)
        print("Master prescale:")
        print(self.GetPrescale())
        print("ItemList:")
        print(self.Stream.ItemList)
        print("MetaData ItemList:")
        print(self.Stream.MetadataItemList)
        return
 
 

RemoveAcceptAlgs()

def python.MultipleStreamManager.AugmentedStreamBase.RemoveAcceptAlgs (   self,   algs  )

inherited

Definition at line 69 of file MultipleStreamManager.py.

    def RemoveAcceptAlgs(self, algs):
        self._RemoveValidItemFromList(algs, self.Stream.AcceptAlgs)
        return
 

RemoveItem()

def python.MultipleStreamManager.AugmentedPoolStream.RemoveItem (   self,   item  )

inherited

Definition at line 197 of file MultipleStreamManager.py.

    def RemoveItem(self, item):
        self._RemoveValidItemFromList(item, self.Stream.ItemList)
        return
 

RemoveMetaDataItem()

def python.MultipleStreamManager.AugmentedPoolStream.RemoveMetaDataItem (   self,   item  )

inherited

Definition at line 208 of file MultipleStreamManager.py.

    def RemoveMetaDataItem(self, item):
        self._RemoveValidItemFromList(item, self.Stream.MetadataItemList)
        return
 

RemoveOtherAlgsToBookkeep()

def python.MultipleStreamManager.AugmentedStreamBase.RemoveOtherAlgsToBookkeep (   self,   algs  )

inherited

Definition at line 108 of file MultipleStreamManager.py.

    def RemoveOtherAlgsToBookkeep(self, algs):
        self._RemoveValidItemFromList(algs, self.OtherAlgs)
        return
 

RemoveRequireAlgs()

def python.MultipleStreamManager.AugmentedStreamBase.RemoveRequireAlgs (   self,   algs  )

inherited

Definition at line 82 of file MultipleStreamManager.py.

    def RemoveRequireAlgs(self, algs):
        self._RemoveValidItemFromList(algs, self.Stream.RequireAlgs)
        return
 

RemoveVetoAlgs()

def python.MultipleStreamManager.AugmentedStreamBase.RemoveVetoAlgs (   self,   algs  )

inherited

Definition at line 95 of file MultipleStreamManager.py.

    def RemoveVetoAlgs(self, algs):
        self._RemoveValidItemFromList(algs, self.Stream.VetoAlgs)
        return
 

RequireAlgs()

def python.MultipleStreamManager.AugmentedPoolStream.RequireAlgs (   self,   AlgsList  )

inherited

Require Algs.

Definition at line 224 of file MultipleStreamManager.py.

    def RequireAlgs(self, AlgsList):
        #Keep this function for now... but we may get rid of it.
        self.Stream.RequireAlgs=AlgsList
        return
 

SetOutputFileName()

def python.MultipleStreamManager.AugmentedPoolStream.SetOutputFileName (   self,   name  )

inherited

Definition at line 187 of file MultipleStreamManager.py.

    def SetOutputFileName(self, name):
        self.Stream.OutputFile = name
        return
 

SetPrescale()

def python.MultipleStreamManager.AugmentedStreamBase.SetPrescale (   self,   value  )

inherited

Master prescale.

Definition at line 135 of file MultipleStreamManager.py.

    def SetPrescale(self,value):
        #Set a master prescale to given value. Create the Prescaler tool if necessary.
        if not hasattr(self,"_Prescaler"):
            from PrimaryDPDMaker.PrimaryDPDMakerConf import PrimaryDPDPrescaler
            prescalerName="MasterPrescale_"+self.Name
            self._Prescaler = PrimaryDPDPrescaler(prescalerName)
            #Deep copies of the Require and Accept algs lists considered by the Master prescaler
            #Notes:
            # 1) deep copy is necessary because the Master prescaler itself will be added to the RequireAlgs list\
            # 2) this implies that SetPrescale must be the *last* algorithm added to the stream
            self._Prescaler.RequireAlgs = self.Stream.RequireAlgs[:]
            self._Prescaler.AcceptAlgs = self.Stream.AcceptAlgs[:]
 
            from AthenaCommon.AlgSequence import AlgSequence
            topSequence = AlgSequence()
            topSequence += self._Prescaler
            self.AddRequireAlgs(prescalerName)
 
        self._Prescaler.Prescale=value
        return
 

VetoAlgs()

def python.MultipleStreamManager.AugmentedPoolStream.VetoAlgs (   self,   AlgsList  )

inherited

Veto Algs (ignored by prescaler for now)

Definition at line 231 of file MultipleStreamManager.py.

    def VetoAlgs(self, AlgsList):
        #Keep this function for now... but we may get rid of it
        self.Stream.VetoAlgs=AlgsList
        return
 

Member Data Documentation

_Prescaler

python.MultipleStreamManager.AugmentedStreamBase._Prescaler

privateinherited

Definition at line 140 of file MultipleStreamManager.py.

Name

python.MultipleStreamManager.AugmentedStreamBase.Name

inherited

Definition at line 14 of file MultipleStreamManager.py.

OtherAlgs

python.MultipleStreamManager.AugmentedStreamBase.OtherAlgs

inherited

Definition at line 15 of file MultipleStreamManager.py.

parentIndex

python.MultipleStreamManager.AugmentedPoolStreamExtension.parentIndex

Definition at line 268 of file MultipleStreamManager.py.

Stream

python.MultipleStreamManager.AugmentedPoolStream.Stream

inherited

Definition at line 171 of file MultipleStreamManager.py.

---

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

• MultipleStreamManager.py