Commit f8058b68 authored by Dominik Charousset's avatar Dominik Charousset

Fix message ID handling and unit test

parent 0d1de2d6
......@@ -140,13 +140,13 @@ public:
dest->eq_impl(req_id, dptr->ctrl(), dptr->context(),
std::forward<Ts>(xs)...);
dptr->request_response_timeout(timeout, req_id);
ids.emplace_back(req_id);
ids.emplace_back(req_id.response_id());
}
if (ids.empty()) {
auto req_id = dptr->new_request_id(Prio);
dptr->eq_impl(req_id.response_id(), dptr->ctrl(), dptr->context(),
make_error(sec::invalid_argument));
ids.emplace_back(req_id);
ids.emplace_back(req_id.response_id());
}
using response_type
= response_type_t<typename handle_type::signatures,
......
......@@ -170,11 +170,11 @@ CAF_TEST(requesters support fan_out_request) {
});
run_once();
expect((int, int), from(client).to(workers[0]).with(1, 2));
expect((int), from(workers[0]).to(client).with(3));
expect((int, int), from(client).to(workers[1]).with(1, 2));
expect((int), from(workers[1]).to(client).with(3));
expect((int, int), from(client).to(workers[2]).with(1, 2));
expect((int), from(client).to(workers[0]).with(3));
expect((int), from(client).to(workers[1]).with(3));
expect((int), from(client).to(workers[2]).with(3));
expect((int), from(workers[2]).to(client).with(3));
CAF_CHECK_EQUAL(*sum, 9);
}
......
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