Derecho  0.9
Distributed systems toolkit for RDMA
derecho::MulticastGroup Member List

This is the complete list of members for derecho::MulticastGroup, including all inherited members.

callbacksderecho::MulticastGroupprivate
check_failures_loop()derecho::MulticastGroupprivate
check_pending_sst_sends(subgroup_id_t subgroup_num)derecho::MulticastGroup
compute_global_stability_frontier(subgroup_id_t subgroup_num)derecho::MulticastGroup
create_rdmc_sst_groups()derecho::MulticastGroupprivate
current_receivesderecho::MulticastGroupprivate
current_sendsderecho::MulticastGroupprivate
debug_print()derecho::MulticastGroup
deliver_message(RDMCMessage &msg, const subgroup_id_t &subgroup_num, const persistent::version_t &version, const uint64_t &msg_timestamp)derecho::MulticastGroupprivate
deliver_message(SSTMessage &msg, const subgroup_id_t &subgroup_num, const persistent::version_t &version, const uint64_t &msg_timestamp)derecho::MulticastGroupprivate
deliver_messages_upto(const std::vector< int32_t > &max_indices_for_senders, subgroup_id_t subgroup_num, uint32_t num_shard_senders)derecho::MulticastGroup
delivery_pred_handlesderecho::MulticastGroupprivate
delivery_trigger(subgroup_id_t subgroup_num, const SubgroupSettings &subgroup_settings, const uint32_t num_shard_members, DerechoSST &sst)derecho::MulticastGroupprivate
free_message_buffersderecho::MulticastGroupprivate
future_message_indicesderecho::MulticastGroupprivate
get_buffer_and_send_auto_null(subgroup_id_t subgroup_num)derecho::MulticastGroupprivate
get_num_senders(const std::vector< int > &shard_senders)derecho::MulticastGroupinlineprivate
get_sendbuffer_ptr(subgroup_id_t subgroup_num, long long unsigned int payload_size, bool cooked_send)derecho::MulticastGroupprivate
get_shard_sst_indices(subgroup_id_t subgroup_num)derecho::MulticastGroup
get_subgroup_settings()derecho::MulticastGroupinline
get_time()derecho::MulticastGroupprivate
initialize_sst_row()derecho::MulticastGroupprivate
last_transfer_mediumderecho::MulticastGroupprivate
locally_stable_rdmc_messagesderecho::MulticastGroupprivate
locally_stable_sst_messagesderecho::MulticastGroupprivate
member_indexderecho::MulticastGroupprivate
membersderecho::MulticastGroupprivate
msg_state_mtxderecho::MulticastGroupprivate
MulticastGroup(std::vector< node_id_t > members, node_id_t my_node_id, std::shared_ptr< DerechoSST > sst, CallbackSet callbacks, uint32_t total_num_subgroups, const std::map< subgroup_id_t, SubgroupSettings > &subgroup_settings_by_id, unsigned int sender_timeout, const subgroup_post_next_version_func_t &post_next_version_callback, const persistence_manager_callbacks_t &persistence_manager_callbacks, std::vector< char > already_failed={})derecho::MulticastGroup
MulticastGroup(std::vector< node_id_t > members, node_id_t my_node_id, std::shared_ptr< DerechoSST > sst, MulticastGroup &&old_group, uint32_t total_num_subgroups, const std::map< subgroup_id_t, SubgroupSettings > &subgroup_settings_by_id, const subgroup_post_next_version_func_t &post_next_version_callback, const persistence_manager_callbacks_t &persistence_manager_callbacks, std::vector< char > already_failed={})derecho::MulticastGroup
next_message_to_deliverderecho::MulticastGroupprivate
next_sendsderecho::MulticastGroupprivate
node_id_to_sst_indexderecho::MulticastGroupprivate
non_persistent_messagesderecho::MulticastGroupprivate
non_persistent_sst_messagesderecho::MulticastGroupprivate
num_membersderecho::MulticastGroupprivate
pending_message_timestampsderecho::MulticastGroupprivate
pending_persistencederecho::MulticastGroupprivate
pending_sendsderecho::MulticastGroupprivate
pending_sst_sendsderecho::MulticastGroupprivate
persistence_manager_callbacksderecho::MulticastGroupprivate
persistence_pred_handlesderecho::MulticastGroupprivate
post_next_version_callbackderecho::MulticastGroupprivate
pred_handle typedefderecho::MulticastGroupprivate
rdmc_group_num_offsetderecho::MulticastGroupprivate
rdmc_sst_groups_createdderecho::MulticastGroupprivate
received_intervalsderecho::MulticastGroupprivate
receiver_function(subgroup_id_t subgroup_num, const SubgroupSettings &subgroup_settings, const std::map< uint32_t, uint32_t > &shard_ranks_by_sender_rank, uint32_t num_shard_senders, DerechoSST &sst, unsigned int batch_size, const std::function< void(uint32_t, volatile char *, uint32_t)> &sst_receive_handler_lambda)derecho::MulticastGroupprivate
receiver_pred_handlesderecho::MulticastGroupprivate
receiver_predicate(const SubgroupSettings &subgroup_settings, const std::map< uint32_t, uint32_t > &shard_ranks_by_sender_rank, uint32_t num_shard_senders, const DerechoSST &sst)derecho::MulticastGroupprivate
register_predicates()derecho::MulticastGroupprivate
register_rpc_callback(rpc_handler_t handler)derecho::MulticastGroupinline
resolve_num_received(int32_t index, uint32_t num_received_entry)derecho::MulticastGroupprivate
rpc_callbackderecho::MulticastGroupprivate
send(subgroup_id_t subgroup_num, long long unsigned int payload_size, const std::function< void(char *buf)> &msg_generator, bool cooked_send)derecho::MulticastGroup
send_loop()derecho::MulticastGroupprivate
sender_cvderecho::MulticastGroupprivate
sender_pred_handlesderecho::MulticastGroupprivate
sender_threadderecho::MulticastGroupprivate
sender_timeoutderecho::MulticastGroupprivate
singleton_shard_receive_handlersderecho::MulticastGroupprivate
sstderecho::MulticastGroupprivate
sst_multicast_group_ptrsderecho::MulticastGroupprivate
sst_receive_handler(subgroup_id_t subgroup_num, const SubgroupSettings &subgroup_settings, const std::map< uint32_t, uint32_t > &shard_ranks_by_sender_rank, uint32_t num_shard_senders, uint32_t sender_rank, volatile char *data, uint64_t size)derecho::MulticastGroupprivate
stability_pred_handlesderecho::MulticastGroupprivate
subgroup_settings_mapderecho::MulticastGroupprivate
subgroup_to_rdmc_groupderecho::MulticastGroupprivate
thread_shutdownderecho::MulticastGroupprivate
timeout_threadderecho::MulticastGroupprivate
total_num_subgroupsderecho::MulticastGroupprivate
version_message(RDMCMessage &msg, const subgroup_id_t &subgroup_num, const persistent::version_t &version, const uint64_t &msg_timestamp)derecho::MulticastGroupprivate
version_message(SSTMessage &msg, const subgroup_id_t &subgroup_num, const persistent::version_t &version, const uint64_t &msg_timestamp)derecho::MulticastGroupprivate
ViewManager classderecho::MulticastGroupfriend
wedge()derecho::MulticastGroup
~MulticastGroup()derecho::MulticastGroup