hpx/parcelport_libfabric/libfabric_controller.hpp¶
See Public API for a list of names and headers that are part of the public HPX API.
Defines
-
HPX_PARCELPORT_LIBFABRIC_ENDPOINT_MSG
¶
-
namespace
hpx
-
namespace
parcelset
-
namespace
policies
-
namespace
libfabric
Typedefs
-
typedef std::shared_ptr<libfabric_controller>
libfabric_controller_ptr
¶
-
class
libfabric_controller
¶ Public Types
-
typedef hpx::parcelset::policies::libfabric::unique_lock<mutex_type>
unique_lock
¶
-
typedef hpx::parcelset::policies::libfabric::scoped_lock<mutex_type>
scoped_lock
¶
-
typedef hpx::concurrent::unordered_map<uint32_t, promise_tuple_type>::map_read_lock_type
map_read_lock_type
¶
-
typedef hpx::concurrent::unordered_map<uint32_t, promise_tuple_type>::map_write_lock_type
map_write_lock_type
¶
Public Functions
-
libfabric_controller
(std::string const &provider, std::string const &domain, std::string const &endpoint, int = 7910)¶
-
void
boot_PMI
()¶
-
~libfabric_controller
()¶
-
void
open_fabric
(std::string const &provider, std::string const &domain, std::string const &endpoint_type)¶
-
void
startup
(parcelport *pp)¶
-
void
_set_check_domain_op_value
(int op, const char *value)¶
-
void
_set_disable_registration
()¶
-
void
create_event_queue
()¶
-
void
new_endpoint_active
(struct fi_info *info, struct fid_ep **new_endpoint)¶
-
void
bind_endpoint_to_queues
(struct fid_ep *endpoint)¶
-
void
bind_passive_endpoint_to_queues
(struct fid_pep *endpoint)¶
-
void
initialize_localities
()¶
-
const bool &
immedate_data_supported
() const¶
-
bool
isTerminated
()¶
-
void
setConnectionFunction
(ConnectionFunction f)¶
-
void
setDisconnectionFunction
(DisconnectionFunction f)¶
-
int
poll_endpoints
(bool stopped = false)¶
-
int
poll_for_work_completions
()¶
-
int
poll_send_queue
()¶
-
int
poll_recv_queue
()¶
-
int
poll_event_queue
(bool = false)¶
-
struct fid_domain *
get_domain
()¶
-
rma_memory_pool<libfabric_region_provider> &
get_memory_pool
()¶
-
void
create_completion_queues
(struct fi_info *info, int N)¶
-
void
disconnect_all
()¶
-
bool
active
()¶
Public Members
-
hpx::concurrent::unordered_map<uint32_t, promise_tuple_type>
endpoint_tmp_
¶
-
struct fi_info *
fabric_info_
¶
-
struct fid_fabric *
fabric_
¶
-
struct fid_domain *
fabric_domain_
¶
-
struct fid_pep *
ep_passive_
¶
-
struct fid_ep *
ep_active_
¶
-
struct fid_eq *
event_queue_
¶
-
struct fid_cq *
txcq_
¶
-
struct fid_cq *
rxcq_
¶
-
struct fid_av *
av_
¶
-
bool
immediate_
¶
Private Members
-
sockaddr_in
local_addr_
¶
-
ConnectionFunction
connection_function_
¶
-
DisconnectionFunction
disconnection_function_
¶
-
std::unique_ptr<rma_memory_pool<libfabric_region_provider>>
memory_pool_
¶
-
mutex_type
initialization_mutex_
¶
-
mutex_type
endpoint_map_mutex_
¶
-
mutex_type
polling_mutex_
¶
-
uint32_t
event_pause_
¶
-
typedef hpx::parcelset::policies::libfabric::unique_lock<mutex_type>
-
typedef std::shared_ptr<libfabric_controller>
-
namespace
-
namespace
-
namespace