Commit d5671fa3 authored by Dominik Charousset's avatar Dominik Charousset

Fix sequencing in learned_new_node actor

parent a334c19b
...@@ -263,10 +263,14 @@ void basp_broker_state::learned_new_node(const node_id& nid) { ...@@ -263,10 +263,14 @@ void basp_broker_state::learned_new_node(const node_id& nid) {
auto& tmp = spawn_servers[nid]; auto& tmp = spawn_servers[nid];
tmp = system().spawn<hidden>([=](event_based_actor* this_actor) -> behavior { tmp = system().spawn<hidden>([=](event_based_actor* this_actor) -> behavior {
CAF_LOG_TRACE(""); CAF_LOG_TRACE("");
// skip messages until we receive the initial ok_atom
this_actor->set_unexpected_handler(skip_unexpected);
return { return {
[=](ok_atom, const std::string& /* key == "info" */, [=](ok_atom, const std::string& /* key == "info" */,
const actor_addr& config_serv_addr, const std::string& /* name */) { const actor_addr& config_serv_addr, const std::string& /* name */) {
CAF_LOG_TRACE(CAF_ARG(config_serv_addr)); CAF_LOG_TRACE(CAF_ARG(config_serv_addr));
// drop unexpected messages from this point on
this_actor->set_unexpected_handler(print_and_drop_unexpected);
auto config_serv = actor_cast<actor>(config_serv_addr); auto config_serv = actor_cast<actor>(config_serv_addr);
this_actor->monitor(config_serv); this_actor->monitor(config_serv);
this_actor->become( this_actor->become(
......
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