| The Gaudi Framework v30r0 (c919700c)

- 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 26 of file Parallel.py.

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

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

Definition at line 22 of file Parallel.py.

22 def _prefunction(f, task, item):
23 return f((task, item))
24
25
GaudiMP.Parallel._prefunction
def _prefunction(f, task, item)
Definition: Parallel.py:22

## Variable Documentation

list GaudiMP.Parallel.__all__ = ['Task', 'WorkManager']
| private

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.