Theme by the Executable Book Project

Class ucx_message_listener¶

Defined in File messageListener.hpp

Inheritance Relationships¶

Base Type¶

public comm::message_listener (Class message_listener)

Class Documentation¶

class comm::ucx_message_listener : public comm::message_listener ¶

Public Functions

void poll_begin_message_tag(bool running_from_unit_test)¶

void add_receiver(ucp_tag_t tag, std::shared_ptr<message_receiver> receiver)¶

std::shared_ptr<message_receiver> get_receiver(ucp_tag_t tag)¶

void remove_receiver(ucp_tag_t tag)¶

ucp_worker_h get_worker()¶

virtual void start_polling() override¶

Public Static Functions

static void initialize_message_listener(ucp_context_h context, ucp_worker_h worker, const std::map<std::string, comm::node> &nodes, int num_threads, std::shared_ptr<ral::cache::CacheMachine> input_cache)¶

static ucx_message_listener *get_instance()¶

Class ucx_buffer_transport Template Class Queue