Identifier Index

[ A B C D E F G H I J K L M N O P Q R S T U V W X Y Z _ ]

A

abort() (in Engine)	add_range() (in RangeSet)	arm() (in _EngineTimerCase)
abort() (in Task)	add_source() (in GroupResolver)	armed() (in _EngineTimerCase)
add() (in Engine)	add_timer() (in Engine)	atomic_dec() (in _SuspendCondition)
add() (in MsgTree)	all_nodes() (in GroupResolver)	atomic_inc() (in _SuspendCondition)
add() (in NodeSetBase)	AlreadyRunningError (in ClusterShell.Task)
add() (in RangeSet)	append() (in MsgTreeElem)

B

bind_stdin() (in clush)	bufnodeset_cmp() (in clush)

C

clear() (in Engine)	clubak() (in clubak)	ClusterShell
clear() (in _EngineTimerQ)	clush	COLOR_STDERR_FMT (in Display)
clear() (in MsgTree)	clush_excepthook() (in clush)	COLOR_STDERR_FMT (in Display)
clear() (in NodeSetBase)	clush_exit() (in clush)	COLOR_STDOUT_FMT (in Display)
clear() (in RangeSet)	clush_main() (in clush)	COLOR_STDOUT_FMT (in Display)
clients() (in Engine)	ClushConfig (in clush)	compute_nodeset() (in nodeset)
clubak	ClushConfigError (in clush)	copy() (in Task)

D

DEF_GROUPS_CONFIG (in ClusterShell.NodeSet)	difference() (in RangeSet)	Display (in clubak)
DEF_STD_GROUP_RESOLVER (in ClusterShell.NodeSet)	difference_update() (in NodeSet)	Display (in clush)
default() (in Task)	difference_update() (in NodeSetBase)	display() (in clubak)
default_excepthook() (in Task)	difference_update() (in RangeSet)	DistantWorker (in ClusterShell.Worker.Worker)
did_timeout() (in Worker)	DirectOutputHandler (in clush)
difference() (in NodeSetBase)	disarm() (in _EngineTimerCase)

E

E_ANY (in Engine)	EnginePoll (in ClusterShell.Engine.Poll)	ev_hup() (in GatherOutputHandler)
E_ERROR (in Engine)	EnginePort (in ClusterShell.Worker.EngineClient)	ev_msg() (in EventHandler)
E_READ (in Engine)	engines (in PreferredEngine)	ev_msg() (in _SyncMsgHandler)
E_WRITE (in Engine)	EngineTimeoutException (in ClusterShell.Engine.Engine)	ev_read() (in EventHandler)
Engine (in ClusterShell)	EngineTimer (in ClusterShell.Engine.Engine)	ev_read() (in DirectOutputHandler)
Engine (in ClusterShell.Engine)	EPoll (in ClusterShell.Engine)	ev_read() (in GatherOutputHandler)
Engine (in ClusterShell.Engine.Engine)	erase_line() (in RunTimer)	ev_read() (in StdInputHandler)
EngineAbortException (in ClusterShell.Engine.Engine)	error() (in WorkerSimple)	ev_start() (in EventHandler)
EngineAlreadyRunningError (in ClusterShell.Engine.Engine)	error_exit() (in nodeset)	ev_timeout() (in EventHandler)
EngineBaseTimer (in ClusterShell.Engine.Engine)	error_fileno() (in EngineClient)	ev_timeout() (in DirectOutputHandler)
EngineClient (in ClusterShell.Worker)	error_fileno() (in WorkerSimple)	ev_timer() (in EventHandler)
EngineClient (in ClusterShell.Worker.EngineClient)	ev_close() (in EventHandler)	ev_timer() (in RunTimer)
EngineClientEOF (in ClusterShell.Worker.EngineClient)	ev_close() (in DirectOutputHandler)	ev_written() (in EventHandler)
EngineClientError (in ClusterShell.Worker.EngineClient)	ev_close() (in GatherOutputHandler)	Event (in ClusterShell)
EngineClientException (in ClusterShell.Worker.EngineClient)	ev_close() (in StdInputHandler)	EventHandler (in ClusterShell.Event)
EngineClientNotSupportedError (in ClusterShell.Worker.EngineClient)	ev_error() (in EventHandler)	excepthook (in Task)
EngineEPoll (in ClusterShell.Engine.EPoll)	ev_error() (in DirectOutputHandler)	exited() (in Engine)
EngineException (in ClusterShell.Engine.Engine)	ev_error() (in GatherOutputHandler)	expand() (in ClusterShell.NodeSet)
EngineIllegalOperationError (in ClusterShell.Engine.Engine)	ev_hup() (in EventHandler)	expired() (in _EngineTimerQ)
EngineNotSupportedError (in ClusterShell.Engine.Engine)	ev_hup() (in DirectOutputHandler)

