Commit 951a54d9 authored by Jakob Otto's avatar Jakob Otto

Revert falsely added as_bytes

parent a0aedac6
......@@ -87,7 +87,7 @@ public:
CAF_LOG_DEBUG("received " << num_bytes << " bytes");
auto ep = res->second;
this->read_buf_.resize(num_bytes);
this->next_layer_.handle_data(*this, as_bytes(make_span(this->read_buf_)),
this->next_layer_.handle_data(*this, make_span(this->read_buf_),
std::move(ep));
prepare_next_read();
} else {
......
......@@ -85,8 +85,8 @@ public:
this->collected_ += *num_bytes;
if (this->collected_ >= this->read_threshold_) {
if (auto err = this->next_layer_.handle_data(*this,
as_bytes(make_span(
this->read_buf_)))) {
make_span(
this->read_buf_))) {
CAF_LOG_ERROR("handle_data failed: " << CAF_ARG(err));
return false;
}
......@@ -186,7 +186,7 @@ private:
CAF_ASSERT(!buf.empty());
auto data = buf.data() + written_;
auto len = buf.size() - written_;
auto write_ret = write(this->handle(), as_bytes(make_span(data, len)));
auto write_ret = write(this->handle(), make_span(data, len));
if (auto num_bytes = get_if<size_t>(&write_ret)) {
CAF_LOG_DEBUG(CAF_ARG(this->handle_.id) << CAF_ARG(*num_bytes));
written_ += *num_bytes;
......
......@@ -274,7 +274,7 @@ void multiplexer::write_to_pipe(uint8_t opcode, const socket_manager_ptr& mgr) {
{ // Lifetime scope of guard.
std::lock_guard<std::mutex> guard{write_lock_};
if (write_handle_ != invalid_socket)
res = write(write_handle_, as_bytes(make_span(buf)));
res = write(write_handle_, make_span(buf));
else
res = sec::socket_invalid;
}
......
......@@ -75,16 +75,16 @@ struct fixture : test_coordinator_fixture<>,
set_input(basp::header{basp::message_type::handshake,
static_cast<uint32_t>(payload.size()),
basp::version});
REQUIRE_OK(app.handle_data(*this, as_bytes(make_span(input))));
REQUIRE_OK(app.handle_data(*this, make_span(input)));
CAF_CHECK_EQUAL(app.state(),
basp::connection_state::await_handshake_payload);
REQUIRE_OK(app.handle_data(*this, as_bytes(make_span(payload))));
REQUIRE_OK(app.handle_data(*this, make_span(payload)));
}
void consume_handshake() {
if (output.size() < basp::header_size)
CAF_FAIL("BASP application did not write a handshake header");
auto hdr = basp::header::from_bytes(as_bytes(make_span(output)));
auto hdr = basp::header::from_bytes(make_span(output));
if (hdr.type != basp::message_type::handshake || hdr.payload_len == 0
|| hdr.operation_data != basp::version)
CAF_FAIL("invalid handshake header");
......@@ -158,10 +158,10 @@ protected:
do { \
auto payload = to_buf(__VA_ARGS__); \
set_input(basp::header{kind, static_cast<uint32_t>(payload.size()), op}); \
if (auto err = app.handle_data(*this, as_bytes(make_span(input)))) \
if (auto err = app.handle_data(*this, make_span(input))) \
CAF_FAIL("application-under-test failed to process header: " \
<< sys.render(err)); \
if (auto err = app.handle_data(*this, as_bytes(make_span(payload)))) \
if (auto err = app.handle_data(*this, make_span(payload))) \
CAF_FAIL("application-under-test failed to process payload: " \
<< sys.render(err)); \
} while (false)
......@@ -185,21 +185,21 @@ CAF_TEST_FIXTURE_SCOPE(application_tests, fixture)
CAF_TEST(missing handshake) {
CAF_CHECK_EQUAL(app.state(), basp::connection_state::await_handshake_header);
set_input(basp::header{basp::message_type::heartbeat, 0, 0});
CAF_CHECK_EQUAL(app.handle_data(*this, as_bytes(make_span(input))),
CAF_CHECK_EQUAL(app.handle_data(*this, make_span(input)),
basp::ec::missing_handshake);
}
CAF_TEST(version mismatch) {
CAF_CHECK_EQUAL(app.state(), basp::connection_state::await_handshake_header);
set_input(basp::header{basp::message_type::handshake, 0, 0});
CAF_CHECK_EQUAL(app.handle_data(*this, as_bytes(make_span(input))),
CAF_CHECK_EQUAL(app.handle_data(*this, make_span(input)),
basp::ec::version_mismatch);
}
CAF_TEST(missing payload in handshake) {
CAF_CHECK_EQUAL(app.state(), basp::connection_state::await_handshake_header);
set_input(basp::header{basp::message_type::handshake, 0, basp::version});
CAF_CHECK_EQUAL(app.handle_data(*this, as_bytes(make_span(input))),
CAF_CHECK_EQUAL(app.handle_data(*this, make_span(input)),
basp::ec::missing_payload);
}
......@@ -210,9 +210,9 @@ CAF_TEST(invalid handshake) {
auto payload = to_buf(no_nid, no_ids);
set_input(basp::header{basp::message_type::handshake,
static_cast<uint32_t>(payload.size()), basp::version});
REQUIRE_OK(app.handle_data(*this, as_bytes(make_span(input))));
REQUIRE_OK(app.handle_data(*this, make_span(input)));
CAF_CHECK_EQUAL(app.state(), basp::connection_state::await_handshake_payload);
CAF_CHECK_EQUAL(app.handle_data(*this, as_bytes(make_span(payload))),
CAF_CHECK_EQUAL(app.handle_data(*this, make_span(payload)),
basp::ec::invalid_handshake);
}
......@@ -222,9 +222,9 @@ CAF_TEST(app identifier mismatch) {
auto payload = to_buf(mars, wrong_ids);
set_input(basp::header{basp::message_type::handshake,
static_cast<uint32_t>(payload.size()), basp::version});
REQUIRE_OK(app.handle_data(*this, as_bytes(make_span(input))));
REQUIRE_OK(app.handle_data(*this, make_span(input)));
CAF_CHECK_EQUAL(app.state(), basp::connection_state::await_handshake_payload);
CAF_CHECK_EQUAL(app.handle_data(*this, as_bytes(make_span(payload))),
CAF_CHECK_EQUAL(app.handle_data(*this, make_span(payload)),
basp::ec::app_identifiers_mismatch);
}
......@@ -237,8 +237,8 @@ CAF_TEST(repeated handshake) {
auto payload = to_buf(no_nid, no_ids);
set_input(basp::header{basp::message_type::handshake,
static_cast<uint32_t>(payload.size()), basp::version});
CAF_CHECK_EQUAL(app.handle_data(*this, as_bytes(make_span(input))), none);
CAF_CHECK_EQUAL(app.handle_data(*this, as_bytes(make_span(payload))),
CAF_CHECK_EQUAL(app.handle_data(*this, make_span(input)), none);
CAF_CHECK_EQUAL(app.handle_data(*this, make_span(payload)),
basp::ec::unexpected_handshake);
}
......@@ -337,7 +337,7 @@ CAF_TEST(heartbeat message) {
CAF_CHECK_EQUAL(app.state(), basp::connection_state::await_header);
auto bytes = to_bytes(basp::header{basp::message_type::heartbeat, 0, 0});
set_input(bytes);
REQUIRE_OK(app.handle_data(*this, as_bytes(make_span(input))));
REQUIRE_OK(app.handle_data(*this, make_span(input)));
CAF_CHECK_EQUAL(app.state(), basp::connection_state::await_header);
}
......
......@@ -45,7 +45,7 @@ CAF_TEST(serialization) {
CAF_CHECK_EQUAL(source(y), none);
}
CAF_CHECK_EQUAL(x, y);
auto z = basp::header::from_bytes(as_bytes(make_span(buf)));
auto z = basp::header::from_bytes(make_span(buf));
CAF_CHECK_EQUAL(x, z);
CAF_CHECK_EQUAL(y, z);
}
......
......@@ -72,7 +72,7 @@ public:
bool handle_write_event() override {
if (wr_buf_.size() == 0)
return false;
auto res = write(handle(), as_bytes(make_span(wr_buf_)));
auto res = write(handle(), make_span(wr_buf_));
if (auto num_bytes = get_if<size_t>(&res)) {
CAF_ASSERT(*num_bytes > 0);
wr_buf_.erase(wr_buf_.begin(), wr_buf_.begin() + *num_bytes);
......
......@@ -117,7 +117,7 @@ CAF_TEST(deliver serialized message) {
static_cast<uint32_t>(payload.size()),
make_message_id().integer_value()};
CAF_MESSAGE("launch worker");
w->launch(last_hop, hdr, as_bytes(make_span(payload)));
w->launch(last_hop, hdr, make_span(payload));
sched.run_once();
expect((ok_atom), from(_).to(testee));
}
......
......@@ -41,8 +41,7 @@ CAF_TEST(send and receive) {
pipe_socket rd_sock;
pipe_socket wr_sock;
std::tie(rd_sock, wr_sock) = unbox(make_pipe());
CAF_CHECK_EQUAL(write(wr_sock, as_bytes(make_span(send_buf))),
send_buf.size());
CAF_CHECK_EQUAL(write(wr_sock, make_span(send_buf)), send_buf.size());
CAF_CHECK_EQUAL(read(rd_sock, make_span(receive_buf)), send_buf.size());
CAF_CHECK(std::equal(send_buf.begin(), send_buf.end(), receive_buf.begin()));
}
......
......@@ -90,7 +90,7 @@ struct fixture : host_fixture, test_coordinator_fixture<config> {
template <class... Ts>
void mock(const Ts&... xs) {
auto buf = to_buf(xs...);
if (fetch_size(write(sock, as_bytes(make_span(buf)))) != buf.size())
if (fetch_size(write(sock, make_span(buf))) != buf.size())
CAF_FAIL("unable to write " << buf.size() << " bytes");
run();
}
......@@ -103,7 +103,7 @@ struct fixture : host_fixture, test_coordinator_fixture<config> {
static_cast<uint32_t>(payload.size()), basp::version});
CAF_CHECK_EQUAL(app->state(),
basp::connection_state::await_handshake_payload);
write(sock, as_bytes(make_span(payload)));
write(sock, make_span(payload));
run();
}
......@@ -111,7 +111,7 @@ struct fixture : host_fixture, test_coordinator_fixture<config> {
buffer_type buf(basp::header_size);
if (fetch_size(read(sock, make_span(buf))) != basp::header_size)
CAF_FAIL("unable to read " << basp::header_size << " bytes");
auto hdr = basp::header::from_bytes(as_bytes(make_span(buf)));
auto hdr = basp::header::from_bytes(make_span(buf));
if (hdr.type != basp::message_type::handshake || hdr.payload_len == 0
|| hdr.operation_data != basp::version)
CAF_FAIL("invalid handshake header");
......@@ -149,7 +149,7 @@ struct fixture : host_fixture, test_coordinator_fixture<config> {
std::tuple<unit_t>>::value) { \
auto payload = to_buf(__VA_ARGS__); \
mock(basp::header{kind, static_cast<uint32_t>(payload.size()), op}); \
write(sock, as_bytes(make_span(payload))); \
write(sock, make_span(payload)); \
} else { \
mock(basp::header{kind, 0, op}); \
} \
......@@ -162,7 +162,7 @@ struct fixture : host_fixture, test_coordinator_fixture<config> {
buffer_type buf(basp::header_size); \
if (fetch_size(read(sock, make_span(buf))) != basp::header_size) \
CAF_FAIL("unable to read " << basp::header_size << " bytes"); \
auto hdr = basp::header::from_bytes(as_bytes(make_span(buf))); \
auto hdr = basp::header::from_bytes(make_span(buf)); \
CAF_CHECK_EQUAL(hdr.type, msg_type); \
CAF_CHECK_EQUAL(hdr.operation_data, op_data); \
if (!std::is_same<decltype(std::make_tuple(__VA_ARGS__)), \
......
......@@ -83,7 +83,7 @@ CAF_TEST(read on empty sockets) {
CAF_TEST(transfer data from first to second socket) {
std::vector<byte> wr_buf{1_b, 2_b, 4_b, 8_b, 16_b, 32_b, 64_b};
CAF_MESSAGE("transfer data from first to second socket");
CAF_CHECK_EQUAL(write(first, as_bytes(make_span(wr_buf))), wr_buf.size());
CAF_CHECK_EQUAL(write(first, make_span(wr_buf)), wr_buf.size());
CAF_CHECK_EQUAL(read(second, make_span(rd_buf)), wr_buf.size());
CAF_CHECK(std::equal(wr_buf.begin(), wr_buf.end(), rd_buf.begin()));
rd_buf.assign(rd_buf.size(), byte(0));
......@@ -91,7 +91,7 @@ CAF_TEST(transfer data from first to second socket) {
CAF_TEST(transfer data from second to first socket) {
std::vector<byte> wr_buf{1_b, 2_b, 4_b, 8_b, 16_b, 32_b, 64_b};
CAF_CHECK_EQUAL(write(second, as_bytes(make_span(wr_buf))), wr_buf.size());
CAF_CHECK_EQUAL(write(second, make_span(wr_buf)), wr_buf.size());
CAF_CHECK_EQUAL(read(first, make_span(rd_buf)), wr_buf.size());
CAF_CHECK(std::equal(wr_buf.begin(), wr_buf.end(), rd_buf.begin()));
}
......@@ -108,8 +108,7 @@ CAF_TEST(transfer data using multiple buffers) {
std::vector<byte> full_buf;
full_buf.insert(full_buf.end(), wr_buf_1.begin(), wr_buf_1.end());
full_buf.insert(full_buf.end(), wr_buf_2.begin(), wr_buf_2.end());
CAF_CHECK_EQUAL(write(second, {as_bytes(make_span(wr_buf_1)),
as_bytes(make_span(wr_buf_2))}),
CAF_CHECK_EQUAL(write(second, {make_span(wr_buf_1), make_span(wr_buf_2)}),
full_buf.size());
CAF_CHECK_EQUAL(read(first, make_span(rd_buf)), full_buf.size());
CAF_CHECK(std::equal(full_buf.begin(), full_buf.end(), rd_buf.begin()));
......
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