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

Static Private Attributes
string	__default_db_file_name = "mps.db"

Detailed Description

Definition at line 46 of file Mpslibclass.py.

Member Function Documentation

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

Definition at line 238 of file Mpslibclass.py.

    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
            sys.exit(1)
        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
            sys.exit(1)

def Mpslibclass.jobdatabase.print_memdb

(

self

)

Definition at line 127 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'