Mpslibclass.jobdatabase Class Reference

Public Member Functions
def	get_class
def	print_memdb
def	read_db
def	write_db

Public Attributes
	addFiles
	batchScript
	cfgTemplate
	classInf
	currentTime
	driver
	elapsedTime
	header
	infiList
	mergeScript
	mssDir
	mssDirPool
	nJobs
	pedeMem
	spare1
	spare2
	spare3
	updateTime
	updateTimeHuman

Detailed Description

Definition at line 45 of file Mpslibclass.py.

Member Function Documentation

def Mpslibclass.jobdatabase.get_class	(		self,
			argument = ''
	)

Definition at line 224 of file Mpslibclass.py.

References cmsRelvalreport.exit.

    def get_class(self, argument=''):
        CLASSES = self.classInf.split(':')
        if len(CLASSES)<1 or len(CLASSES)>2:
            print '\nget_class():\n  class must be of the form \'class\' or \'classMille:classPede\', but is \'%s\'!\n\n', classInf
            exit()
            return ''
        elif argument == 'mille':
            return CLASSES[0]
        elif argument == 'pede':
            if len(CLASSES) == 1:
                return CLASSES[0]
            elif len(CLASSES) == 2:
                return CLASSES[1]
        else:
            print '\nget_class():\n  Know class only for \'mille\' or \'pede\', not %s!\n\n' %argument
        exit()  #???????????????
        return ''
        
        
        
        
        
        
        
        
        

def Mpslibclass.jobdatabase.print_memdb

(

self

)

Definition at line 113 of file Mpslibclass.py.

References Mpslibclass.jobdatabase.addFiles, Mpslibclass.jobdatabase.batchScript, Mpslibclass.jobdatabase.cfgTemplate, Mpslibclass.jobdatabase.classInf, Mpslibclass.jobdatabase.driver, Mpslibclass.jobdatabase.elapsedTime, Mpslibclass.jobdatabase.header, Mpslibclass.jobdatabase.infiList, Mpslibclass.jobdatabase.mergeScript, Mpslibclass.jobdatabase.mssDir, Mpslibclass.jobdatabase.mssDirPool, Mpslibclass.jobdatabase.nJobs, Mpslibclass.jobdatabase.pedeMem, and Mpslibclass.jobdatabase.updateTimeHuman.

    def print_memdb(self):
        #print metainfo 
        print "\n=== mps database printout ===\n"   
        print self.header
        print 'Script:\t\t',    self.batchScript
        print 'cfg:\t\t',       self.cfgTemplate
        print 'files:\t\t',     self.infiList
        print 'class:\t\t',     self.classInf
        print 'name:\t\t',      self.addFiles
        print 'driver:\t\t',    self.driver
        print 'mergeScript:\t', self.mergeScript
        print 'mssDir:\t\t',    self.mssDir
        print 'updateTime:\t',  self.updateTimeHuman
        print 'elapsed:\t',     self.elapsedTime
        print 'mssDirPool:\t',  self.mssDirPool
        print 'pedeMem:\t',     self.pedeMem, '\n'

        #print interesting Job-level lists ---- to add: t/evt, fix remarks
        print '###     dir      jobid    stat  try  rtime      nevt  remark   weight  name'
        print "------------------------------------------------------------------------------"
        for i in xrange(self.nJobs):
            print '%03d  %6s  %9d  %6s  %3d  %5d  %8d  %8s  %5s  %s' % ( 
                             self.JOBNUMBER[i],
                             self.JOBDIR[i],
                             self.JOBID[i],
                             self.JOBSTATUS[i],
                             self.JOBNTRY[i],
                             self.JOBRUNTIME[i],
                             self.JOBNEVT[i],
                             self.JOBHOST[i],
                             self.JOBSP2[i],
                             self.JOBSP3[i])

        #print merge Jobs if merge mode 
        if self.driver == 'merge':
            for i in xrange(self.nJobs,len(self.JOBDIR)):
                print '%s  %6s  %9d  %6s  %3d  %5d  %8d  %8s  %5s  %s' % ( 
                             'MMM',
                             self.JOBDIR[i],
                             self.JOBID[i],
                             self.JOBSTATUS[i],
                             self.JOBNTRY[i],
                             self.JOBRUNTIME[i],
                             self.JOBNEVT[i],
                             self.JOBHOST[i],
                             self.JOBSP2[i],
                             self.JOBSP3[i])

        #print summed info
        totalEvents = sum(self.JOBNEVT[:self.nJobs])
        totalCpu    = sum(self.JOBRUNTIME[:self.nJobs])
        meanCpuPerEvent = 0.
        if totalEvents > 0:
            meanCpuPerEvent = float(totalCpu)/totalEvents
        print "------------------------------------------------------------------------------"
        print "\t\t\t\t\tEvent total:\t",   totalEvents
        print "\t\t\t\t\tCPU total:\t",     totalCpu,       's'
        print "\t\t\t\t\tMean CPU/event:\t",meanCpuPerEvent,'s'