#warning fixme
// we currently do dangerous i/o from a Connection core, different from the Socket core.
container().invoke_on(shard, [sock = std::move(socket), peer_addr, this](auto& msgr) mutable {
- SocketConnectionRef conn = seastar::make_shared<SocketConnection>(msgr, *msgr.dispatcher, false);
+ SocketConnectionRef conn = seastar::make_shared<SocketConnection>(
+ msgr, *msgr.dispatcher, get_myaddr().is_msgr2());
conn->start_accept(std::move(sock), peer_addr);
});
});
if (auto found = lookup_conn(peer_addr); found) {
return seastar::make_foreign(found->shared_from_this());
}
- SocketConnectionRef conn = seastar::make_shared<SocketConnection>(*this, *dispatcher, false);
+ SocketConnectionRef conn = seastar::make_shared<SocketConnection>(
+ *this, *dispatcher, peer_addr.is_msgr2());
conn->start_connect(peer_addr, peer_type);
return seastar::make_foreign(conn->shared_from_this());
}