Method dispatch

libcaf_io/caf/io/basp/instance.cpp:163–203

}

bool instance::dispatch(scheduler* ctx, const strong_actor_ptr& sender,
                        const node_id& dest_node, uint64_t dest_actor,
                        uint8_t flags, message_id mid, const message& msg) {
  auto lg = log::io::trace("sender = {}, dest_node = {}, mid = {}, msg = {}",
                           sender, dest_node, mid, msg);
  CAF_ASSERT(dest_node && this_node_ != dest_node);
  auto path = lookup(dest_node);
  if (!path)
    return false;
  auto& source_node = sender ? sender->node() : this_node_;
  if (dest_node == path->next_hop && source_node == this_node_) {
    header hdr{message_type::direct_message,
               flags,
               0,
               mid.integer_value(),
               sender ? sender->id() : invalid_actor_id,
               dest_actor};
    auto writer = make_callback([&](binary_serializer& sink) { //
      return sink.apply(msg);
    });
    write(*sys_, ctx, callee_.get_buffer(path->hdl), hdr, &writer);
  } else {
    header hdr{message_type::routed_message,
               flags,
               0,
               mid.integer_value(),
               sender ? sender->id() : invalid_actor_id,
               dest_actor};
    auto writer = make_callback([&](binary_serializer& sink) {
      log::io::debug(
        "send routed message: source_node = {} dest_node = {} msg = {}",
        source_node, dest_node, msg);
      return sink.apply(source_node)  //
             && sink.apply(dest_node) //
             && sink.apply(msg);
    });
    write(*sys_, ctx, callee_.get_buffer(path->hdl), hdr, &writer);
  }
  flush(*path);
  return true;
}

void instance::write(actor_system& sys, scheduler*, byte_buffer& buf,
                     header& hdr, payload_writer* pw) {