Inheritance diagram for edmTracerCompactLogViewer.TracerCompactFileParser:

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

def	processingSteps (self)

Public Attributes
	maxNameSize

	numStreams

Private Attributes
	_esModuleNames

	_f

	_frameworkOnly

	_moduleNames

	_recordNames

Detailed Description

Definition at line 469 of file edmTracerCompactLogViewer.py.

Constructor & Destructor Documentation

◆ init()

def edmTracerCompactLogViewer.TracerCompactFileParser.__init__	(	self,
		f,
		frameworkOnly
	)

Definition at line 470 of file edmTracerCompactLogViewer.py.

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

     def __init__(self,f, frameworkOnly):
         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._frameworkOnly = frameworkOnly
         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 edmTracerCompactLogViewer.TracerCompactFileParser.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 518 of file edmTracerCompactLogViewer.py.

References edmStreamStallGrapher.StallMonitorParser._esModuleNames, edmTracerCompactLogViewer.TracerCompactFileParser._esModuleNames, edmStreamStallGrapher.StallMonitorParser._f, edmTracerCompactLogViewer.TracerCompactFileParser._f, edmTracerCompactLogViewer.TracerCompactFileParser._frameworkOnly, edmStreamStallGrapher.StallMonitorParser._moduleNames, edmTracerCompactLogViewer.TracerCompactFileParser._moduleNames, edmTracerCompactLogViewer.TracerCompactFileParser._recordNames, and edmTracerCompactLogViewer.processingStepsFromFile().

     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._frameworkOnly)
 