F

Factory (in ClusterShell.Engine)	flush_buffers() (in Worker)	fromlist() (in NodeSet)
finalize() (in RunTimer)	flush_errors() (in Task)	fromlist() (in RangeSet)
fire() (in _EngineTimerQ)	flush_errors() (in Worker)	fromone() (in RangeSet)
fire_timers() (in Engine)	fold() (in ClusterShell.NodeSet)
flush_buffers() (in Task)	fromall() (in NodeSet)

G

GatherOutputHandler (in clush)	get_ssh_path() (in ClushConfig)	GroupResolverConfig (in ClusterShell.NodeUtils)
get() (in MsgTree)	get_ssh_user() (in ClushConfig)	GroupResolverConfigError (in ClusterShell.NodeUtils)
get() (in _Msg)	get_verbosity() (in ClushConfig)	GroupResolverError (in ClusterShell.NodeUtils)
get_color() (in ClushConfig)	getfloat() (in ClushConfig)	GroupResolverSourceError (in ClusterShell.NodeUtils)
get_command_timeout() (in ClushConfig)	getint() (in ClushConfig)	GroupSource (in ClusterShell.NodeUtils)
get_connect_timeout() (in ClushConfig)	group_nodes() (in GroupResolver)	GroupSourceException (in ClusterShell.NodeUtils)
get_fanout() (in ClushConfig)	grouplist() (in ClusterShell.NodeSet)	GroupSourceNoUpcall (in ClusterShell.NodeUtils)
get_history_file() (in clush)	grouplist() (in GroupResolver)	GroupSourceQueryFailed (in ClusterShell.NodeUtils)
get_ssh_options() (in ClushConfig)	GroupResolver (in ClusterShell.NodeUtils)

H

has_node_groups() (in GroupResolver)

I

identifier (in EngineEPoll)	invalidate() (in _EngineTimerQ)	iter_buffers() (in DistantWorker)
identifier (in Engine)	is_valid() (in EngineBaseTimer)	iter_errors() (in Task)
identifier (in EnginePoll)	issubset() (in NodeSet)	iter_errors() (in DistantWorker)
info() (in Task)	issubset() (in NodeSetBase)	iter_keys_timeout() (in Task)
intersection() (in NodeSetBase)	issubset() (in RangeSet)	iter_keys_timeout() (in DistantWorker)
intersection() (in RangeSet)	issuperset() (in NodeSet)	iter_node_buffers() (in DistantWorker)
intersection_update() (in NodeSet)	issuperset() (in NodeSetBase)	iter_node_errors() (in DistantWorker)
intersection_update() (in NodeSetBase)	issuperset() (in RangeSet)	iter_node_retcodes() (in DistantWorker)
intersection_update() (in RangeSet)	items() (in MsgTree)	iter_retcodes() (in Task)
invalidate() (in EngineBaseTimer)	iter_buffers() (in Task)	iter_retcodes() (in DistantWorker)

J

join() (in Task)

K

key_buffer() (in Task)	key_retcode() (in Task)
key_error() (in Task)	keys() (in MsgTree)

L

last_error() (in DistantWorker)	last_read() (in DistantWorker)	line_mode (in Display)
last_error() (in Worker)	last_read() (in Worker)	line_mode (in Display)
last_error() (in WorkerSimple)	last_read() (in WorkerSimple)	lines() (in MsgTreeElem)
last_node() (in DistantWorker)	last_retcode() (in DistantWorker)

M

