]> git-server-git.apps.pok.os.sepia.ceph.com Git - ceph.git/commitdiff
crimson/osd/pg: add pg itself to queue_check_readable debug outputs
authorSamuel Just <sjust@redhat.com>
Tue, 13 Sep 2022 02:14:05 +0000 (19:14 -0700)
committerSamuel Just <sjust@redhat.com>
Tue, 13 Sep 2022 02:14:51 +0000 (19:14 -0700)
Signed-off-by: Samuel Just <sjust@redhat.com>
src/crimson/osd/pg.cc

index 3d9751e5822e5f910cfe6c3e7dce3caf40c1bd22..d23ab6f48bcd5e8f9ff73a0867e7e05506167407 100644 (file)
@@ -192,14 +192,16 @@ void PG::recheck_readable()
   if (peering_state.state_test(PG_STATE_WAIT)) {
     auto prior_readable_until_ub = peering_state.get_prior_readable_until_ub();
     if (mnow < prior_readable_until_ub) {
-      logger().info("{} will wait (mnow {} < prior_readable_until_ub {})",
-                   __func__, mnow, prior_readable_until_ub);
+      logger().info(
+       "{}: {} will wait (mnow {} < prior_readable_until_ub {})",
+       *this, __func__, mnow, prior_readable_until_ub);
       queue_check_readable(
        peering_state.get_last_peering_reset(),
        prior_readable_until_ub - mnow);
     } else {
-      logger().info("{} no longer wait (mnow {} >= prior_readable_until_ub {})",
-                   __func__, mnow, prior_readable_until_ub);
+      logger().info(
+       "{}:{} no longer wait (mnow {} >= prior_readable_until_ub {})",
+       *this, __func__, mnow, prior_readable_until_ub);
       peering_state.state_clear(PG_STATE_WAIT);
       peering_state.clear_prior_readable_until_ub();
       changed = true;
@@ -208,14 +210,17 @@ void PG::recheck_readable()
   if (peering_state.state_test(PG_STATE_LAGGY)) {
     auto readable_until = peering_state.get_readable_until();
     if (readable_until == readable_until.zero()) {
-      logger().info("{} still laggy (mnow {}, readable_until zero)",
-                   __func__, mnow);
+      logger().info(
+       "{}:{} still laggy (mnow {}, readable_until zero)",
+       *this, __func__, mnow);
     } else if (mnow >= readable_until) {
-      logger().info("{} still laggy (mnow {} >= readable_until {})",
-                   __func__, mnow, readable_until);
+      logger().info(
+       "{}:{} still laggy (mnow {} >= readable_until {})",
+       *this, __func__, mnow, readable_until);
     } else {
-      logger().info("{} no longer laggy (mnow {} < readable_until {})",
-                   __func__, mnow, readable_until);
+      logger().info(
+       "{}:{} no longer laggy (mnow {} < readable_until {})",
+       *this, __func__, mnow, readable_until);
       peering_state.state_clear(PG_STATE_LAGGY);
       changed = true;
     }