Commit a53224c4 authored by Dominik Charousset's avatar Dominik Charousset

Fix formatting

parent 577d3996
...@@ -116,8 +116,8 @@ public: ...@@ -116,8 +116,8 @@ public:
if (handshake_complete_) if (handshake_complete_)
return upper_layer_.consume(down, buffer, delta); return upper_layer_.consume(down, buffer, delta);
// TODO: we could avoid repeated scans by using the delta parameter. // TODO: we could avoid repeated scans by using the delta parameter.
auto i = std::search(buffer.begin(), buffer.end(), auto i = std::search(buffer.begin(), buffer.end(), end_of_header.begin(),
end_of_header.begin(), end_of_header.end()); end_of_header.end());
if (i == buffer.end()) { if (i == buffer.end()) {
if (buffer.size() == max_header_size) { if (buffer.size() == max_header_size) {
write(down, header_too_large); write(down, header_too_large);
......
...@@ -120,7 +120,7 @@ CAF_TEST(read / write using span<byte>) { ...@@ -120,7 +120,7 @@ CAF_TEST(read / write using span<byte>) {
if (CAF_CHECK(holds_alternative<sec>(read_res))) if (CAF_CHECK(holds_alternative<sec>(read_res)))
CAF_CHECK(get<sec>(read_res) == sec::unavailable_or_would_block); CAF_CHECK(get<sec>(read_res) == sec::unavailable_or_would_block);
CAF_MESSAGE("sending data to " << to_string(ep)); CAF_MESSAGE("sending data to " << to_string(ep));
auto write_res=write(send_socket, as_bytes(make_span(hello_test)), ep); auto write_res = write(send_socket, as_bytes(make_span(hello_test)), ep);
if (CAF_CHECK(holds_alternative<size_t>(write_res))) if (CAF_CHECK(holds_alternative<size_t>(write_res)))
CAF_CHECK_EQUAL(get<size_t>(write_res), hello_test.size()); CAF_CHECK_EQUAL(get<size_t>(write_res), hello_test.size());
CAF_CHECK_EQUAL(read_from_socket(receive_socket, buf), none); CAF_CHECK_EQUAL(read_from_socket(receive_socket, buf), none);
......
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