RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-03-29 23:09:47 +00:00
Code Issues Packages Projects Releases Wiki Activity

crimson/osd/pg: add pg itself to queue_check_readable debug outputs

Browse Source 
Signed-off-by: Samuel Just <sjust@redhat.com>
This commit is contained in:
Samuel Just 2022-09-12 19:14:05 -07:00
parent d1e9a2cc63
commit 9299d234fc
1 changed files with 15 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
src/crimson/osd/pg.cc
View 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;
}