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

fix ref leak

Browse Source
This commit is contained in:
obdev 2024-11-26 03:15:27 +00:00 committed by ob-robot
parent 7f042e8253
commit 0c3e8eaa9b
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/share/io/io_schedule/ob_io_schedule_v2.cpp
View File

@ -333,8 +333,11 @@ int ObTenantIOSchedulerV2::schedule_request(ObIORequest &req)
} else if (FALSE_IT(req.io_result_->time_log_.enqueue_ts_ = ObTimeUtility::fast_current_time())) {
} else if (0 != qsched_submit(root, &req.qsched_req_, assign_chan_id())) {
ret = OB_ERR_UNEXPECTED;
req.dec_ref("phyqueue_dec"); //ref for phy_queue
LOG_WARN("qsched_submit fail", K(ret), K(req));
}
if (OB_FAIL(ret)) {
req.dec_ref("phyqueue_dec"); //ref for phy_queue
io_req_finish(req, ObIORetCode(ret));
}
return ret;