Commit 64c9b996 authored by Dominik Charousset's avatar Dominik Charousset

Remove P2P fixture, remove BASP from fixture

parent ae20e892
...@@ -37,14 +37,12 @@ public: ...@@ -37,14 +37,12 @@ public:
exec_all_nodes_fun exec_all_nodes; exec_all_nodes_fun exec_all_nodes;
caf::io::middleman& mm; caf::io::middleman& mm;
caf::io::network::test_multiplexer& mpx; caf::io::network::test_multiplexer& mpx;
caf::io::basp_broker* basp;
/// @param fun A function object for delegating to the parent's `exec_all`. /// @param fun A function object for delegating to the parent's `exec_all`.
test_node_fixture(exec_all_nodes_fun fun) test_node_fixture(exec_all_nodes_fun fun)
: exec_all_nodes(std::move(fun)), : exec_all_nodes(std::move(fun)),
mm(this->sys.middleman()), mm(this->sys.middleman()),
mpx(dynamic_cast<caf::io::network::test_multiplexer&>(mm.backend())), mpx(dynamic_cast<caf::io::network::test_multiplexer&>(mm.backend())) {
basp(get_basp_broker()) {
// nop // nop
} }
...@@ -186,6 +184,10 @@ public: ...@@ -186,6 +184,10 @@ public:
return [&] { exec_all(); }; return [&] { exec_all(); };
} }
void loop_after_next_enqueue(PlanetType& planet) {
planet.sched.after_next_enqueue(exec_all_callback());
}
private: private:
int64_t hdl_id_ = 0; int64_t hdl_id_ = 0;
std::vector<PlanetType*> planets_; std::vector<PlanetType*> planets_;
...@@ -209,7 +211,8 @@ public: ...@@ -209,7 +211,8 @@ public:
: super({&earth, &mars}), : super({&earth, &mars}),
earth(this->exec_all_callback()), earth(this->exec_all_callback()),
mars(this->exec_all_callback()) { mars(this->exec_all_callback()) {
// nop // Run initialization code.
this->exec_all();
} }
}; };
......
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