Index

_

__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) __firstlineno__ (_Task attribute) (AbstractPipeConnection attribute) (AbstractWorkerPool attribute) (Amap attribute) (ApplyResult attribute) (Asmap attribute) (Copier attribute), [1] (FileNotFound attribute) (Imap attribute) (Ismap attribute) (Map attribute) (MapResult attribute) (ParallelPool attribute), [1] (Pipe attribute), [1], [2] (PipeException attribute) (portnumber attribute), [1] (ProcessPool attribute), [1] (profile attribute) (profiled attribute) (Selector attribute) (SerialPool attribute), [1] (Server attribute), [1] (Smap attribute) (ThreadPool attribute), [1] (TimeoutError attribute) (Tunnel attribute), [1] (TunnelException attribute), [1] (Uimap attribute) (XMLRPCRequestHandler attribute), [1] (XMLRPCServer attribute), [1] __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] __static_attributes__ (_Task attribute) (AbstractPipeConnection attribute) (AbstractWorkerPool attribute) (Amap attribute) (ApplyResult attribute) (Asmap attribute) (Copier attribute), [1] (FileNotFound attribute) (Imap attribute) (Ismap attribute) (Map attribute) (MapResult attribute) (ParallelPool attribute), [1] (Pipe attribute), [1], [2] (PipeException attribute) (portnumber attribute), [1] (ProcessPool attribute), [1] (profile attribute) (profiled attribute) (Selector attribute) (SerialPool attribute), [1] (Server attribute), [1] (Smap attribute) (ThreadPool attribute), [1] (TimeoutError attribute) (Tunnel attribute), [1] (TunnelException attribute), [1] (Uimap attribute) (XMLRPCRequestHandler attribute), [1] (XMLRPCServer 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)