Commit 98dbfe27 authored by Dominik Charousset's avatar Dominik Charousset

Add convenience functions for TCP to broker

parent cd16965f
...@@ -252,6 +252,8 @@ class broker : public extend<local_actor>:: ...@@ -252,6 +252,8 @@ class broker : public extend<local_actor>::
m_scribes.insert(std::make_pair(ptr->hdl(), ptr)); m_scribes.insert(std::make_pair(ptr->hdl(), ptr));
} }
connection_handle add_tcp_scribe(const std::string& host, uint16_t port);
inline void add_doorman(const doorman_pointer& ptr) { inline void add_doorman(const doorman_pointer& ptr) {
m_doormen.insert(std::make_pair(ptr->hdl(), ptr)); m_doormen.insert(std::make_pair(ptr->hdl(), ptr));
if (is_initialized()) { if (is_initialized()) {
...@@ -259,6 +261,10 @@ class broker : public extend<local_actor>:: ...@@ -259,6 +261,10 @@ class broker : public extend<local_actor>::
} }
} }
std::pair<accept_handle, uint16_t> add_tcp_doorman(uint16_t port = 0,
const char* in = nullptr,
bool reuse_addr = false);
void invoke_message(const actor_addr& sender, message_id mid, message& msg); void invoke_message(const actor_addr& sender, message_id mid, message& msg);
void enqueue(const actor_addr&, message_id, message, void enqueue(const actor_addr&, message_id, message,
......
...@@ -353,5 +353,15 @@ network::multiplexer& broker::backend() { ...@@ -353,5 +353,15 @@ network::multiplexer& broker::backend() {
return m_mm.backend(); return m_mm.backend();
} }
connection_handle broker::add_tcp_scribe(const std::string& hst, uint16_t prt) {
return backend().add_tcp_scribe(this, hst, prt);
}
std::pair<accept_handle, uint16_t>
broker::add_tcp_doorman(uint16_t port, const char* in, bool reuse_addr) {
return backend().add_tcp_doorman(this, port, in, reuse_addr);
}
} // namespace io } // namespace io
} // namespace caf } // namespace caf
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment