Theme by the Executable Book Project

Class message_listener¶

Defined in File messageListener.hpp

Inheritance Relationships¶

Derived Types¶

public comm::tcp_message_listener (Class tcp_message_listener)
public comm::ucx_message_listener (Class ucx_message_listener)

Class Documentation¶

class comm::message_listener¶

Subclassed by comm::tcp_message_listener, comm::ucx_message_listener

Public Functions

inline message_listener(const std::map<std::string, comm::node> &nodes, int num_threads, std::shared_ptr<ral::cache::CacheMachine> input_cache)¶

inline virtual ~message_listener()¶

virtual void start_polling() = 0¶

ctpl::thread_pool<BlazingThread> &get_pool()¶

std::map<std::string, comm::node> get_node_map()¶

inline std::shared_ptr<ral::cache::CacheMachine> get_input_cache()¶

Protected Attributes

ctpl::thread_pool<BlazingThread> pool¶

std::map<std::string, comm::node> _nodes_info_map¶

bool polling_started = {false}¶

std::shared_ptr<ral::cache::CacheMachine> input_cache¶

Class graphs_info Class message_receiver