pathos
stable
pathos package documentation
pathos module documentation
pathos scripts documentation
pathos
Index
Edit on GitHub
Index
_
|
A
|
C
|
D
|
E
|
F
|
G
|
I
|
J
|
K
|
L
|
M
|
N
|
P
|
Q
|
R
|
S
|
T
|
U
|
V
|
W
|
X
_
__add_to_active_tasks() (Server method)
__attr__() (Map method)
__call__() (_Task method)
(Amap method)
(ApplyResult method)
(Asmap method)
(Copier method)
,
[1]
(Imap method)
(Ismap method)
(Map method)
(MapResult method)
(Pipe method)
,
[1]
,
[2]
(portnumber method)
,
[1]
(profile method)
(profiled method)
(Smap method)
(Uimap method)
__cls__() (Map method)
__connect() (Server method)
__del__() (Map method)
(Server method)
__detect_ncpus() (Server method)
__disconnect() (Tunnel method)
,
[1]
__dumpsfunc() (Server method)
__enter__() (AbstractWorkerPool method)
__exit__() (AbstractWorkerPool method)
__find_modules() (Server method)
__func__ (Map property)
__gentid() (Server method)
__get__ (Map property)
__get_nodes() (AbstractWorkerPool method)
(ParallelPool method)
,
[1]
(ProcessPool method)
,
[1]
(SerialPool method)
,
[1]
(ThreadPool method)
,
[1]
__get_nodes__() (in module pathos.serial)
__get_servers() (ParallelPool method)
,
[1]
__get_source() (Server method)
__imap() (AbstractWorkerPool method)
__init() (AbstractWorkerPool method)
__map() (AbstractWorkerPool method)
__meth__() (Map method)
__nodes (AbstractWorkerPool attribute)
__pipe() (AbstractWorkerPool method)
__repr__() (AbstractPipeConnection method)
(AbstractWorkerPool method)
(ParallelPool method)
,
[1]
(Pipe method)
(ProcessPool method)
,
[1]
(ThreadPool method)
,
[1]
(Tunnel method)
,
[1]
__scheduler() (Server method)
__self__ (Map property)
__set_nodes() (AbstractWorkerPool method)
(ParallelPool method)
,
[1]
(ProcessPool method)
,
[1]
(SerialPool method)
,
[1]
(ThreadPool method)
,
[1]
__set_nodes__() (in module pathos.serial)
__set_servers() (ParallelPool method)
,
[1]
__stat_add_job() (Server method)
__stat_add_time() (Server method)
__state__ (ParallelPool attribute)
,
[1]
(ProcessPool attribute)
,
[1]
(SerialPool attribute)
,
[1]
(ThreadPool attribute)
,
[1]
__unpickle() (ApplyResult method)
(MapResult method)
__update_active_rworkers() (Server method)
_ApplyResult (in module pathos.helpers.pp_helper)
_b() (in module pathos.util)
_cleanup() (Selector method)
_clear() (in module pathos.pools)
(ParallelPool method)
,
[1]
(ProcessPool method)
,
[1]
(ThreadPool method)
,
[1]
_connect() (Tunnel method)
,
[1]
_debug (Pipe attribute)
(Selector attribute)
(XMLRPCRequestHandler attribute)
,
[1]
_dispatch() (Selector method)
_equals() (ParallelPool method)
,
[1]
_execute() (Pipe method)
_exiting (SerialPool attribute)
,
[1]
_handleMessageFromChild() (XMLRPCServer method)
,
[1]
_installSocket() (XMLRPCServer method)
,
[1]
_is_alive() (ParallelPool method)
,
[1]
(SerialPool method)
,
[1]
_MapResult (in module pathos.helpers.pp_helper)
_marshaled_dispatch() (XMLRPCServer method)
,
[1]
_onConnection() (XMLRPCServer method)
,
[1]
_onSelectorIdle() (XMLRPCServer method)
,
[1]
_onSocketConnection() (XMLRPCServer method)
,
[1]
_pathos_connect
module
_portpicker
module
_ProcessPool (in module pathos.multiprocessing)
(in module pathos.pools)
_profiles (in module pathos.hosts)
_registerChild() (XMLRPCServer method)
,
[1]
_run_local() (Server method)
_run_remote() (Server method)
_sendResponse() (XMLRPCRequestHandler method)
,
[1]
_serve() (AbstractWorkerPool method)
(ParallelPool method)
,
[1]
(ProcessPool method)
,
[1]
(ThreadPool method)
,
[1]
_set() (MapResult method)
_str() (in module pathos.util)
_Task (class in pathos.helpers.pp_helper)
_Task__unpickle() (_Task method)
_ThreadPool() (in module pathos.pools)
(in module pathos.threading)
_TIMEOUT (Selector attribute)
_unRegisterChild() (XMLRPCServer method)
,
[1]
_watch() (Selector method)
A
AbstractPipeConnection (class in pathos.abstract_launcher)
AbstractWorkerPool (class in pathos.abstract_launcher)
activate() (Server method)
(XMLRPCServer method)
,
[1]
Amap (class in pathos.maps)
amap() (AbstractWorkerPool method)
(ParallelPool method)
,
[1]
(ProcessPool method)
,
[1]
(ThreadPool method)
,
[1]
apipe() (AbstractWorkerPool method)
(ParallelPool method)
,
[1]
(ProcessPool method)
,
[1]
(ThreadPool method)
,
[1]
ApplyResult (class in pathos.helpers.pp_helper)
Asmap (class in pathos.maps)
C
callback (ApplyResult property)
callbackargs (ApplyResult property)
citation() (in module pathos)
clear() (AbstractWorkerPool method)
(Map method)
(ParallelPool method)
,
[1]
(ProcessPool method)
,
[1]
(SerialPool method)
,
[1]
(ThreadPool method)
,
[1]
clear_stats() (in module pathos.profile)
close() (Map method)
(ParallelPool method)
,
[1]
(ProcessPool method)
,
[1]
(SerialPool method)
,
[1]
(ThreadPool method)
,
[1]
config() (Copier method)
,
[1]
(Pipe method)
,
[1]
,
[2]
connect() (in module _pathos_connect)
(in module pathos.core)
(Tunnel method)
,
[1]
connect1() (Server method)
Copier (class in pathos.secure)
(class in pathos.secure.copier)
copy() (in module _pathos_connect)
(in module pathos.core)
cpu_count() (in module pathos.helpers)
D
deactivate() (Server method)
default_port (Server attribute)
default_secret (Server attribute)
destroy() (Server method)
disable_profiling() (in module pathos.profile)
disconnect() (Tunnel method)
,
[1]
do_POST() (XMLRPCRequestHandler method)
,
[1]
dump_stats() (in module pathos.profile)
E
enable_profiling() (in module pathos.profile)
execute() (in module _pathos_connect)
(in module pathos.core)
F
FileNotFound
finalize() (_Task method)
(ApplyResult method)
(MapResult method)
finished (ApplyResult property)
freeze_support() (in module pathos.helpers)
G
get() (ApplyResult method)
(MapResult method)
get_active_nodes() (Server method)
get_ncpus() (Server method)
get_profile() (in module _pathos_connect)
(in module pathos.hosts)
get_profiles() (in module pathos.hosts)
get_stats() (in module pathos.profile)
(Server method)
getchild() (in module _pathos_connect)
(in module pathos.core)
getpid() (in module _pathos_connect)
(in module pathos.core)
getppid() (in module _pathos_connect)
(in module pathos.core)
group (ApplyResult property)
I
Imap (class in pathos.maps)
imap() (AbstractWorkerPool method)
(ParallelPool method)
,
[1]
(ProcessPool method)
,
[1]
(SerialPool method)
,
[1]
(ThreadPool method)
,
[1]
insert() (Server method)
Ismap (class in pathos.maps)
J
join() (Map method)
(ParallelPool method)
,
[1]
(ProcessPool method)
,
[1]
(SerialPool method)
,
[1]
(ThreadPool method)
,
[1]
K
kill() (in module _pathos_connect)
(in module pathos.core)
(Pipe method)
L
launch() (Pipe method)
license() (in module pathos)
lock (ApplyResult property)
log_message() (XMLRPCRequestHandler method)
,
[1]
logger() (in module pathos)
M
Map (class in pathos.maps)
map() (AbstractWorkerPool method)
(ParallelPool method)
,
[1]
(ProcessPool method)
,
[1]
(SerialPool method)
,
[1]
(ThreadPool method)
,
[1]
MapResult (class in pathos.helpers.pp_helper)
MAXPORT (Tunnel attribute)
,
[1]
MINPORT (Tunnel attribute)
,
[1]
module
_pathos_connect
_portpicker
pathos
pathos.abstract_launcher
pathos.connection
pathos.core
pathos.helpers
pathos.helpers.mp_helper
pathos.helpers.pp_helper
pathos.hosts
pathos.maps
pathos.mp_map
pathos.multiprocessing
pathos.parallel
pathos.pools
pathos.portpicker
pathos.pp
pathos.pp_map
pathos.profile
pathos.python
pathos.secure
pathos.secure.connection
pathos.secure.copier
pathos.secure.tunnel
pathos.selector
pathos.serial
pathos.server
pathos.threading
pathos.util
pathos.xmlrpc
pathos.xmlrpc.server
mp_map() (in module pathos.mp_map)
N
ncpus (ParallelPool property)
,
[1]
(ProcessPool property)
,
[1]
nodes (ParallelPool property)
,
[1]
(ProcessPool property)
,
[1]
(SerialPool property)
,
[1]
(ThreadPool property)
,
[1]
not_profiled() (in module pathos.profile)
notifyOnException() (Selector method)
notifyOnInterrupt() (Selector method)
notifyOnReadReady() (Selector method)
notifyOnWriteReady() (Selector method)
notifyWhenIdle() (Selector method)
nthreads (ThreadPool property)
,
[1]
P
ParallelPool (class in pathos.parallel)
(class in pathos.pools)
ParallelPythonPool (in module pathos.pp)
pathos
module
pathos.abstract_launcher
module
pathos.connection
module
pathos.core
module
pathos.helpers
module
pathos.helpers.mp_helper
module
pathos.helpers.pp_helper
module
pathos.hosts
module
pathos.maps
module
pathos.mp_map
module
pathos.multiprocessing
module
pathos.parallel
module
pathos.pools
module
pathos.portpicker
module
pathos.pp
module
pathos.pp_map
module
pathos.profile
module
pathos.python
module
pathos.secure
module
pathos.secure.connection
module
pathos.secure.copier
module
pathos.secure.tunnel
module
pathos.selector
module
pathos.serial
module
pathos.server
module
pathos.threading
module
pathos.util
module
pathos.xmlrpc
module
pathos.xmlrpc.server
module
pid() (Pipe method)
Pipe (class in pathos.connection)
(class in pathos.secure)
(class in pathos.secure.connection)
pipe() (AbstractWorkerPool method)
(ParallelPool method)
,
[1]
(ProcessPool method)
,
[1]
(SerialPool method)
,
[1]
(ThreadPool method)
,
[1]
PipeException
portnumber (class in _portpicker)
(class in pathos.portpicker)
pp_map() (in module pathos.pp_map)
ppmap() (in module pathos.pp_map)
ppServer (in module pathos.pp_map)
print_exc_info() (in module pathos.util)
print_stats() (in module pathos.pp_map)
(in module pathos.profile)
(Server method)
process_id() (in module pathos.profile)
ProcessPool (class in pathos.multiprocessing)
(class in pathos.pools)
(in module pathos.helpers)
profile (class in pathos.profile)
profiled (class in pathos.profile)
PythonSerial (in module pathos.python)
Q
queue() (MapResult method)
R
random_seed() (in module pathos.helpers.mp_helper)
random_state() (in module pathos.helpers.mp_helper)
randomport() (in module _pathos_connect)
(in module pathos.core)
(in module pathos.portpicker)
ready() (ApplyResult method)
(MapResult method)
register() (in module pathos.hosts)
register_profiles() (in module _pathos_connect)
(in module pathos.hosts)
response() (Pipe method)
restart() (ParallelPool method)
,
[1]
(ProcessPool method)
,
[1]
(SerialPool method)
,
[1]
(ThreadPool method)
,
[1]
S
SCP_Launcher (in module pathos)
Selector (class in pathos.selector)
selector() (Server method)
SerialPool (class in pathos.pools)
(class in pathos.serial)
serve() (in module _pathos_connect)
(in module pathos.core)
(Server method)
(XMLRPCServer method)
,
[1]
server (ApplyResult property)
Server (class in pathos.helpers.pp_helper)
(class in pathos.server)
servers (ParallelPool property)
,
[1]
set_ncpus() (Server method)
shutdown() (in module pathos.helpers)
Smap (class in pathos.maps)
spawn() (in module pathos.util)
spawn2() (in module pathos.util)
SSH_Launcher (in module pathos)
SSH_Tunnel (in module pathos)
starargs() (in module pathos.helpers.mp_helper)
start_profiling() (in module pathos.profile)
stats() (in module pathos.parallel)
(in module pathos.pp)
(in module pathos.pp_map)
stop_profiling() (in module pathos.profile)
submit() (Server method)
successful() (ApplyResult method)
(MapResult method)
T
terminate() (ParallelPool method)
,
[1]
(ProcessPool method)
,
[1]
(SerialPool method)
,
[1]
(ThreadPool method)
,
[1]
thread_id() (in module pathos.profile)
ThreadPool (class in pathos.pools)
(class in pathos.threading)
ThreadPool() (in module pathos.helpers)
tid (ApplyResult property)
TimeoutError
Tunnel (class in pathos.secure)
(class in pathos.secure.tunnel)
TunnelException
,
[1]
U
Uimap (class in pathos.maps)
uimap() (AbstractWorkerPool method)
(ParallelPool method)
,
[1]
(ProcessPool method)
,
[1]
(ThreadPool method)
,
[1]
V
verbose (Pipe attribute)
(Tunnel attribute)
,
[1]
W
wait() (_Task method)
(ApplyResult method)
(MapResult method)
(Server method)
watch() (Selector method)
X
XMLRPCRequestHandler (class in pathos.xmlrpc)
(class in pathos.xmlrpc.server)
XMLRPCServer (class in pathos.xmlrpc)
(class in pathos.xmlrpc.server)