]> git-server-git.apps.pok.os.sepia.ceph.com Git - ceph.git/commitdiff
crimson/tools/store_nbd: s/socket/server_socket/
authorKefu Chai <kchai@redhat.com>
Thu, 17 Jun 2021 02:53:34 +0000 (10:53 +0800)
committerKefu Chai <kchai@redhat.com>
Fri, 18 Jun 2021 01:05:35 +0000 (09:05 +0800)
to prepare for the next commit, which will keep track of the
connected_socket as another member variable.

Signed-off-by: Kefu Chai <kchai@redhat.com>
src/crimson/tools/store_nbd/store-nbd.cc

index d678112ed33eb012f29b7d48cc1fc55bbb87306c..1d5953d6464e5f9d4dd6dabf23396273da10043f 100644 (file)
@@ -218,7 +218,7 @@ struct RequestWriter {
 class NBDHandler {
   BlockDriver &backend;
   std::string uds_path;
-  std::optional<seastar::server_socket> socket;
+  std::optional<seastar::server_socket> server_socket;
   seastar::gate gate;
 public:
   struct config_t {
@@ -423,13 +423,13 @@ seastar::future<> handle_commands(
 seastar::future<> NBDHandler::run()
 {
   logger().debug("About to listen on {}", uds_path);
-  socket = seastar::engine().listen(
+  server_socket = seastar::engine().listen(
       seastar::socket_address{
       seastar::unix_domain_addr{uds_path}});
 
   return seastar::keep_doing([this] {
     return seastar::try_with_gate(gate, [this] {
-      return socket->accept().then([this](auto acc) {
+      return server_socket->accept().then([this](auto acc) {
         logger().debug("Accepted");
         return seastar::do_with(
           std::move(acc.connection),
@@ -461,9 +461,9 @@ seastar::future<> NBDHandler::run()
 seastar::future<> NBDHandler::stop()
 {
   seastar::future<> done = gate.close();
-  if (socket) {
-    socket->abort_accept();
-    socket.reset();
+  if (server_socket) {
+    server_socket->abort_accept();
+    server_socket.reset();
   }
   return done;
 }