Method handle

libcaf_io/caf/io/basp/instance.cpp:49–83

}

connection_state instance::handle(scheduler* ctx, new_data_msg& dm, header& hdr,
                                  bool is_payload) {
  auto lg = log::io::trace("dm = {}, is_payload = {}", dm, is_payload);
  // function object providing cleanup code on errors
  auto err = [&](connection_state code) {
    if (auto nid = tbl_.erase_direct(dm.handle))
      callee_.purge_state(nid);
    return code;
  };
  byte_buffer* payload = nullptr;
  if (is_payload) {
    payload = &dm.buf;
    if (payload->size() != hdr.payload_len) {
      log::io::warning("received invalid payload, expected {} bytes, got {}",
                       hdr.payload_len, payload->size());
      return err(malformed_message);
    }
  } else {
    binary_deserializer source{*sys_, dm.buf};
    if (!source.apply(hdr)) {
      log::io::warning("failed to receive header: {}", source.get_error());
      return err(malformed_message);
    }
    if (!valid(hdr)) {
      log::io::warning("received invalid header: hdr = {}", hdr);
      return err(malformed_message);
    }
    if (hdr.payload_len > 0) {
      log::io::debug("await payload before processing further");
      return await_payload;
    }
  }
  log::io::debug("hdr = {}", hdr);
  return handle(ctx, dm.handle, hdr, payload);
}

void instance::handle_heartbeat(scheduler* ctx) {
  auto lg = log::io::trace("");