hcq/oceanbase
hcq/oceanbase
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

fix phy_queue dec ref leak

Browse Source
This commit is contained in:
zhjc1124 2024-10-25 13:46:52 +00:00 committed by ob-robot
parent 07af09e351
commit 0cd99e2ca6
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/share/io/ob_io_define.cpp
View File

@ -2436,7 +2436,7 @@ int ObMClockQueue::pop_phyqueue(ObIORequest *&req, int64_t &deadline_ts)
if (OB_ISNULL(next_req)) {
ret = OB_ERR_UNEXPECTED;
LOG_WARN("get null next_req", KP(next_req));
} else if (OB_FAIL(io_clock->calc_phyqueue_clock(tmp_phy_queue, *next_req))) {
} else if (OB_SUCCESS != io_clock->calc_phyqueue_clock(tmp_phy_queue, *next_req)) {
LOG_WARN("calc phyqueue clock failed", K(ret), KPC(next_req));
} else if (FALSE_IT(time_guard.click("R_calc_clock"))) {
}
@ -2545,8 +2545,8 @@ int ObMClockQueue::pop_with_ready_queue(const int64_t current_ts, ObIORequest *&
LOG_WARN("calc phyqueue clock failed", K(ret));
} else if (OB_UNLIKELY(OB_SUCCESS != tmp_ret)) {
LOG_WARN("adjust reservation clock failed", K(tmp_ret), KPC(next_req));
}
}
}
}
}
}
int tmp_ret = push_phyqueue(tmp_phy_queue);