throw std::runtime_error(fmt::format(
"The connected connection [{}] {} doesn't"
" match the tracked connection [{}] {}",
- result.index, *result.conn, tracked_index, tracked_conn));
+ result.index, *result.conn, tracked_index, *tracked_conn));
}
if (pending_send == 0 && pending_peer_receive == 0 && pending_receive == 0) {
result.state = conn_state_t::established;
break;
}
default:
- logger().error("{} got unexpected msg from cmd client: {}", *c, m);
+ logger().error("{} got unexpected msg from cmd client: {}", *c, *m);
ceph_abort();
}
return {seastar::now()};
std::optional<seastar::future<>> ms_dispatch(crimson::net::ConnectionRef con,
MessageRef m) {
if (verbose) {
- logger().warn("{}: con = {}", __func__, con);
+ logger().warn("{}: con = {}", __func__, *con);
}
// MSG_COMMAND is used to disorganize regular message flow
if (m->get_type() == MSG_COMMAND) {
decode(pl, p);
if (pl.who == Payload::PING) {
logger().info(" {} conn= {} {}", __func__,
- m->get_connection(), pl);
+ *m->get_connection(), pl);
return reply_message(m, pl);
} else {
ceph_assert(pl.who == Payload::PONG);
}
void ms_handle_accept(crimson::net::ConnectionRef conn) {
- logger().info("{} - Connection:{}", __func__, conn);
+ logger().info("{} - Connection:{}", __func__, *conn);
}
void ms_handle_connect(crimson::net::ConnectionRef conn) {
- logger().info("{} - Connection:{}", __func__, conn);
+ logger().info("{} - Connection:{}", __func__, *conn);
}
void ms_handle_reset(crimson::net::ConnectionRef con, bool is_replace);
sent[pl.seq] = pl.data;
conn_sent[&*con].push_back(pl.seq);
logger().info("{} conn= {} send i= {}",
- __func__, con, pl.seq);
+ __func__, *con, pl.seq);
return con->send(std::move(m));
}