| The Gaudi Framework v32r1 (f65d50dc)

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

## ◆ _ppfunction()

def GaudiMP.Parallel._ppfunction | ( |  | args | ) |
| private

Definition at line 25 of file Parallel.py.

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

## ◆ _prefunction()

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

Definition at line 21 of file Parallel.py.

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

## Variable Documentation

## ◆ __all__

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

Definition at line 11 of file Parallel.py.

## ◆ excluded_varnames

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

Definition at line 12 of file Parallel.py.