Inheritance diagram for edmModuleAllocMonitorAnalyze.ModuleAllocCompactFileParser:

Public Member Functions
def	__init__ (self, f, moduleCentric)

def	processingSteps (self)

Public Attributes
	maxNameSize

	numStreams

Private Attributes
	_esModuleNames

	_f

	_moduleCentric

	_moduleNames

	_recordNames

Detailed Description

Definition at line 943 of file edmModuleAllocMonitorAnalyze.py.

Constructor & Destructor Documentation

◆ init()

def edmModuleAllocMonitorAnalyze.ModuleAllocCompactFileParser.__init__	(	self,
		f,
		moduleCentric
	)

Definition at line 944 of file edmModuleAllocMonitorAnalyze.py.

References createfilelist.int, submitPVValidationJobs.split(), str, and mkLumiAveragedPlots.tuple.

     def __init__(self,f, moduleCentric):
         streamBeginRun = str(Phase.streamBeginRun)
         numStreams = 0
         numStreamsFromSource = 0
         moduleNames = {}
         esModuleNames = {}
         recordNames = {}
         for rawl in f:
             l = rawl.strip()
             if l and l[0] == 'M':
                 i = l.split(' ')
                 if i[3] == streamBeginRun:
                     #found global begin run
                     numStreams = int(i[1])+1
                     break
             if numStreams == 0 and l and l[0] == 'S':
                 s = int(l.split(' ')[1])
                 if s > numStreamsFromSource:
                   numStreamsFromSource = s
             if len(l) > 5 and l[0:2] == "#M":
                 (id,name)=tuple(l[2:].split())
                 moduleNames[int(id)] = name
                 continue
             if len(l) > 5 and l[0:2] == "#N":
                 (id,name)=tuple(l[2:].split())
                 esModuleNames[int(id)] = name
                 continue
             if len(l) > 5 and l[0:2] == "#R":
                 (id,name)=tuple(l[2:].split())
                 recordNames[int(id)] = name
                 continue
 
         self._f = f
         self._moduleCentric = moduleCentric
         if numStreams == 0:
           numStreams = numStreamsFromSource +2
         self.numStreams =numStreams
         self._moduleNames = moduleNames
         self._esModuleNames = esModuleNames
         self._recordNames = recordNames
         self.maxNameSize =0
         for n in moduleNames.items():
             self.maxNameSize = max(self.maxNameSize,len(n))
         for n in esModuleNames.items():
             self.maxNameSize = max(self.maxNameSize,len(n))
         self.maxNameSize = max(self.maxNameSize,len(kSourceDelayedRead))
         self.maxNameSize = max(self.maxNameSize, len('streamBeginLumi'))
 

Member Function Documentation

◆ processingSteps()

def edmModuleAllocMonitorAnalyze.ModuleAllocCompactFileParser.processingSteps ( self )

Create a generator which can step through the file and return each processing step.
Using a generator reduces the memory overhead when parsing a large file.

Definition at line 992 of file edmModuleAllocMonitorAnalyze.py.

     def processingSteps(self):
         """Create a generator which can step through the file and return each processing step.
         Using a generator reduces the memory overhead when parsing a large file.
             """
         self._f.seek(0)
         return processingStepsFromFile(self._f,self._moduleNames, self._esModuleNames, self._recordNames,  self._moduleCentric)
 