]> git-server-git.apps.pok.os.sepia.ceph.com Git - ceph.git/commitdiff
crimson/net/io_handler: minor adjustments to logs
authorYingxin Cheng <yingxin.cheng@intel.com>
Thu, 5 Dec 2024 08:52:42 +0000 (16:52 +0800)
committerYingxin Cheng <yingxin.cheng@intel.com>
Fri, 13 Dec 2024 02:59:58 +0000 (10:59 +0800)
Signed-off-by: Yingxin Cheng <yingxin.cheng@intel.com>
src/crimson/net/io_handler.cc
src/crimson/net/io_handler.h

index b93124f3c1269c11f149794489823fe64cf43174..bc5e9bf404c59c254717a774de31e95f907012d4 100644 (file)
@@ -347,7 +347,7 @@ void IOHandler::do_set_io_state(
 {
   ceph_assert_always(seastar::this_shard_id() == get_shard_id());
   auto prv_state = get_io_state();
-  logger().debug("{} got {}do_set_io_state(): prv_state={}, new_state={}, "
+  logger().debug("{} got {} do_set_io_state(): prv_state={}, new_state={}, "
                  "fa={}, set_notify_out={}, at {}",
                  conn,
                  cc_seq.has_value() ? fmt::format("{} ", *cc_seq) : "",
@@ -984,7 +984,7 @@ void IOHandler::notify_out_dispatch()
       });
     });
   }
-  if (shard_states->try_enter_out_dispatching()) {
+  if (shard_states->try_enter_out_dispatching(conn)) {
     shard_states->dispatch_in_background(
         "do_out_dispatch", conn, [this] {
       return do_out_dispatch(*shard_states);
index 5986fcb16ac28ae1368358d67e37068a2c263478..41c76ab925b844071926f3f39c1a20463dbd4d28 100644 (file)
@@ -309,7 +309,7 @@ public:
       in_exit_dispatching = std::nullopt;
     }
 
-    bool try_enter_out_dispatching() {
+    bool try_enter_out_dispatching(SocketConnection &conn) {
       assert(seastar::this_shard_id() == sid);
       if (out_dispatching) {
         // already dispatching out
@@ -327,6 +327,9 @@ public:
         // do not dispatch out
         return false;
       default:
+        crimson::get_logger(ceph_subsys_ms).error(
+          "{} try_enter_out_dispatching() got wrong io_state {}",
+          conn, io_state);
         ceph_abort("impossible");
       }
     }
@@ -574,6 +577,8 @@ struct fmt::formatter<crimson::net::IOHandler::io_state_t>
     case switched:
       name = "switched";
       break;
+    default:
+      name = "undefined";
     }
     return formatter<string_view>::format(name, ctx);
   }