edmStreamStallGrapher.StallMonitorParser Class Reference

Inheritance diagram for edmStreamStallGrapher.StallMonitorParser:

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

Public Attributes
	maxNameSize
	numStreams

Private Attributes
	_f
	_moduleNames

Detailed Description

Definition at line 140 of file edmStreamStallGrapher.py.

Constructor & Destructor Documentation

def edmStreamStallGrapher.StallMonitorParser.__init__	(		self,
			f
	)

Definition at line 141 of file edmStreamStallGrapher.py.

References createfilelist.int, and split.

    def __init__(self,f):
        numStreams = 0
        numStreamsFromSource = 0
        moduleNames = {}
        for rawl in f:
            l = rawl.strip()
            if l and l[0] == 'M':
                i = l.split(' ')
                if i[3] == '4':
                    #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[id] = name
                continue
        self._f = f
        if numStreams == 0:
          numStreams = numStreamsFromSource +1
        self.numStreams =numStreams
        self._moduleNames = moduleNames
        self.maxNameSize =0
        for n in six.iteritems(moduleNames):
            self.maxNameSize = max(self.maxNameSize,len(n))
        self.maxNameSize = max(self.maxNameSize,len(kSourceDelayedRead))

Member Function Documentation

def edmStreamStallGrapher.StallMonitorParser.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 171 of file edmStreamStallGrapher.py.

References edmStreamStallGrapher.StallMonitorParser._f, edmStreamStallGrapher.StallMonitorParser._moduleNames, and edmStreamStallGrapher.processingStepsFromStallMonitorOutput().

    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 processingStepsFromStallMonitorOutput(self._f,self._moduleNames)

#----------------------------------------------
# Utility to get time out of Tracer output text format

Member Data Documentation

edmStreamStallGrapher.StallMonitorParser._f

private

Definition at line 161 of file edmStreamStallGrapher.py.

Referenced by mergeLHE.DefaultLHEMerger.merge(), mergeLHE.DefaultLHEMerger.merge_init_blocks(), and edmStreamStallGrapher.StallMonitorParser.processingSteps().

edmStreamStallGrapher.StallMonitorParser._moduleNames

private

Definition at line 165 of file edmStreamStallGrapher.py.

Referenced by edmStreamStallGrapher.StallMonitorParser.processingSteps().

edmStreamStallGrapher.StallMonitorParser.maxNameSize

Definition at line 166 of file edmStreamStallGrapher.py.

edmStreamStallGrapher.StallMonitorParser.numStreams

Definition at line 164 of file edmStreamStallGrapher.py.