Commit a1e8e813 authored by Dominik Charousset's avatar Dominik Charousset

Fix access modifier for abstract_broker::scribe_

parent 91946b53
......@@ -249,11 +249,10 @@ protected:
bool invoke_message_from_cache();
private:
scribe_map scribes_;
doorman_map doormen_;
middleman& mm_;
detail::intrusive_partitioned_list<mailbox_element, detail::disposer> cache_;
protected:
scribe_map scribes_;
};
} // namespace io
......
......@@ -52,7 +52,7 @@ public:
return spawn_functor(nullptr,
[sptr](broker* forked) {
sptr->set_parent(forked);
forked->scribes_.emplace(sptr->hdl(), sptr);
forked->add_scribe(sptr);
},
fun, hdl, std::forward<Ts>(xs)...);
}
......
......@@ -241,14 +241,17 @@ void basp_broker_state::set_context(connection_handle hdl) {
auto i = ctx.find(hdl);
if (i == ctx.end()) {
CAF_LOG_INFO("create new BASP context for handle " << hdl.id());
i = ctx.emplace(hdl, connection_context{basp::await_header,
basp::header{invalid_node_id,
i = ctx.emplace(hdl,
connection_context{
basp::await_header,
basp::header{basp::message_type::server_handshake, 0, 0,
invalid_node_id, invalid_node_id,
invalid_actor_id, invalid_actor_id},
hdl,
invalid_node_id,
invalid_actor_id,
invalid_actor_id,
0, 0, 0},
hdl, invalid_node_id, 0, none, {}})
.first;
0,
none,
{}}).first;
}
this_context = &i->second;
}
......
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