Index

A

Action (class in combtest.action) add_work() (combtest.worker.ThreadPool method)

append() (combtest.walk.Walk method) attach() (combtest.bootstrap.ServiceHandleArray method)

B

BaseAction (class in combtest.action)

C

CancelWalk clients (combtest.worker.ServiceGroup attribute) combtest.action (module) combtest.bootstrap (module) combtest.config (module) combtest.encode (module) combtest.forkjoin (module) combtest.replay (module) combtest.runner (module) combtest.ssh_handle (module)

combtest.utils (module) combtest.walk (module) combtest.worker (module) CONFIG_LOC (in module combtest.config) ConnectionInfo (class in combtest.bootstrap) ContinuingWalkServiceGroup (class in combtest.runner) CoordinatorService (class in combtest.worker) count_cancel() (combtest.runner.WalkRunner method) count_error() (combtest.runner.WalkRunner method) count_total() (combtest.runner.WalkRunner method)

D

decode() (in module combtest.encode) DEFAULT_INSTANCE_COUNT (combtest.worker.ServiceGroup attribute) DEFAULT_LOGGER_PORT (in module combtest.config)

DEFAULT_MAX_THREAD_COUNT (combtest.worker.CoordinatorService attribute) (in module combtest.config) DEFAULT_SERVICE_PORT (in module combtest.config)

E

elapsed (combtest.runner.Result attribute) encode() (in module combtest.encode) error_count (combtest.runner.Result attribute) execute() (combtest.walk.Walk method) exposed_add_work() (combtest.worker.CoordinatorService method) exposed_clean_worker() (combtest.runner.WalkExecutorService method) (combtest.worker.CoordinatorService method) exposed_gather_state() (combtest.runner.MultistageWalkRunningService method) (combtest.runner.WalkExecutorService method) (combtest.worker.CoordinatorService method)

exposed_join_all_workers() (combtest.worker.CoordinatorService method) exposed_join_workers() (combtest.worker.CoordinatorService method) exposed_run() (combtest.worker.CoordinatorService method) exposed_signal_stop() (combtest.worker.CoordinatorService method) exposed_start_remote_logging() (combtest.worker.CoordinatorService method) exposed_start_work() (combtest.worker.CoordinatorService method) exposed_start_workers_on() (combtest.worker.CoordinatorService method)

F

failed_tests (combtest.runner.Result attribute) fork_join() (in module combtest.forkjoin)

from_json() (combtest.action.BaseAction class method) (combtest.action.OptionSet class method)

G

gather_all_runner_states() (combtest.runner.ContinuingWalkServiceGroup method) gather_all_states() (combtest.runner.ContinuingWalkServiceGroup method) (combtest.worker.ServiceGroup method) gather_runner_state() (combtest.runner.ContinuingWalkServiceGroup method) gather_state() (combtest.runner.ContinuingWalkServiceGroup method) (combtest.worker.ServiceGroup method) get_class_from_qualname() (in module combtest.utils) get_class_qualname() (in module combtest.utils) get_logger_port() (in module combtest.config) get_machine_ips() (in module combtest.config)

get_max_thread_count() (in module combtest.config) get_my_IP() (in module combtest.utils) get_option_set() (combtest.action.Action class method) (combtest.action.BaseAction class method) get_random_action_by_class() (in module combtest.action) get_service_port() (in module combtest.config) get_ssh_options() (in module combtest.config) get_ssh_passwords() (in module combtest.config) get_ssh_rsa_keys() (in module combtest.config) get_ssh_usernames() (in module combtest.config) give_up() (combtest.worker.ServiceGroup class method)

I

is_alive (combtest.bootstrap.ServiceHandleArray attribute)

J

join() (combtest.worker.ServiceGroup method) (combtest.worker.ThreadPool method)

K

kick_workers() (combtest.worker.ThreadPool method)

L

load_from_master() (in module combtest.replay)

load_from_trace() (in module combtest.replay) logs (combtest.runner.Result attribute)

M

MultistageWalkRunner (class in combtest.runner)

MultistageWalkRunningService (class in combtest.runner)

N

next() (combtest.action.OptionSet method)

O

on_connect() (combtest.worker.CoordinatorService method) on_error_item() (combtest.runner.WalkThreadPool method) (combtest.worker.ThreadPool method) on_finish() (combtest.worker.ThreadPool method)

