Commit d8d6dd49 authored by Jakob Otto's avatar Jakob Otto

Move to CAF_ASSERT()

parent 868cfc3b
......@@ -265,10 +265,7 @@ private:
return false;
do {
auto& buf = write_queue_.front().second;
if (buf.empty()) {
recycle();
continue;
}
CAF_ASSERT(!buf.empty());
auto data = buf.data() + written_;
auto len = buf.size() - written_;
auto write_ret = write(handle_, make_span(data, len));
......
......@@ -74,8 +74,7 @@ public:
template <class Parent>
void write_message(Parent& parent,
std::unique_ptr<endpoint_manager_queue::message> ptr) {
auto header_buf = parent.next_header_buffer();
parent.write_packet(header_buf, ptr->payload);
parent.write_packet(ptr->payload);
}
template <class Parent>
......
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