rhadd.haddJob Class Reference

Inheritance diagram for rhadd.haddJob:

Collaboration diagram for rhadd.haddJob:

Public Types
typedef HLT::TypeInformation::for_each_type_c< typenameEDMLIST::map, my_functor, my_result<>, my_arg< HLT::TypeInformation::get_cont, CONTAINER > >::type	result

Public Member Functions
	__init__ (self, inputFiles, outputFile)
	outputFile (self)
	exitCode (self)
	exitCode (self, value)
	exe (self)
	__str__ (self)
	__call__ (self)

Protected Attributes
	_inputFiles = inputFiles
	_outputFile = outputFile
	_exitCode = None

Detailed Description

A single hadd job

Definition at line 40 of file rhadd.py.

Member Typedef Documentation

result

typedef HLT::TypeInformation::for_each_type_c<typenameEDMLIST::map,my_functor,my_result<>,my_arg<HLT::TypeInformation::get_cont,CONTAINER>>::type master_search< typenameEDMLIST::map, HLT::TypeInformation::get_cont, CONTAINER >::result

inherited

Definition at line 90 of file EDM_MasterSearch.h.

Constructor & Destructor Documentation

__init__()

rhadd.haddJob.__init__	(		self,
			inputFiles,
			outputFile )

Definition at line 42 of file rhadd.py.

    def __init__(self, inputFiles, outputFile):
        self._inputFiles = inputFiles
        self._outputFile = outputFile
        self._exitCode = None
        

Member Function Documentation

__call__()

rhadd.haddJob.__call__

(

self

)

Wrapper to call my own exe function and return the exit code of hadd

Definition at line 78 of file rhadd.py.

    def __call__(self):
        '''Wrapper to call my own exe function and return the exit code of hadd'''
        self.exe()
        return self._exitCode
            
        

__str__()

rhadd.haddJob.__str__

(

self

)

Definition at line 75 of file rhadd.py.

    def __str__(self):
        return str(self._inputFiles) + ' -> ' + str(self._outputFile)
    

exe()

rhadd.haddJob.exe

(

self

)

Execute the hadd command

Definition at line 60 of file rhadd.py.

    def exe(self):
        '''Execute the hadd command'''
        mergeCmd = ['hadd', '-f']  # -f because our output file was touched to be safely created
        mergeCmd.append(self._outputFile)
        mergeCmd.extend(self._inputFiles)
        
        logging.info('Will now execute merge: %s', ' '.join(mergeCmd))
        output = []
        job = Popen(mergeCmd, stdout=PIPE, stderr=STDOUT, bufsize=1, close_fds=True)
        while job.poll() is None:
            output.append(job.stdout.readline().strip())
        self._exitCode = job.returncode
        if self._exitCode != 0:
            logging.warning('Non zero return code from hadd. STDOUT/ERR follows:\n%s', os.linesep.join(output))
 

exitCode() [1/2]

rhadd.haddJob.exitCode

(

self

)

Definition at line 52 of file rhadd.py.

    def exitCode(self):
        return self._exitCode
    

exitCode() [2/2]

rhadd.haddJob.exitCode	(		self,
			value )

Definition at line 57 of file rhadd.py.

    def exitCode(self, value):
        self._exitCode = value
        

outputFile()

rhadd.haddJob.outputFile

(

self

)

Definition at line 48 of file rhadd.py.

    def outputFile(self):
        return(self._outputFile)
    

Member Data Documentation

_exitCode

rhadd.haddJob._exitCode = None

protected

Definition at line 45 of file rhadd.py.

_inputFiles

rhadd.haddJob._inputFiles = inputFiles

protected

Definition at line 43 of file rhadd.py.

_outputFile

rhadd.haddJob._outputFile = outputFile

protected

Definition at line 44 of file rhadd.py.

---

The documentation for this class was generated from the following file:

• rhadd.py