Commit 6fc2cbf9 authored by Dominik Charousset's avatar Dominik Charousset

Fix bug in BASP test caused by recent changes

parent ca1f9e92
...@@ -115,10 +115,6 @@ public: ...@@ -115,10 +115,6 @@ public:
this_node_ = detail::singletons::get_node_id(); this_node_ = detail::singletons::get_node_id();
CAF_MESSAGE("this node: " << to_string(this_node_)); CAF_MESSAGE("this node: " << to_string(this_node_));
self_.reset(new scoped_actor); self_.reset(new scoped_actor);
// run the initialization message of the BASP broker
mpx_->exec_runnable();
// handle the message from the configuration server
mpx()->exec_runnable();
ahdl_ = accept_handle::from_int(1); ahdl_ = accept_handle::from_int(1);
mpx_->assign_tcp_doorman(aut_.get(), ahdl_); mpx_->assign_tcp_doorman(aut_.get(), ahdl_);
registry_ = detail::singletons::get_actor_registry(); registry_ = detail::singletons::get_actor_registry();
...@@ -137,6 +133,8 @@ public: ...@@ -137,6 +133,8 @@ public:
registry_->put((*ptr)->id(), registry_->put((*ptr)->id(),
actor_cast<abstract_actor_ptr>((*ptr)->address())); actor_cast<abstract_actor_ptr>((*ptr)->address()));
} }
// make sure all init messages are handled properly
mpx_->flush_runnables();
} }
uint32_t serialized_size(const message& msg) { uint32_t serialized_size(const message& msg) {
......
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