}
}
-inline seastar::future<> unexpected_tag(const Tag& unexpected,
- ceph::net::SocketConnection& conn,
- const char *where) {
+inline void unexpected_tag(const Tag& unexpected,
+ ceph::net::SocketConnection& conn,
+ const char *where) {
logger().error("{} {} received unexpected tag: {}",
conn, where, static_cast<uint32_t>(unexpected));
- return abort_in_fault();
+ abort_in_fault();
}
} // namespace anonymous
return finish_auth();
});
default: {
- return unexpected_tag(tag, conn, __func__);
+ unexpected_tag(tag, conn, __func__);
+ return seastar::now();
}
}
});
logger().trace("{} got KEEPALIVE_ACK {}",
conn, conn.last_keepalive_ack);
});
- default:
- return unexpected_tag(tag, conn, "execute_ready");
+ default: {
+ unexpected_tag(tag, conn, "execute_ready");
+ return seastar::now();
+ }
}
});
}).handle_exception([this] (std::exception_ptr eptr) {