on_finish_item() (combtest.worker.ThreadPool method) on_start() (combtest.worker.ThreadPool method) on_start_item() (combtest.worker.ThreadPool method) OPTIONS (combtest.action.Action attribute) OptionSet (class in combtest.action)

P

param (combtest.action.BaseAction attribute)

prep_work_call() (combtest.runner.MultistageWalkRunner method) (combtest.runner.WalkRunner method)

R

RangeTree (class in combtest.utils) refresh_cfg() (in module combtest.config) REMOTE_CONNECTION_CLASS (combtest.bootstrap.ServiceHandleArray attribute) repack_ctx() (combtest.runner.MultistageWalkRunningService method) (combtest.runner.WalkExecutorService method) (combtest.worker.CoordinatorService method) replay_walk() (in module combtest.replay) (in module combtest.runner)

replay_walk_by_id() (in module combtest.replay) Result (class in combtest.runner) run() (combtest.action.BaseAction method) (combtest.runner.ContinuingWalkServiceGroup method) (combtest.worker.ServiceGroup method) (combtest.worker.ThreadPool method) run_tests() (in module combtest.runner) run_walk() (combtest.runner.MultistageWalkRunner method) (combtest.runner.WalkRunner method)

S

scatter_work() (combtest.runner.ContinuingWalkServiceGroup method) (combtest.worker.ServiceGroup method) segment_count (combtest.runner.Result attribute) SerialAction (class in combtest.action) ServiceGroup (class in combtest.worker) ServiceHandleArray (class in combtest.bootstrap) ServiceHandler (class in combtest.bootstrap) ServiceHandler_Local (class in combtest.bootstrap) ServiceHandler_SSH (class in combtest.ssh_handle) set_my_IP() (in module combtest.utils) set_service_port() (in module combtest.config) should_cancel() (combtest.action.BaseAction method) shutdown() (combtest.bootstrap.ServiceHandleArray method) (combtest.bootstrap.ServiceHandler method) (combtest.bootstrap.ServiceHandler_Local method) (combtest.worker.ServiceGroup method) shutdown_all() (combtest.bootstrap.ServiceHandleArray class method) shutdown_clients() (combtest.worker.ServiceGroup method) shutdown_services() (combtest.worker.ServiceGroup method) signal_stop() (combtest.worker.ThreadPool method)

sizes (combtest.walk.WalkOptions attribute) spawn() (combtest.bootstrap.ServiceHandleArray method) (combtest.worker.ServiceGroup method) spawn_clients() (combtest.worker.ServiceGroup method) spawn_many() (combtest.bootstrap.ServiceHandleArray method) spawn_services() (combtest.worker.ServiceGroup method) SPAWN_TIMEOUT (combtest.worker.ServiceGroup attribute) standard_strftime() (in module combtest.utils) start() (combtest.worker.ThreadPool method) start_all_on() (combtest.runner.ContinuingWalkServiceGroup method) (combtest.worker.ServiceGroup method) start_all_on_next() (combtest.worker.ThreadPool method) start_cmd() (combtest.bootstrap.ServiceHandler method) (combtest.bootstrap.ServiceHandler_Local method) start_remote_logging() (combtest.runner.ContinuingWalkServiceGroup method) (combtest.worker.ServiceGroup method) start_remote_services() (in module combtest.worker) start_service() (in module combtest.worker) start_service_by_name() (in module combtest.worker) states (combtest.runner.Result attribute)

T

ThreadPool (class in combtest.worker)

to_json() (combtest.action.BaseAction method) (combtest.action.OptionSet method)

U

update_remote_states() (combtest.runner.ContinuingWalkServiceGroup method)

W

Walk (class in combtest.walk) walk_count (combtest.runner.Result attribute) WALK_RUNNER_TYPE (combtest.runner.MultistageWalkRunningService attribute) (combtest.runner.WalkExecutorService attribute) WalkExecutorService (class in combtest.runner) WalkFailedError WalkOptions (class in combtest.walk) WalkOpTracer (class in combtest.walk)

WalkRunner (class in combtest.runner) WalkThreadPool (class in combtest.runner) WORK_QUANTUM_SIZE (combtest.worker.ServiceGroup attribute) work_repack() (combtest.runner.MultistageWalkRunningService method) (combtest.runner.WalkExecutorService method) (combtest.worker.CoordinatorService method) WORKER_TYPE (combtest.runner.WalkExecutorService attribute) (combtest.worker.CoordinatorService attribute) WorkItem (class in combtest.forkjoin)