GaudiMP::Parallel Namespace Reference

Classes
class	Statistics
class	Task
class	WorkManager
class	SshSession
Functions
def	_prefunction
def	_ppfunction
Variables
list	__all__ = [ 'Task','WorkManager' ]
list	excluded_varnames = ['HOSTNAME', 'SSH_CLIENT', 'SSH_CONNECTION', 'DISPLAY']

---

Function Documentation

def GaudiMP::Parallel::_ppfunction

(

args )

[private]

Definition at line 20 of file Parallel.py.

                        :
    #--- Unpack arguments
    task, item = args
    stat = Statistics()
    #--- Initialize the remote side (at least once)
    if not task.__class__._initializeDone :
        for k,v in task.environ.items() :
            if k not in excluded_varnames : os.environ[k] = v
        task.initializeRemote()
        task.__class__._initializeDone = True
    #--- Reset the task output
    task._resetOutput()
    #--- Call processing
    task.process(item)
    #--- Collect statistics
    stat.stop()
    return (copy.deepcopy(task.output), stat)

def GaudiMP::Parallel::_prefunction	(		f,
			task,
			item
	)		[private]

Definition at line 18 of file Parallel.py.

00019                                  :
    return f((task,item))

---

Variable Documentation

list GaudiMP::Parallel::__all__ = [ 'Task','WorkManager' ]

Definition at line 12 of file Parallel.py.

list GaudiMP::Parallel::excluded_varnames = ['HOSTNAME', 'SSH_CLIENT', 'SSH_CONNECTION', 'DISPLAY']

Definition at line 13 of file Parallel.py.