main_defaults (in ClushConfig)	messages() (in MsgTree)	MsgTree (in ClusterShell)
max_fdlimit() (in ClushConfig)	modify() (in Engine)	MsgTree (in ClusterShell.MsgTree)
max_retcode() (in Task)	msg() (in EnginePort)	MsgTreeElem (in ClusterShell.MsgTree)
message() (in MsgTreeElem)	msg_send() (in EnginePort)

N

nextfire_delay() (in _EngineTimerQ)	NodeSet (in ClusterShell.NodeSet)	NodeSetParseError (in ClusterShell.NodeSet)
node_buffer() (in DistantWorker)	nodeset	NodeSetParseRangeError (in ClusterShell.NodeSet)
node_error() (in DistantWorker)	nodeset_cmp() (in clubak)	NodeUtils (in ClusterShell)
node_groups() (in GroupResolver)	nodeset_cmp() (in clush)	NOGROUP_RESOLVER (in ClusterShell.NodeSet)
node_retcode() (in DistantWorker)	NodeSetBase (in ClusterShell.NodeSet)	notify_all() (in _SuspendCondition)
NodeGroupBase (in ClusterShell.NodeSet)	NodeSetException (in ClusterShell.NodeSet)	num_timeout() (in Task)
NodeSet (in ClusterShell)	NodeSetExternalError (in ClusterShell.NodeSet)	num_timeout() (in DistantWorker)

O

OP_CODES (in ParsingEngine)

P

parse() (in ParsingEngine)	Poll (in ClusterShell.Engine)	print_gather() (in Display)
parse_group() (in ParsingEngine)	Popen (in ClusterShell.Worker)	print_line() (in Display)
parse_group_string() (in ParsingEngine)	port() (in Task)	print_line() (in Display)
parse_string() (in ParsingEngine)	ports() (in Engine)	print_line_error() (in Display)
ParsingEngine (in ClusterShell.NodeSet)	PreferredEngine (in ClusterShell.Engine.Factory)	print_line_error() (in Display)
Pdsh (in ClusterShell.Worker)	print_gather() (in Display)	process_stdin() (in nodeset)

R

RangeSet (in ClusterShell.NodeSet)	remove() (in MsgTree)	run() (in Engine)
RangeSetException (in ClusterShell.NodeSet)	remove() (in NodeSetBase)	run_command() (in clush)
RangeSetPaddingError (in ClusterShell.NodeSet)	remove() (in RangeSet)	run_copy() (in clush)
RangeSetParseError (in ClusterShell.NodeSet)	remove_timer() (in Engine)	run_nodeset() (in nodeset)
read() (in WorkerSimple)	reschedule() (in _EngineTimerQ)	runloop() (in EngineEPoll)
reader_fileno() (in EngineClient)	resolv_all() (in GroupSource)	runloop() (in Engine)
reader_fileno() (in WorkerSimple)	resolv_list() (in GroupSource)	runloop() (in EnginePoll)
readline_setup() (in clush)	resolv_map() (in GroupSource)	running() (in Task)
register() (in Engine)	resolv_reverse() (in GroupSource)	RunTimer (in clush)
regroup() (in NodeSet)	resume() (in Task)
remove() (in Engine)	retcode() (in WorkerPopen)

S

schedule() (in _EngineTimerQ)	set_reading_error() (in Engine)	Ssh (in ClusterShell.Worker.Ssh)
schedule() (in Task)	set_verbosity() (in GroupResolver)	start_all() (in Engine)
Scp (in ClusterShell.Worker.Ssh)	set_write_eof() (in WorkerSsh)	start_ports() (in Engine)
SEP (in Display)	set_write_eof() (in WorkerSimple)	STD_GROUP_RESOLVER (in ClusterShell.NodeSet)
SEP (in Display)	set_writing() (in Engine)	StdInputHandler (in clush)
set_default() (in Task)	shell() (in Task)	suspend() (in Task)
set_dirty() (in RunTimer)	signal_handler() (in clush)	symmetric_difference() (in NodeSetBase)
set_events() (in Engine)	snoop_ports() (in Engine)	symmetric_difference() (in RangeSet)
set_info() (in Task)	sources() (in GroupResolver)	symmetric_difference_update() (in NodeSet)
set_key() (in WorkerSimple)	sources() (in GroupResolverConfig)	symmetric_difference_update() (in NodeSetBase)
set_main() (in ClushConfig)	split() (in NodeSet)	symmetric_difference_update() (in RangeSet)
set_nextfire() (in EngineBaseTimer)	split() (in RangeSet)	sync() (in _Msg)
set_reading() (in Engine)	Ssh (in ClusterShell.Worker)

