Navigation
index
modules
|
ExpoCloud 1.0 documentation
»
Index
Index
_
|
A
|
B
|
C
|
D
|
E
|
F
|
G
|
H
|
I
|
K
|
L
|
M
|
N
|
O
|
P
|
Q
|
R
|
S
|
T
|
U
|
V
|
W
_
__init__() (AATask method)
(AbstractAlgorithm method)
(AbstractEngine method)
(AbstractProblemInstance method)
(AbstractTask method)
(AbstractTask.Hardness method)
(Algorithm method)
(BackupServerInstance method)
(Client method)
(ClientInstance method)
(GCE method)
(Instance method)
(LocalEngine method)
(PrimaryServerInstance method)
(ProblemInstance method)
(Server method)
(Task method)
(Worker method)
__le__() (AbstractTask.Hardness method)
__lt__() (AbstractTask.Hardness method)
__repr__() (AbstractTask method)
(AbstractTask.Hardness method)
__str__() (AATask method)
(AbstractTask method)
(AbstractTask.Hardness method)
(ProblemInstance method)
_full_assignment() (Algorithm method)
_heuristic() (Algorithm method)
_search() (Algorithm method)
A
AATask (class in examples.agent_assignment.instance)
AbstractAlgorithm (class in src.abstract_task)
AbstractEngine (class in src.abstract_engine)
AbstractProblemInstance (class in src.abstract_task)
AbstractTask (class in src.abstract_task)
AbstractTask.Hardness (class in src.abstract_task)
accept_handshakes() (Server method)
agent_costs (examples.agent_assignment.instance.AATask parameter)
Algorithm (class in examples.agent_assignment.bnb)
algorithm (examples.agent_assignment.task.Task parameter)
(src.abstract_task.AbstractTask parameter)
all (Verbosity attribute)
all_le() (in module src.util)
all_lt() (in module src.util)
all_non_health_messages (Verbosity attribute)
APPLY_DOMINO_EFFECT (MessageType attribute)
apply_domino_effect() (Client method)
arr (src.util.filter_indices parameter)
assignment (examples.agent_assignment.bnb.Algorithm._full_assignment parameter)
(examples.agent_assignment.bnb.Algorithm._heuristic parameter)
(examples.agent_assignment.bnb.Algorithm._search parameter)
(examples.agent_assignment.bnb.assignment2str parameter)
(src.util.list2str parameter)
assignment2str() (in module examples.agent_assignment.bnb)
assume_backup_role() (Server method)
assume_primary_role() (Server method)
attempt_command() (in module src.util)
B
backup (src.server.Server parameter)
BACKUP_SERVER (InstanceRole attribute)
BackupServerInstance (class in src.instance)
body (src.client.Client.message_to_servers parameter)
(src.server.Server.forward_message parameter)
(src.server.Server.message_to_instance parameter)
(src.server.Server.process_message parameter)
(src.server.Server.process_new_client parameter)
(src.server.Server.process_result parameter)
BYE (MessageType attribute)
C
Client (class in src.client)
CLIENT (InstanceRole attribute)
client (src.server.Server.process_bye parameter)
(src.server.Server.process_exception parameter)
(src.server.Server.process_log parameter)
(src.server.Server.process_request_tasks parameter)
(src.server.Server.process_result parameter)
CLIENT_CYCLE_WAIT (Constants attribute)
client_name (src.server.Server.process_client_terminated parameter)
CLIENT_TERMINATED (MessageType attribute)
CLIENT_WAIT_AFTER_SENDING_BYE (Constants attribute)
ClientInstance (class in src.instance)
CLIENTS_TIME_TO_STOP (Constants attribute)
collect_garbage() (Client method)
command (src.util.attempt_command parameter)
(src.util.remote_execute parameter)
(src.util.ssh_command parameter)
command_arg_ip() (in module src.util)
command_arg_max_cpus() (in module src.util)
command_arg_name() (in module src.util)
command_arg_port() (in module src.util)
command_lines (Verbosity attribute)
cond (src.util.filter_indices parameter)
(src.util.my_eprint parameter)
(src.util.my_print parameter)
config (src.abstract_engine.AbstractEngine parameter)
(src.engines.gce.engine.GCE parameter)
connect() (ClientInstance method)
Constants (class in src.constants)
create() (Instance method)
create_backup_server_instance() (Server method)
create_client_instance() (Server method)
create_instance() (AbstractEngine method)
(LocalEngine method)
(Server method)
create_instance_native() (GCE method)
creation_attempt_allowed() (AbstractEngine method)
D
descr (src.client.Client.event_to_servers parameter)
(src.server.Server.process_exception parameter)
(src.server.Server.process_log parameter)
dest_folder (src.util.remote_replace parameter)
(src.util.scp_command parameter)
E
e (src.util.handle_exception parameter)
engine (src.instance.BackupServerInstance parameter)
(src.instance.ClientInstance parameter)
(src.instance.Instance parameter)
(src.server.Server parameter)
err_flag (src.util.my_print parameter)
event_to_servers() (Client method)
examples
module
examples.agent_assignment
module
examples.agent_assignment.bnb
module
examples.agent_assignment.instance
module
examples.agent_assignment.run_client
module
examples.agent_assignment.run_server
module
examples.agent_assignment.task
module
EXCEPTION (MessageType attribute)
existing_clients (src.abstract_engine.AbstractEngine.kill_dangling_clients parameter)
exit_flag (src.util.handle_exception parameter)
extended_prefix() (in module src.util)
F
failure_traceback (Verbosity attribute)
filter_indices() (in module src.util)
filter_out() (in module src.util)
first_id (examples.agent_assignment.instance.generate_instances parameter)
forward_message() (Server method)
G
g (examples.agent_assignment.bnb.Algorithm._search parameter)
GCE (class in src.engines.gce.engine)
(Mode attribute)
generate_instances() (in module examples.agent_assignment.instance)
get_client() (Server method)
get_guest_qs() (in module src.util)
get_project_root() (in module src.util)
get_unused_port() (in module src.util)
GRANT_TASKS (MessageType attribute)
group_parameter_titles() (AbstractTask method)
(Task method)
group_parameters() (AbstractTask method)
H
handle_exception() (in module src.util)
handle_messages() (Server method)
handle_primary_server_failure() (Server method)
handshake() (in module src.util)
handshake_from_backup() (Server method)
handshake_from_client() (Server method)
hard (src.client.Client.apply_domino_effect parameter)
hardness (src.instance.ClientInstance.unregister_domino parameter)
(src.server.Server.is_hard parameter)
hardness_parameters() (AbstractTask method)
(Task method)
HEALTH_UPDATE (MessageType attribute)
health_update() (Client method)
HEALTH_UPDATE_FREQUENCY (Constants attribute)
HEALTH_UPDATE_LIMIT (Constants attribute)
HEURISTIC (Option attribute)
I
id (examples.agent_assignment.instance.AATask parameter)
(examples.agent_assignment.instance.ProblemInstance parameter)
(src.abstract_task.AbstractProblemInstance parameter)
(src.client.Worker parameter)
id() (AATask method)
image (src.engines.gce.engine.GCE.create_instance_native parameter)
image_name() (AbstractEngine method)
init_files() (ClientInstance method)
init_handshake_q() (Server method)
Instance (class in src.instance)
instance (examples.agent_assignment.bnb.Algorithm parameter)
(src.abstract_task.AbstractAlgorithm parameter)
(src.instance.is_backup parameter)
(src.instance.is_client parameter)
(src.instance.is_primary parameter)
(src.server.Server.forward_message parameter)
(src.server.Server.kill_instance parameter)
(src.server.Server.message_to_instance parameter)
(src.server.Server.messages_waiting parameter)
(src.server.Server.process_health_update parameter)
(src.server.Server.process_message parameter)
instance_creation_etc (Verbosity attribute)
instance_id (src.util.next_instance_name parameter)
INSTANCE_MAX_NON_ACTIVE_TIME (Constants attribute)
instance_name (src.util.output_folder parameter)
InstanceRole (class in src.util)
ip (src.abstract_engine.AbstractEngine.run_instance parameter)
(src.util.get_guest_qs parameter)
(src.util.remote_execute parameter)
(src.util.remote_replace parameter)
(src.util.scp_command parameter)
(src.util.ssh_command parameter)
ip_from_name_() (GCE method)
is_backup() (in module src.instance)
(Server method)
is_client() (in module src.instance)
is_hard() (Server method)
is_healthy() (Instance method)
(PrimaryServerInstance method)
is_local() (AbstractEngine method)
(LocalEngine method)
is_primary() (in module src.instance)
(Server method)
K
kill_client() (Server method)
kill_dangling_clients() (AbstractEngine method)
kill_dangling_instances() (LocalEngine method)
kill_instance() (AbstractEngine method)
(GCE method)
(LocalEngine method)
(Server method)
kill_overdue() (Client method)
kill_unhealthy_instances() (Server method)
L
last_id (examples.agent_assignment.instance.generate_instances parameter)
list2str() (in module src.util)
list_instances() (AbstractEngine method)
(GCE method)
LOCAL (Mode attribute)
LocalEngine (class in src.engines.local)
LOG (MessageType attribute)
M
make_manager() (in module src.util)
max_clients (src.server.Server parameter)
max_cpus (src.abstract_engine.AbstractEngine.run_instance parameter)
(src.engines.local.LocalEngine.run_instance parameter)
max_cpus_per_client (src.server.Server parameter)
MESSAGE_FROM_CLIENT (MessageType attribute)
message_id (src.server.Server.forward_message parameter)
message_sync (Verbosity attribute)
message_to_instance() (Server method)
message_to_servers() (Client method)
messages (Verbosity attribute)
messages_waiting() (Server method)
MessageType (class in src.util)
MIN_CREATION_DELAY (Constants attribute)
min_group_size (src.server.Server parameter)
Mode (class in examples.agent_assignment.run_server)
module
examples
examples.agent_assignment
examples.agent_assignment.bnb
examples.agent_assignment.instance
examples.agent_assignment.run_client
examples.agent_assignment.run_server
examples.agent_assignment.task
src
src.abstract_engine
src.abstract_task
src.client
src.constants
src.engines
src.engines.gce
src.engines.gce.engine
src.engines.local
src.instance
src.run_backup
src.server
src.util
msg (src.util.handle_exception parameter)
my_eprint() (in module src.util)
my_ip() (in module src.util)
my_kill() (Worker method)
my_name() (in module src.util)
my_port (src.instance.PrimaryServerInstance parameter)
my_port1 (src.util.handshake parameter)
my_port2 (src.util.handshake parameter)
my_print() (in module src.util)
my_role (src.util.handshake parameter)
N
n (src.client.Client.request_tasks parameter)
(src.server.Server.process_request_tasks parameter)
n_active_clients() (Server method)
n_agents (examples.agent_assignment.instance.generate_instances parameter)
n_attempts (src.util.attempt_command parameter)
n_tasks (examples.agent_assignment.instance.generate_instances parameter)
name (src.abstract_engine.AbstractEngine.create_instance parameter)
(src.abstract_engine.AbstractEngine.kill_instance parameter)
(src.abstract_engine.AbstractEngine.run_instance parameter)
(src.engines.gce.engine.GCE.create_instance_native parameter)
(src.engines.gce.engine.GCE.ip_from_name_ parameter)
(src.engines.gce.engine.GCE.kill_instance parameter)
(src.engines.local.LocalEngine.kill_instance parameter)
(src.engines.local.LocalEngine.run_instance parameter)
(src.server.Server.get_client parameter)
(src.server.Server.handshake_from_backup parameter)
(src.server.Server.handshake_from_client parameter)
(src.server.Server.kill_client parameter)
NEW_CLIENT (MessageType attribute)
next_instance_name() (AbstractEngine method)
(in module src.util)
(LocalEngine method)
NO_CUTOFFS (Option attribute)
NO_FURTHER_TASKS (MessageType attribute)
O
occupy_workers() (Client method)
Option (class in examples.agent_assignment.bnb)
options (examples.agent_assignment.bnb.Algorithm parameter)
(src.abstract_task.AbstractAlgorithm parameter)
other (src.abstract_task.AbstractTask.Hardness.__le__ parameter)
(src.abstract_task.AbstractTask.Hardness.__lt__ parameter)
OUTPUT_FOLDER (Constants attribute)
output_folder() (in module src.util)
P
parameter_titles() (AbstractTask method)
(ProblemInstance method)
(Task method)
parameters() (AbstractTask method)
(ProblemInstance method)
(Task method)
params (src.abstract_task.AbstractTask.Hardness parameter)
parent_dir (src.instance.ClientInstance.init_files parameter)
(src.instance.ClientInstance.shake_hands parameter)
path (src.util.pickled_file_name parameter)
pickled_file_name() (in module src.util)
PICKLED_SERVER_FILE (Constants attribute)
port (src.server.Server.handshake_from_backup parameter)
(src.util.get_guest_qs parameter)
(src.util.make_manager parameter)
port_backup (src.server.Server.handshake_from_client parameter)
port_primary (src.server.Server.handshake_from_client parameter)
prefix (src.abstract_engine.AbstractEngine.kill_dangling_clients parameter)
(src.util.extended_prefix parameter)
(src.util.next_instance_name parameter)
PRIMARY_SERVER (InstanceRole attribute)
PrimaryServerInstance (class in src.instance)
print_results() (Server method)
ProblemInstance (class in examples.agent_assignment.instance)
process_bye() (Server method)
process_client_terminated() (Server method)
process_exception() (Server method)
process_grant_tasks() (Client method)
process_health_update() (Server method)
process_log() (Server method)
process_message() (Server method)
process_messages() (Client method)
process_new_client() (Server method)
process_no_further_tasks() (Client method)
process_report_hard_task() (Server method)
process_request_tasks() (Server method)
process_result() (Server method)
process_resume() (Client method)
process_stop() (Client method)
process_swap_queues() (Client method)
process_worker_done() (Client method)
process_worker_messages() (Client method)
process_worker_started() (Client method)
process_workers() (Client method)
project_folder (src.engines.local.LocalEngine parameter)
Q
q_names (src.util.get_guest_qs parameter)
(src.util.make_manager parameter)
queue (src.client.Worker parameter)
R
register_tasks() (ClientInstance method)
remote_execute() (in module src.util)
remote_replace() (in module src.util)
REPORT_HARD_TASK (MessageType attribute)
REQUEST_TASKS (MessageType attribute)
request_tasks() (Client method)
RESULT (MessageType attribute)
result_titles() (AbstractTask method)
(Algorithm method)
(Task method)
RESUME (MessageType attribute)
resume_clients() (Server method)
role (src.abstract_engine.AbstractEngine.create_instance parameter)
(src.abstract_engine.AbstractEngine.image_name parameter)
(src.abstract_engine.AbstractEngine.next_instance_name parameter)
(src.abstract_engine.AbstractEngine.run_instance parameter)
(src.engines.local.LocalEngine.next_instance_name parameter)
(src.engines.local.LocalEngine.run_instance parameter)
(src.instance.Instance parameter)
(src.util.extended_prefix parameter)
(src.util.next_instance_name parameter)
run() (AbstractTask method)
(Client method)
(Instance method)
(Server method)
(Task method)
(Worker method)
run_instance() (AbstractEngine method)
(LocalEngine method)
S
s (src.util.set2str parameter)
scp_command() (in module src.util)
search() (Algorithm method)
send_health_update() (Server method)
sep (src.util.list2str parameter)
(src.util.set2str parameter)
Server (class in src.server)
SERVER_CYCLE_WAIT (Constants attribute)
server_port (src.abstract_engine.AbstractEngine.run_instance parameter)
(src.engines.local.LocalEngine.run_instance parameter)
server_role (src.instance.ClientInstance.connect parameter)
(src.instance.ClientInstance.shake_hands parameter)
set2str() (in module src.util)
shake_hands() (BackupServerInstance method)
(ClientInstance method)
(Instance method)
short_now_str() (in module src.util)
short_timestamp() (in module src.util)
source_folder (src.util.remote_replace parameter)
(src.util.scp_command parameter)
src
module
src.abstract_engine
module
src.abstract_task
module
src.client
module
src.constants
module
src.engines
module
src.engines.gce
module
src.engines.gce.engine
module
src.engines.local
module
src.instance
module
src.run_backup
module
src.server
module
src.util
module
ssh_command() (in module src.util)
SSH_RETRY_DELAY (Constants attribute)
STOP (MessageType attribute)
stop_clients() (Server method)
str (src.util.my_eprint parameter)
(src.util.my_print parameter)
SWAP_QUEUES (MessageType attribute)
T
t (src.util.tuple_to_csv parameter)
t1 (src.util.all_le parameter)
(src.util.all_lt parameter)
(src.util.filter_out parameter)
t2 (src.util.all_le parameter)
(src.util.all_lt parameter)
(src.util.filter_out parameter)
t_id (src.instance.ClientInstance.unregister_task parameter)
Task (class in examples.agent_assignment.task)
task (src.client.Client.event_to_servers parameter)
(src.client.Worker parameter)
task_id (src.server.Server.process_report_hard_task parameter)
tasks (examples.agent_assignment.instance.ProblemInstance parameter)
(src.client.Client.process_grant_tasks parameter)
(src.instance.ClientInstance.register_tasks parameter)
(src.instance.ClientInstance.unregister_domino parameter)
(src.server.Server parameter)
tasks_from_failed (src.instance.ClientInstance parameter)
tasks_remain (src.instance.Instance.is_healthy parameter)
tasks_remain() (Server method)
TIME_BETWEEN_INSTANCES (LocalEngine attribute)
timeout (examples.agent_assignment.task.Task parameter)
(src.abstract_task.AbstractTask parameter)
timestamp (src.util.short_timestamp parameter)
to_primary_q (src.util.handle_exception parameter)
tuple_to_csv() (in module src.util)
type (src.client.Client.message_to_servers parameter)
(src.server.Server.forward_message parameter)
(src.server.Server.message_to_instance parameter)
(src.server.Server.process_message parameter)
U
unregister_domino() (ClientInstance method)
unregister_task() (ClientInstance method)
V
Verbosity (class in src.constants)
W
Worker (class in src.client)
worker (src.client.Client.event_to_servers parameter)
(src.client.Client.process_worker_done parameter)
,
[1]
(src.client.Client.process_worker_started parameter)
WORKER_DONE (MessageType attribute)
WORKER_STARTED (MessageType attribute)
WORKER_WAIT_AFTER_DONE (Constants attribute)
workers (Verbosity attribute)
Quick search
Navigation
index
modules
|
ExpoCloud 1.0 documentation
»
Index