Inheritance diagram for edmModuleAllocMonitorAnalyze.SyncValues:

Public Member Functions
def	__init__ (self)

def	get (self, transition, index)

def	lumiFor (self, index)

def	runFor (self, index)

def	setLumi (self, index, runNumber, lumiNumber)

def	setRun (self, index, runNumber)

def	setStream (self, index, runNumber, lumiNumber, eventNumber)

def	streamFor (self, index)

Private Attributes
	_lumis

	_runs

	_streams

Detailed Description

Definition at line 214 of file edmModuleAllocMonitorAnalyze.py.

Constructor & Destructor Documentation

◆ init()

def edmModuleAllocMonitorAnalyze.SyncValues.__init__ ( self )

Definition at line 215 of file edmModuleAllocMonitorAnalyze.py.

     def __init__(self):
         self._runs = []
         self._lumis = []
         self._streams = []

Member Function Documentation

◆ get()

def edmModuleAllocMonitorAnalyze.SyncValues.get	(	self,
		transition,
		index
	)

Definition at line 237 of file edmModuleAllocMonitorAnalyze.py.

References edmModuleAllocMonitorAnalyze.SyncValues.lumiFor(), edmModuleAllocMonitorAnalyze.SyncValues.runFor(), TTDTC.setStream(), edmModuleAllocMonitorAnalyze.SyncValues.setStream(), edmModuleAllocMonitorAnalyze.SyncValues.streamFor(), and edmModuleAllocMonitorAnalyze.transitionIsGlobal().

Referenced by Options.Options.__getitem__(), betterConfigParser.BetterConfigParser.__updateDict(), submitPVValidationJobs.BetterConfigParser.__updateDict(), betterConfigParser.BetterConfigParser.getCompares(), betterConfigParser.BetterConfigParser.getGeneral(), betterConfigParser.BetterConfigParser.getResultingSection(), and submitPVValidationJobs.BetterConfigParser.getResultingSection().

     def get(self, transition, index):
         if transition == Phase.construction or transition == Phase.destruction:
             return ()
         if transition == Phase.beginJob or transition == Phase.endJob or transition == Phase.openFile:
             return ()
         if transition == Phase.globalBeginRun or transition == Phase.globalEndRun or transition == Phase.globalWriteRun:
             return (self.runFor(index),)
         if transition == Phase.globalBeginLumi or transition == Phase.globalEndLumi or transition == Phase.globalWriteLumi:
             return self.lumiFor(index)
         if transition == Phase.getNextTransition:
             return ()
         if transition == Phase.writeProcessBlock:
             return ()
         if transition == Phase.beginStream:
             self.setStream(index, 0,0,0)
             return ()
         if not transitionIsGlobal(transition):
             return self.streamFor(index)
         raise RuntimeError("Unknown transition {}".format(transition))
 

◆ lumiFor()

def edmModuleAllocMonitorAnalyze.SyncValues.lumiFor	(	self,
		index
	)

Definition at line 229 of file edmModuleAllocMonitorAnalyze.py.

References edmModuleAllocMonitorAnalyze.SyncValues._lumis.

Referenced by edmModuleAllocMonitorAnalyze.SyncValues.get().

229 def lumiFor(self, index):

230 return self._lumis[index]

◆ runFor()

def edmModuleAllocMonitorAnalyze.SyncValues.runFor	(	self,
		index
	)

Definition at line 223 of file edmModuleAllocMonitorAnalyze.py.

References edmModuleAllocMonitorAnalyze.SyncValues._runs, and hcaldqm::quantity::RunNumber._runs.

Referenced by edmModuleAllocMonitorAnalyze.SyncValues.get().

223 def runFor(self,index):

224 return self._runs[index]

◆ setLumi()

def edmModuleAllocMonitorAnalyze.SyncValues.setLumi	(	self,
		index,
		runNumber,
		lumiNumber
	)

Definition at line 225 of file edmModuleAllocMonitorAnalyze.py.

References edmModuleAllocMonitorAnalyze.SyncValues._lumis, and mps_setup.append.

     def setLumi(self, index, runNumber, lumiNumber):
         while len(self._lumis) <= index:
             self._lumis.append((0,0))
         self._lumis[index] = (runNumber, lumiNumber)

◆ setRun()

def edmModuleAllocMonitorAnalyze.SyncValues.setRun	(	self,
		index,
		runNumber
	)

Definition at line 219 of file edmModuleAllocMonitorAnalyze.py.

References edmModuleAllocMonitorAnalyze.SyncValues._runs, hcaldqm::quantity::RunNumber._runs, and mps_setup.append.

     def setRun(self, index, runNumber):
         while len(self._runs) <= index:
             self._runs.append(0)
         self._runs[index] = runNumber

◆ setStream()

def edmModuleAllocMonitorAnalyze.SyncValues.setStream	(	self,
		index,
		runNumber,
		lumiNumber,
		eventNumber
	)

Definition at line 231 of file edmModuleAllocMonitorAnalyze.py.

References edmModuleAllocMonitorAnalyze.SyncValues._streams, edmTracerCompactLogViewer.Containers._streams, edmTracerCompactLogViewer.ModuleCentricContainers._streams, and mps_setup.append.

Referenced by edmModuleAllocMonitorAnalyze.SyncValues.get().

     def setStream(self, index, runNumber, lumiNumber, eventNumber):
         while len(self._streams) <= index:
             self._streams.append((0,0,0))
         self._streams[index] = (runNumber, lumiNumber, eventNumber)