Commit 7ebba2fd authored by Jakob Otto's avatar Jakob Otto

Fix transport_worker_dispatcher test

parent e774b6a8
...@@ -199,13 +199,14 @@ struct fixture : host_fixture { ...@@ -199,13 +199,14 @@ struct fixture : host_fixture {
auto p = make_actor<dummy_actor, strong_actor_ptr>(aid, nid, &sys, cfg); auto p = make_actor<dummy_actor, strong_actor_ptr>(aid, nid, &sys, cfg);
auto test_span = as_bytes(make_span(hello_test)); auto test_span = as_bytes(make_span(hello_test));
buffer_type payload(test_span.begin(), test_span.end()); buffer_type payload(test_span.begin(), test_span.end());
auto strong_actor = actor_cast<strong_actor_ptr>(p); auto receiver = actor_cast<strong_actor_ptr>(p);
if (!receiver)
CAF_FAIL("receiver cast failed");
mailbox_element::forwarding_stack stack; mailbox_element::forwarding_stack stack;
auto elem = make_mailbox_element(std::move(strong_actor), auto elem = make_mailbox_element(nullptr, make_message_id(12345),
make_message_id(12345), std::move(stack), std::move(stack), make_message());
make_message());
return detail::make_unique<endpoint_manager_queue::message>(std::move(elem), return detail::make_unique<endpoint_manager_queue::message>(std::move(elem),
strong_actor, receiver,
payload); payload);
} }
...@@ -223,8 +224,8 @@ struct fixture : host_fixture { ...@@ -223,8 +224,8 @@ struct fixture : host_fixture {
void test_write_message(testdata& testcase) { void test_write_message(testdata& testcase) {
auto msg = make_dummy_message(testcase.nid); auto msg = make_dummy_message(testcase.nid);
if (!msg->msg->sender) if (!msg->receiver)
CAF_FAIL("sender is null"); CAF_FAIL("receiver is null");
dispatcher.write_message(dummy, std::move(msg)); dispatcher.write_message(dummy, std::move(msg));
} }
......
...@@ -115,7 +115,7 @@ CAF_TEST(read / write using span<byte>) { ...@@ -115,7 +115,7 @@ CAF_TEST(read / write using span<byte>) {
CAF_CHECK_EQUAL(received, hello_test); CAF_CHECK_EQUAL(received, hello_test);
} }
CAF_TEST(read / write using span<std::vector<byte>>) { CAF_TEST(read / write using span<std::vector<byte>*>) {
// generate header and payload in separate buffers // generate header and payload in separate buffers
header hdr{hello_test.size()}; header hdr{hello_test.size()};
std::vector<byte> hdr_buf; std::vector<byte> hdr_buf;
......
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