assert(0);
}
logger().info("sending {}", *m);
- return conn->send(m).then([this] {
+ return conn->send(std::move(m)).then([this] {
logger().info("waiting");
- return reply.get_shared_future();
- }).then([this] (Ref<MAuthReply> m) {
+ return auth_reply.get_shared_future();
+ }).then([this, life_extender=shared_from_this()] (Ref<MAuthReply> m) {
if (!m) {
ceph_assert(closed);
logger().info("do_auth_single: connection closed");