T

Task (in ClusterShell)	task_wait() (in ClusterShell.Task)	TimeoutError (in ClusterShell.Task)
Task (in ClusterShell.Task)	TaskError (in ClusterShell.Task)	timer() (in Task)
task_cleanup() (in ClusterShell.Task)	TaskException (in ClusterShell.Task)	ttyloop() (in clush)
task_self() (in ClusterShell.Task)	TaskMsgTreeError (in ClusterShell.Task)
task_terminate() (in ClusterShell.Task)	tasksyncmethod (in Task)

U

union() (in NodeSetBase)	unregister_writer() (in Engine)	update() (in RangeSet)
union() (in RangeSet)	update() (in NodeSet)	update() (in RunTimer)
unregister() (in Engine)	update() (in NodeSetBase)	UpdatePromptException (in clush)

V

VERB_DEBUG (in clush)	VERB_STD (in clush)	verbose_print() (in ClushConfig)
VERB_QUIET (in clush)	VERB_VERB (in clush)

W

wait() (in Task)	Worker (in ClusterShell.Worker.Worker)	WorkerSsh (in ClusterShell.Worker.Ssh)
wait_check() (in _SuspendCondition)	WorkerBadArgumentError (in ClusterShell.Worker.Worker)	write() (in WorkerPdsh)
walk() (in MsgTree)	WorkerError (in ClusterShell.Worker.Worker)	write() (in WorkerSsh)
WHENCOLOR_CHOICES (in clubak)	WorkerException (in ClusterShell.Worker.Worker)	write() (in WorkerSimple)
WHENCOLOR_CHOICES (in clush)	WorkerPdsh (in ClusterShell.Worker.Pdsh)	writer_fileno() (in EngineClient)
Worker (in ClusterShell)	WorkerPopen (in ClusterShell.Worker.Popen)	writer_fileno() (in WorkerSimple)
Worker (in ClusterShell.Worker)	WorkerSimple (in ClusterShell.Worker.Worker)

_

