From: Samuel Just Date: Tue, 13 Sep 2022 02:14:05 +0000 (-0700) Subject: crimson/osd/pg: add pg itself to queue_check_readable debug outputs X-Git-Tag: v18.0.0~3^2~1 X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=9299d234fc68ad156554012c41d058094d06e262;p=ceph.git crimson/osd/pg: add pg itself to queue_check_readable debug outputs Signed-off-by: Samuel Just --- diff --git a/src/crimson/osd/pg.cc b/src/crimson/osd/pg.cc index 3d9751e5822e..d23ab6f48bcd 100644 --- a/src/crimson/osd/pg.cc +++ b/src/crimson/osd/pg.cc @@ -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; }