Reference Manual

def runTheMatrix_dev.MatrixRunner.__init__	(	self,
		wfIn = `None`,
		nThrMax = `8`
	)

Definition at line 546 of file runTheMatrix_dev.py.

 
     def __init__(self, wfIn=None, nThrMax=8):
 
         self.workFlows = wfIn
 
         self.threadList = []
         self.maxThreads = int(nThrMax) # make sure we get a number ...

runTheMatrix_dev.MatrixRunner.maxThreads

maxThreads

Definition: runTheMatrix_dev.py:551

runTheMatrix_dev.MatrixRunner.workFlows

workFlows

Definition: runTheMatrix_dev.py:548

runTheMatrix_dev.MatrixRunner.__init__

def __init__

Definition: runTheMatrix_dev.py:546

runTheMatrix_dev.MatrixRunner.threadList

threadList

Definition: runTheMatrix_dev.py:550

def runTheMatrix_dev.MatrixRunner.activeThreads ( self )

Definition at line 554 of file runTheMatrix_dev.py.

References runTheMatrix.MatrixRunner.threadList, and runTheMatrix_dev.MatrixRunner.threadList.

Referenced by addOnTests.StandardTester.runTests(), runTheMatrix_dev.MatrixRunner.runTests(), and addOnTests.StandardTester.upload().

 
     def activeThreads(self):
 
         nActive = 0
         for t in self.threadList:
             if t.isAlive() : nActive += 1
 
         return nActive

runTheMatrix_dev.MatrixRunner.activeThreads

def activeThreads

Definition: runTheMatrix_dev.py:554

runTheMatrix_dev.MatrixRunner.threadList

threadList

Definition: runTheMatrix_dev.py:550

def runTheMatrix_dev.MatrixRunner.runTests	(	self,
		testList = `None`
	)

Definition at line 563 of file runTheMatrix_dev.py.

References runTheMatrix.MatrixRunner.activeThreads(), runTheMatrix_dev.MatrixRunner.activeThreads(), runTheMatrix.MatrixRunner.maxThreads, runTheMatrix_dev.MatrixRunner.maxThreads, runTheMatrix.MatrixReader.workFlows, runTheMatrix_dev.MatrixReader.workFlows, runTheMatrix.MatrixRunner.workFlows, and runTheMatrix_dev.MatrixRunner.workFlows.

 
     def runTests(self, testList=None):
 
         startDir = os.getcwd()
 
         # make sure we have a way to set the environment in the threads ...
         if not os.environ.has_key('CMS_PATH'):
             cmsPath = '/afs/cern.ch/cms'
             print "setting default for CMS_PATH to", cmsPath
             os.environ['CMS_PATH'] = cmsPath
 
         report=''       
         print 'Running in %s thread(s)' % self.maxThreads
                 
         for wf in self.workFlows:
 
             if testList and float(wf.numId) not in [float(x) for x in testList]: continue
 
             item = wf.nameId
             if os.path.islink(item) : continue # ignore symlinks
             
             # make sure we don't run more than the allowed number of threads:
             while self.activeThreads() >= self.maxThreads:
                 time.sleep(10)
                 continue
             
             print '\nPreparing to run %s %s' % (wf.numId, item)