| The Gaudi Framework v27r1

- Main Page
- Related Pages
- Modules
- Namespaces
- Classes
- Files

- Namespace List
- Namespace Members

Classes | Functions | Variables
GaudiMP.Parallel Namespace Reference

## Classes
class | SshSession
class | Statistics
class | Task
class | WorkManager

## Functions
def | _prefunction (f, task, item)
def | _ppfunction (args)

## 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.

20 def _ppfunction( args ) :
21 #--- Unpack arguments
22 task, item = args
23 stat = Statistics()
24 #--- Initialize the remote side (at least once)
25 if not task.__class__._initializeDone :
26 for k,v in task.environ.items() :
27 if k not in excluded_varnames : os.environ[k] = v
28 task.initializeRemote()
29 task.__class__._initializeDone = True
30 #--- Reset the task output
31 task._resetOutput()
32 #--- Call processing
33 task.process(item)
34 #--- Collect statistics
35 stat.stop()
36 return (copy.deepcopy(task.output), stat)
37
GaudiMP.Parallel._ppfunction
def _ppfunction(args)
Definition: Parallel.py:20
GaudiMP.Parallel.Statistics
Definition: Parallel.py:38

def GaudiMP.Parallel._prefunction | ( |  | f,
|  |  | task,
|  |  | item
| ) |  |
| private

Definition at line 18 of file Parallel.py.

18 def _prefunction( f, task, item) :
19 return f((task,item))
GaudiMP.Parallel._prefunction
def _prefunction(f, task, item)
Definition: Parallel.py:18

## 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.