GaudiMP.Parallel.Task Class Reference

Inheritance diagram for GaudiMP.Parallel.Task:

Collaboration diagram for GaudiMP.Parallel.Task:

Public Member Functions
def	__new__ (cls, *args, **kwargs)
def	initializeLocal (self)
def	initializeRemote (self)
def	process (self, item)
def	finalize (self)

Public Attributes
	output

Private Member Functions
def	_mergeResults (self, result)
def	_resetOutput (self)

Static Private Attributes
bool	_initializeDone = False

Detailed Description

Basic base class to encapsulate any processing that is going to be porcessed in parallel.
    User class much inherit from it and implement the methods initializeLocal,
    initializeRemote, process and finalize.   

Definition at line 56 of file Parallel.py.

Member Function Documentation

__new__()

def GaudiMP.Parallel.Task.__new__	(		cls,
		*	args,
		**	kwargs
	)

Definition at line 62 of file Parallel.py.

    def __new__(cls, *args, **kwargs):
        task = object.__new__(cls)
        task.output = ()
        task.environ = {}
        for k, v in os.environ.items():
            task.environ[k] = v
        task.cwd = os.getcwd()
        return task

_mergeResults()

def GaudiMP.Parallel.Task._mergeResults (   self,   result  )

private

Definition at line 83 of file Parallel.py.

    def _mergeResults(self, result):
        if type(result) is not type(self.output):
            raise TypeError("output type is not same as obtained result")
        # --No iteratable---
        if not hasattr(result, '__iter__'):
            if hasattr(self.output, 'Add'):
                self.output.Add(result)
            elif hasattr(self.output, '__iadd__'):
                self.output += result
            elif hasattr(self.output, '__add__'):
                self.output = self.output + result
            else:
                raise TypeError('result cannot be added')
        # --Dictionary---
        elif type(result) is dict:
            if self.output.keys() <= result.keys():
                minkeys = self.output.keys()
            else:
                minkeys = result.keys()
            for key in result.keys():
                if key in self.output:
                    if hasattr(self.output[key], 'Add'):
                        self.output[key].Add(result[key])
                    elif hasattr(self.output[key], '__iadd__'):
                        self.output[key] += result[key]
                    elif hasattr(self.output[key], '__add__'):
                        self.output[key] = self.output[key] + result[key]
                    else:
                        raise TypeError('result cannot be added')
                else:
                    self.output[key] = result[key]
        # --Anything else (list)
        else:
            for i in range(min(len(self.output), len(result))):
                if hasattr(self.output[i], 'Add'):
                    self.output[i].Add(result[i])
                elif hasattr(self.output[i], '__iadd__'):
                    self.output[i] += result[i]
                elif hasattr(self.output[i], '__add__'):
                    self.output[i] = self.output[i] + result[i]
                else:
                    raise TypeError('result cannot be added')

_resetOutput()

def GaudiMP.Parallel.Task._resetOutput (   self )

private

Definition at line 126 of file Parallel.py.

    def _resetOutput(self):
        output = (type(self.output) is
                  dict) and self.output.values() or self.output
        for o in output:
            if hasattr(o, 'Reset'):
                o.Reset()

finalize()

def GaudiMP.Parallel.Task.finalize

(

self

)

Definition at line 80 of file Parallel.py.

    def finalize(self):
        pass

initializeLocal()

def GaudiMP.Parallel.Task.initializeLocal

(

self

)

Definition at line 71 of file Parallel.py.

    def initializeLocal(self):
        pass

initializeRemote()

def GaudiMP.Parallel.Task.initializeRemote

(

self

)

Definition at line 74 of file Parallel.py.

    def initializeRemote(self):
        pass

process()

def GaudiMP.Parallel.Task.process	(		self,
			item
	)

Definition at line 77 of file Parallel.py.

    def process(self, item):
        pass

Member Data Documentation

_initializeDone

bool GaudiMP.Parallel.Task._initializeDone = False

staticprivate

Definition at line 60 of file Parallel.py.

output

GaudiMP.Parallel.Task.output

Definition at line 93 of file Parallel.py.

---

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

• GaudiMP/python/GaudiMP/Parallel.py