acknowledge_proposed_change(DerechoSST &gmsSST) | derecho::ViewManager | private |
active_leader | derecho::ViewManager | private |
add_view_upcall(const view_upcall_t &upcall) | derecho::ViewManager | |
any_persistent_objects | derecho::ViewManager | private |
await_first_view(const node_id_t my_id) | derecho::ViewManager | private |
await_rejoining_nodes(const node_id_t my_id) | derecho::ViewManager | |
barrier_sync() | derecho::ViewManager | |
bSilent | derecho::ViewManager | private |
change_commit_ready_handle | derecho::ViewManager | private |
changes_contains(const DerechoSST &gmsSST, const node_id_t q) | derecho::ViewManager | privatestatic |
check_view_committed(tcp::socket &leader_connection) | derecho::ViewManager | |
client_listener_thread | derecho::ViewManager | private |
compute_global_stability_frontier(subgroup_id_t subgroup_num) | derecho::ViewManager | |
compute_num_received_size(const View &view) | derecho::ViewManager | privatestatic |
construct_multicast_group(CallbackSet callbacks, const std::map< subgroup_id_t, SubgroupSettings > &subgroup_settings, const uint32_t num_received_size, const uint32_t slot_size) | derecho::ViewManager | private |
copy_prior_leader_proposals(DerechoSST &gmsSST) | derecho::ViewManager | privatestatic |
copy_suspected(const DerechoSST &gmsSST, std::vector< bool > &old) | derecho::ViewManager | privatestatic |
create_threads() | derecho::ViewManager | private |
curr_view | derecho::ViewManager | private |
debug_print_status() const | derecho::ViewManager | |
deliver_in_order(const int shard_leader_rank, const subgroup_id_t subgroup_num, const uint32_t num_received_offset, const std::vector< node_id_t > &shard_members, uint num_shard_senders) | derecho::ViewManager | private |
deliver_ragged_trim(DerechoSST &gmsSST) | derecho::ViewManager | private |
derive_subgroup_settings(View &curr_view, std::map< subgroup_id_t, SubgroupSettings > &subgroup_settings) | derecho::ViewManager | private |
disable_partitioning_safety | derecho::ViewManager | private |
echo_ragged_trim(std::shared_ptr< std::map< subgroup_id_t, uint32_t >> follower_subgroups_and_shards, DerechoSST &gmsSST) | derecho::ViewManager | private |
ExternalCaller class | derecho::ViewManager | friend |
finish_setup() | derecho::ViewManager | |
finish_view_change(DerechoSST &gmsSST) | derecho::ViewManager | private |
follower_ragged_edge_cleanup(const subgroup_id_t subgroup_num, uint shard_leader_rank, const uint32_t num_received_offset, uint num_shard_senders) | derecho::ViewManager | private |
get_current_view() | derecho::ViewManager | |
get_current_view_const() | derecho::ViewManager | |
get_max_payload_sizes() | derecho::ViewManager | |
get_members() | derecho::ViewManager | |
get_my_rank() | derecho::ViewManager | |
get_my_shard(subgroup_type_id_t subgroup_type, uint32_t subgroup_index) | derecho::ViewManager | |
get_number_of_shards_in_subgroup(subgroup_type_id_t subgroup_type, uint32_t subgroup_index) | derecho::ViewManager | |
get_old_shard_leaders() const | derecho::ViewManager | inline |
get_subgroup_members(subgroup_type_id_t subgroup_type, uint32_t subgroup_index) | derecho::ViewManager | |
has_pending_join() | derecho::ViewManager | inlineprivate |
in_total_restart | derecho::ViewManager | private |
initialize_multicast_groups(CallbackSet callbacks) | derecho::ViewManager | |
initialize_rdmc_sst() | derecho::ViewManager | private |
initialize_rpc_objects_t typedef | derecho::ViewManager | private |
initialize_subgroup_objects | derecho::ViewManager | private |
last_suspected | derecho::ViewManager | private |
leader_commit_change(DerechoSST &gmsSST) | derecho::ViewManager | private |
leader_commit_initial_view() | derecho::ViewManager | |
leader_committed_handle | derecho::ViewManager | private |
leader_prepare_initial_view(bool &leader_has_quorum) | derecho::ViewManager | |
leader_proposed_handle | derecho::ViewManager | private |
leader_ragged_edge_cleanup(const subgroup_id_t subgroup_num, const uint32_t num_received_offset, const std::vector< node_id_t > &shard_members, uint num_shard_senders) | derecho::ViewManager | private |
leader_start_join(DerechoSST &gmsSST) | derecho::ViewManager | private |
leave() | derecho::ViewManager | |
load_ragged_trim() | derecho::ViewManager | private |
log_ragged_trim(const int shard_leader_rank, const subgroup_id_t subgroup_num, const uint32_t num_received_offset, const uint num_shard_senders) | derecho::ViewManager | private |
make_member_ips_and_ports_map(const View &view) | derecho::ViewManager | inlineprivatestatic |
make_next_view(const std::unique_ptr< View > &curr_view, const DerechoSST &gmsSST) | derecho::ViewManager | privatestatic |
make_subgroup_maps(const SubgroupInfo &subgroup_info, const std::unique_ptr< View > &prev_view, View &curr_view) | derecho::ViewManager | privatestatic |
max_payload_sizes | derecho::ViewManager | |
min_acked(const DerechoSST &gmsSST, const std::vector< char > &failed) | derecho::ViewManager | privatestatic |
new_leader_takeover(DerechoSST &gmsSST) | derecho::ViewManager | private |
new_suspicion(DerechoSST &gmsSST) | derecho::ViewManager | private |
next_view | derecho::ViewManager | private |
old_shard_leaders_by_new_ids(const View &curr_view, const View &next_view) | derecho::ViewManager | privatestatic |
old_view_cleanup_thread | derecho::ViewManager | private |
old_views | derecho::ViewManager | private |
old_views_cv | derecho::ViewManager | private |
old_views_mutex | derecho::ViewManager | private |
pending_join_sockets | derecho::ViewManager | private |
persistence_manager_callbacks | derecho::ViewManager | private |
PersistenceManager class | derecho::ViewManager | friend |
pred_handle typedef | derecho::ViewManager | private |
previous_leaders_suspected(const DerechoSST &gmsSST, const View &curr_view) | derecho::ViewManager | privatestatic |
prior_view_shard_leaders | derecho::ViewManager | private |
proposed_join_sockets | derecho::ViewManager | private |
receive_initial_view(node_id_t my_id, tcp::socket &leader_connection) | derecho::ViewManager | private |
receive_join(DerechoSST &gmsSST, tcp::socket &client_socket) | derecho::ViewManager | private |
receive_vector2d(tcp::socket &socket) | derecho::ViewManager | inlineprivatestatic |
receive_view_and_leaders(const node_id_t my_id, tcp::socket &leader_connection) | derecho::ViewManager | private |
redirect_join_attempt(DerechoSST &gmsSST) | derecho::ViewManager | private |
register_initialize_objects_upcall(initialize_rpc_objects_t upcall) | derecho::ViewManager | inline |
register_predicates() | derecho::ViewManager | private |
reinit_tcp_connections(const View &initial_view, node_id_t my_id) | derecho::ViewManager | private |
reject_join_handle | derecho::ViewManager | private |
Replicated class | derecho::ViewManager | friend |
ReplicatedObjectReferenceMap typedef | derecho::ViewManager | private |
report_failure(const node_id_t who) | derecho::ViewManager | |
restart_leader_state_machine | derecho::ViewManager | private |
restart_state | derecho::ViewManager | private |
RestartLeaderState class | derecho::ViewManager | friend |
rpc::RPCManager class | derecho::ViewManager | friend |
send(subgroup_id_t subgroup_num, long long unsigned int payload_size, const std::function< void(char *buf)> &msg_generator, bool cooked_send=false) | derecho::ViewManager | |
send_logs() | derecho::ViewManager | |
send_objects_to_new_members(const View &new_view, const vector_int64_2d &old_shard_leaders) | derecho::ViewManager | private |
send_subgroup_object(subgroup_id_t subgroup_id, node_id_t new_node_id) | derecho::ViewManager | private |
send_view(const View &new_view, tcp::socket &client_socket) | derecho::ViewManager | private |
server_socket | derecho::ViewManager | private |
setup_initial_tcp_connections(const View &initial_view, node_id_t my_id) | derecho::ViewManager | private |
silence() | derecho::ViewManager | |
start() | derecho::ViewManager | |
start_join_handle | derecho::ViewManager | private |
start_meta_wedge(DerechoSST &gmsSST) | derecho::ViewManager | private |
subgroup_info | derecho::ViewManager | private |
subgroup_objects | derecho::ViewManager | private |
subgroup_type_order | derecho::ViewManager | private |
suspected_changed_handle | derecho::ViewManager | private |
suspected_not_equal(const DerechoSST &gmsSST, const std::vector< bool > &old) | derecho::ViewManager | privatestatic |
tcp_sockets | derecho::ViewManager | private |
terminate_epoch(DerechoSST &gmsSST) | derecho::ViewManager | private |
thread_shutdown | derecho::ViewManager | private |
transition_multicast_group(const std::map< subgroup_id_t, SubgroupSettings > &new_subgroup_settings, const uint32_t new_num_received_size, const uint32_t new_slot_size) | derecho::ViewManager | private |
truncate_logs() | derecho::ViewManager | |
truncate_persistent_logs(const ragged_trim_map_t &logged_ragged_trim) | derecho::ViewManager | private |
update_tcp_connections(const View &new_view) | derecho::ViewManager | private |
view_change_cv | derecho::ViewManager | private |
view_max_rpc_reply_payload_size | derecho::ViewManager | |
view_max_rpc_window_size | derecho::ViewManager | |
view_mutex | derecho::ViewManager | private |
view_upcalls | derecho::ViewManager | private |
ViewManager(const SubgroupInfo &subgroup_info, const std::vector< std::type_index > &subgroup_type_order, const bool any_persistent_objects, const std::shared_ptr< tcp::tcp_connections > &group_tcp_sockets, ReplicatedObjectReferenceMap &object_reference_map, const persistence_manager_callbacks_t &_persistence_manager_callbacks, std::vector< view_upcall_t > _view_upcalls={}) | derecho::ViewManager | |
ViewManager(tcp::socket &leader_connection, const SubgroupInfo &subgroup_info, const std::vector< std::type_index > &subgroup_type_order, const bool any_persistent_objects, const std::shared_ptr< tcp::tcp_connections > &group_tcp_sockets, ReplicatedObjectReferenceMap &object_reference_map, const persistence_manager_callbacks_t &_persistence_manager_callbacks, std::vector< view_upcall_t > _view_upcalls={}) | derecho::ViewManager | |
~ViewManager() | derecho::ViewManager | |