__and__() (in NodeSetBase)	__package__ (in ClusterShell.Event)	_modify_specific() (in EngineEPoll)
__and__() (in RangeSet)	__package__ (in ClusterShell.MsgTree)	_modify_specific() (in Engine)
__call__() (in tasksyncmethod)	__package__ (in ClusterShell.NodeSet)	_modify_specific() (in EnginePoll)
__cmp__() (in _EngineTimerCase)	__package__ (in ClusterShell.NodeUtils)	_Msg (in EnginePort)
__contains__() (in NodeSetBase)	__package__ (in ClusterShell.Task)	_msg_add() (in Task)
__contains__() (in RangeSet)	__package__ (in ClusterShell.Worker.EngineClient)	_msg_by_source() (in Task)
__eq__() (in MsgTreeElem)	__package__ (in ClusterShell.Worker.Pdsh)	_n (in ClusterShell)
__eq__() (in NodeSetBase)	__package__ (in ClusterShell.Worker.Popen)	_next_op() (in ParsingEngine)
__eq__() (in RangeSet)	__package__ (in ClusterShell.Worker.Ssh)	_num_timeout_by_worker() (in Task)
__getattr__() (in _TaskMsgTree)	__package__ (in ClusterShell.Worker.Worker)	_on_errmsgline() (in WorkerSimple)
__getitem__() (in MsgTree)	__package__ (in ClusterShell.Worker)	_on_msgline() (in WorkerSimple)
__getitem__() (in MsgTreeElem)	__package__ (in ClusterShell)	_on_node_errline() (in DistantWorker)
__getitem__() (in NodeSetBase)	__package__ (in clubak)	_on_node_msgline() (in DistantWorker)
__getitem__() (in RangeSet)	__package__ (in clush)	_on_node_rc() (in WorkerPdsh)
__getslice__() (in NodeSet)	__package__ (in nodeset)	_on_node_rc() (in WorkerSsh)
__getslice__() (in RangeSet)	__setstate__() (in NodeSet)	_on_node_rc() (in DistantWorker)
__getstate__() (in NodeSet)	__str__() (in NodeSetBase)	_on_node_timeout() (in WorkerSsh)
__gt__() (in NodeSetBase)	__str__() (in RangeSet)	_on_node_timeout() (in DistantWorker)
__gt__() (in RangeSet)	__str__() (in ClushConfigError)	_on_rc() (in WorkerPopen)
__iand__() (in NodeSetBase)	__sub__() (in NodeSetBase)	_on_start() (in DistantWorker)
__iand__() (in RangeSet)	__sub__() (in RangeSet)	_on_timeout() (in WorkerSimple)
__init__() (in EngineEPoll)	__url__ (in ClusterShell)	_parse_line() (in WorkerPdsh)
__init__() (in Engine)	__version_info__ (in ClusterShell)	_print_buffer() (in Display)
__init__() (in EngineAbortException)	__xor__() (in NodeSetBase)	_print_buffer() (in Display)
__init__() (in EngineBaseTimer)	__xor__() (in RangeSet)	_print_lines() (in Display)
__init__() (in EngineTimer)	_abort() (in Task)	_print_lines() (in Display)
__init__() (in _EngineTimerCase)	_add() (in NodeGroupBase)	_rc_by_source() (in Task)
__init__() (in _EngineTimerQ)	_add() (in NodeSetBase)	_rc_iter_by_key() (in Task)
__init__() (in EnginePoll)	_add_port() (in Task)	_rc_iter_by_worker() (in Task)
__init__() (in MsgTree)	_add_range_exfold() (in RangeSet)	_rc_set() (in Task)
__init__() (in MsgTreeElem)	_binary_sanity_check() (in NodeSetBase)	_read() (in EngineClient)
__init__() (in NodeSet)	_binary_sanity_check() (in RangeSet)	_read() (in EnginePort)
__init__() (in NodeSetBase)	_call_tree_matcher() (in Task)	_read() (in WorkerSimple)
__init__() (in NodeSetParseError)	_check_fini() (in WorkerSsh)	_readerr() (in EngineClient)
__init__() (in NodeSetParseRangeError)	_close() (in EngineClient)	_readerr() (in WorkerSimple)
__init__() (in ParsingEngine)	_close() (in EnginePort)	_readerrlines() (in EngineClient)
__init__() (in RangeSet)	_close() (in WorkerPdsh)	_readlines() (in EngineClient)
__init__() (in RangeSetPaddingError)	_close() (in WorkerPopen)	_register_specific() (in EngineEPoll)
__init__() (in RangeSetParseError)	_close() (in Ssh)	_register_specific() (in Engine)
__init__() (in GroupResolver)	_close() (in WorkerSimple)	_register_specific() (in EnginePoll)
__init__() (in GroupResolverConfig)	_close_writer() (in EngineClient)	_remove() (in Engine)
__init__() (in GroupSource)	_contains() (in RangeSet)	_remove_port() (in Task)
__init__() (in GroupSourceException)	_contains_with_padding() (in RangeSet)	_reset() (in Task)
__init__() (in _SuspendCondition)	_debug() (in Engine)	_resume() (in Task)
__init__() (in Task)	_depth() (in MsgTree)	_resume_thread() (in Task)
__init__() (in _TaskMsgTree)	_dequeue_disarmed() (in _EngineTimerQ)	_run() (in Task)
__init__() (in EngineClient)	_engine_clients() (in WorkerPdsh)	_scan_string() (in ParsingEngine)
__init__() (in _Msg)	_engine_clients() (in WorkerSsh)	_set_engine() (in EngineBaseTimer)
__init__() (in EnginePort)	_engine_clients() (in Worker)	_set_reading() (in EngineClient)
__init__() (in WorkerPdsh)	_engine_clients() (in WorkerSimple)	_set_reading_error() (in EngineClient)
__init__() (in WorkerPopen)	_EngineTimerCase (in _EngineTimerQ)	_set_task() (in Worker)
__init__() (in Scp)	_EngineTimerQ (in ClusterShell.Engine.Engine)	_set_write_eof() (in EngineClient)
__init__() (in Ssh)	_errmsg_add() (in Task)	_set_writing() (in EngineClient)
__init__() (in WorkerSsh)	_errmsg_by_source() (in Task)	_setexcepthook() (in Task)
__init__() (in DistantWorker)	_exec_nonblock() (in EngineClient)	_setlmode() (in Display)
__init__() (in Worker)	_expand() (in RangeSet)	_setlmode() (in Display)
__init__() (in WorkerSimple)	_fd2client() (in Engine)	_shift() (in MsgTreeElem)
__init__() (in Display)	_find_groups() (in NodeSet)	_source() (in GroupResolver)
__init__() (in ClushConfig)	_fire() (in EngineBaseTimer)	_source() (in GroupResolverConfig)
__init__() (in ClushConfigError)	_fire() (in EngineTimer)	_start() (in EngineClient)
__init__() (in DirectOutputHandler)	_fire() (in EngineClient)	_start() (in EnginePort)
__init__() (in Display)	_flush_buffers_by_worker() (in Task)	_start() (in WorkerPdsh)
__init__() (in GatherOutputHandler)	_flush_errors_by_worker() (in Task)	_start() (in WorkerPopen)
__init__() (in RunTimer)	_fold() (in RangeSet)	_start() (in Scp)
__init__() (in StdInputHandler)	_format_header() (in Display)	_start() (in Ssh)
__ior__() (in NodeSetBase)	_format_header() (in Display)	_start() (in WorkerSimple)
__ior__() (in RangeSet)	_get_optional() (in ClushConfig)	_std_default (in Task)
__isub__() (in NodeSetBase)	_getexcepthook() (in Task)	_std_info (in Task)
__isub__() (in RangeSet)	_getlmode() (in Display)	_sub_exfold() (in RangeSet)
__iter__() (in MsgTreeElem)	_getlmode() (in Display)	_suspend_wait() (in Task)
__iter__() (in NodeSetBase)	_handle_error() (in EngineClient)	_SuspendCondition (in Task)
__iter__() (in RangeSet)	_handle_error() (in WorkerPdsh)	_SyncMsgHandler (in Task)
__ixor__() (in NodeSetBase)	_handle_error() (in Ssh)	_task_bound_check() (in Worker)
__ixor__() (in RangeSet)	_handle_error() (in WorkerSimple)	_task_lock (in Task)
__len__() (in _EngineTimerQ)	_handle_read() (in EngineClient)	_task_print_debug() (in ClusterShell.Task)
__len__() (in MsgTree)	_handle_read() (in EnginePort)	_taskid_max (in Task)
__len__() (in MsgTreeElem)	_handle_read() (in WorkerPdsh)	_TaskMsgTree (in ClusterShell.Task)
__len__() (in NodeSetBase)	_handle_read() (in Ssh)	_tasks (in Task)
__len__() (in RangeSet)	_handle_read() (in WorkerSimple)	_terminate() (in Task)
__lt__() (in NodeSetBase)	_handle_write() (in EngineClient)	_test() (in ClusterShell.NodeSet)
__lt__() (in RangeSet)	_intersect_exfold() (in RangeSet)	_thread_start() (in Task)
__new__() (in PreferredEngine)	_invoke() (in EventHandler)	_timeout_add() (in Task)
__new__() (in Task)	_invoke() (in Worker)	_unregister_specific() (in EngineEPoll)
__or__() (in NodeSetBase)	_is_task_self() (in Task)	_unregister_specific() (in Engine)
__or__() (in RangeSet)	_iter() (in NodeSetBase)	_unregister_specific() (in EnginePoll)
__package__ (in ClusterShell.Engine.EPoll)	_iter_keys_timeout_by_worker() (in Task)	_upcall_read() (in GroupSource)
__package__ (in ClusterShell.Engine.Engine)	_iterbase() (in NodeSetBase)	_verbose_print() (in GroupSource)
__package__ (in ClusterShell.Engine.Factory)	_krc_iter_by_worker() (in Task)	_write() (in EngineClient)
__package__ (in ClusterShell.Engine.Poll)	_list() (in GroupResolver)	_xor_exfold() (in RangeSet)
__package__ (in ClusterShell.Engine)	_live_line() (in GatherOutputHandler)