CMS 3D CMS Logo

 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Properties Friends Macros Groups Pages
List of all members | Public Member Functions | Public Attributes | Private Attributes
edmStreamStallGrapher.StallMonitorParser Class Reference
Inheritance diagram for edmStreamStallGrapher.StallMonitorParser:

Public Member Functions

def __init__
 
def processingSteps
 

Public Attributes

 maxNameSize
 
 numStreams
 

Private Attributes

 _esModuleNames
 
 _f
 
 _moduleNames
 

Detailed Description

Definition at line 151 of file edmStreamStallGrapher.py.

Constructor & Destructor Documentation

def edmStreamStallGrapher.StallMonitorParser.__init__ (   self,
  f 
)

Definition at line 152 of file edmStreamStallGrapher.py.

References submitPVValidationJobs.split().

153  def __init__(self,f):
154  numStreams = 0
155  numStreamsFromSource = 0
156  moduleNames = {}
157  esModuleNames = {}
158  for rawl in f:
159  l = rawl.strip()
160  if l and l[0] == 'M':
161  i = l.split(' ')
162  if i[3] == '4':
163  #found global begin run
164  numStreams = int(i[1])+1
165  break
166  if numStreams == 0 and l and l[0] == 'S':
167  s = int(l.split(' ')[1])
168  if s > numStreamsFromSource:
169  numStreamsFromSource = s
170  if len(l) > 5 and l[0:2] == "#M":
171  (id,name)=tuple(l[2:].split())
172  moduleNames[id] = name
173  continue
174  if len(l) > 5 and l[0:2] == "#N":
175  (id,name)=tuple(l[2:].split())
176  esModuleNames[id] = name
177  continue
179  self._f = f
180  if numStreams == 0:
181  numStreams = numStreamsFromSource +1
182  self.numStreams =numStreams
183  self._moduleNames = moduleNames
184  self._esModuleNames = esModuleNames
185  self.maxNameSize =0
186  for n in moduleNames.items():
187  self.maxNameSize = max(self.maxNameSize,len(n))
188  for n in esModuleNames.items():
189  self.maxNameSize = max(self.maxNameSize,len(n))
190  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 191 of file edmStreamStallGrapher.py.

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

192  def processingSteps(self):
193  """Create a generator which can step through the file and return each processing step.
194  Using a generator reduces the memory overhead when parsing a large file.
195  """
196  self._f.seek(0)
198 
199 #----------------------------------------------
# Utility to get time out of Tracer output text format

Member Data Documentation

edmStreamStallGrapher.StallMonitorParser._esModuleNames
private

Definition at line 183 of file edmStreamStallGrapher.py.

Referenced by edmStreamStallGrapher.StallMonitorParser.processingSteps().

edmStreamStallGrapher.StallMonitorParser._f
private

Definition at line 178 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 182 of file edmStreamStallGrapher.py.

Referenced by edmStreamStallGrapher.StallMonitorParser.processingSteps().

edmStreamStallGrapher.StallMonitorParser.maxNameSize

Definition at line 184 of file edmStreamStallGrapher.py.

edmStreamStallGrapher.StallMonitorParser.numStreams

Definition at line 181 of file edmStreamStallGrapher.py.