36 std::shared_ptr<rdma::memory_region>
mr;
40 typedef std::function<receive_destination(size_t size)>
43 typedef std::function<void(std::optional<uint32_t> suspected_victim)>
46 bool initialize(
const std::map<uint32_t, std::pair<ip_addr_t, uint16_t>>& addresses,
48 void add_address(uint32_t index,
const std::pair<ip_addr_t, uint16_t>& address);
68 bool create_group(uint16_t group_number, std::vector<uint32_t> members,
71 completion_callback_t send_callback,
76 bool send(uint16_t group_number, std::shared_ptr<rdma::memory_region> mr,
77 size_t offset,
size_t length)
__attribute__((warn_unused_result));
88 std::vector<rdma::queue_pair> queue_pairs;
97 std::vector<rdma::queue_pair> extra_queue_pairs;
103 std::array<volatile int64_t, 32>
steps;
107 volatile int64_t number = -1;
std::vector< rdma::remote_memory_region > remote_memory_regions
void add_address(uint32_t index, const std::pair< ip_addr_t, uint16_t > &address)
bool initialize(const std::map< uint32_t, std::pair< ip_addr_t, uint16_t >> &addresses, uint32_t node_rank) __attribute__((warn_unused_result))
std::unique_ptr< rdma::memory_region > steps_mr
std::vector< rdma::endpoint > extra_endpoints
std::function< void(std::optional< uint32_t > suspected_victim)> failure_callback_t
std::shared_ptr< rdma::memory_region > mr
std::array< volatile int64_t, 32 > steps
void destroy_group(uint16_t group_number)
bool send(uint16_t group_number, std::shared_ptr< rdma::memory_region > mr, size_t offset, size_t length) __attribute__((warn_unused_result))
std::function< receive_destination(size_t size)> incoming_message_callback_t
std::function< void(char *buffer, size_t size)> completion_callback_t
std::unique_ptr< rdma::memory_region > number_mr
bool create_group(uint16_t group_number, std::vector< uint32_t > members, size_t block_size, send_algorithm algorithm, incoming_message_callback_t incoming_receive, completion_callback_t send_callback, failure_callback_t failure_callback) __attribute__((warn_unused_result))
Creates a new RDMC group.
std::vector< rdma::endpoint > endpoints
struct sst::verbs_sender_ctxt __attribute__