{
ceph_assert_always(seastar::this_shard_id() == get_shard_id());
auto prv_state = get_io_state();
- logger().debug("{} got {}do_set_io_state(): prv_state={}, new_state={}, "
+ logger().debug("{} got {} do_set_io_state(): prv_state={}, new_state={}, "
"fa={}, set_notify_out={}, at {}",
conn,
cc_seq.has_value() ? fmt::format("{} ", *cc_seq) : "",
});
});
}
- if (shard_states->try_enter_out_dispatching()) {
+ if (shard_states->try_enter_out_dispatching(conn)) {
shard_states->dispatch_in_background(
"do_out_dispatch", conn, [this] {
return do_out_dispatch(*shard_states);
in_exit_dispatching = std::nullopt;
}
- bool try_enter_out_dispatching() {
+ bool try_enter_out_dispatching(SocketConnection &conn) {
assert(seastar::this_shard_id() == sid);
if (out_dispatching) {
// already dispatching out
// do not dispatch out
return false;
default:
+ crimson::get_logger(ceph_subsys_ms).error(
+ "{} try_enter_out_dispatching() got wrong io_state {}",
+ conn, io_state);
ceph_abort("impossible");
}
}
case switched:
name = "switched";
break;
+ default:
+ name = "undefined";
}
return formatter<string_view>::format(name, ctx);
}