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

[bugfix] fix request leak when receive request failed

Browse Source
This commit is contained in:
obdev
2024-04-18 04:25:42 +00:00
committed by ob-robot
parent 082e4ee50a
commit 57173123c4
1 changed files with 11 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
src/observer/omt/ob_tenant.cpp
View File

@ -1558,12 +1558,16 @@ int ObTenant::recv_large_request(rpc::ObRequest &req)
{
int ret = OB_SUCCESS;
req.set_enqueue_timestamp(ObTimeUtility::current_time());
if (0 != req.get_group_id()) {
if (has_stopped()) {
ret = OB_TENANT_NOT_IN_SERVER;
LOG_WARN("receive large request but tenant has already stopped", K(ret), "tenant_id", id_);
} else if (0 != req.get_group_id()) {
if (OB_FAIL(recv_group_request(req, req.get_group_id()))) {
LOG_WARN("tenant receive large retry request fail", K(ret));
LOG_WARN("tenant receive large retry request fail", K(ret),
"tenant_id", id_, "group_id", req.get_group_id());
}
} else if (OB_FAIL(recv_group_request(req, OBCG_LQ))){
LOG_ERROR("recv large request failed", K(id_));
LOG_ERROR("recv large request failed", "tenant_id", id_);
} else {
ObTenantStatEstGuard guard(id_);
EVENT_INC(REQUEST_ENQUEUE_COUNT);
@ -1611,11 +1615,13 @@ void ObTenant::handle_retry_req(bool need_clear)
if (nullptr != req) {
if (req->large_retry_flag()) {
if (OB_FAIL(recv_large_request(*req))) {
LOG_ERROR("tenant patrol push req into large_query queue fail", "tenant_id", id_, K(ret));
on_translate_fail(req, ret);
LOG_WARN("tenant patrol push req into large_query queue fail", "tenant_id", id_, K(ret));
}
} else {
if (OB_FAIL(recv_request(*req))) {
LOG_ERROR("tenant patrol push req into common queue fail", "tenant_id", id_, K(ret));
on_translate_fail(req, ret);
LOG_WARN("tenant patrol push req into common queue fail", "tenant_id", id_, K(ret));
}
}
} else {