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

fix: add stop state check in recv_large_request

Browse Source
This commit is contained in:
obdev
2023-02-09 13:59:38 +00:00
committed by ob-robot
parent 122a53be18
commit 2bbf0ee9fe
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@ -1332,7 +1332,10 @@ int ObTenant::recv_large_request(rpc::ObRequest &req)
{ {
int ret = OB_SUCCESS; int ret = OB_SUCCESS;
req.set_enqueue_timestamp(ObTimeUtility::current_time()); req.set_enqueue_timestamp(ObTimeUtility::current_time());
if (0 != req.get_group_id()) { if (ATOMIC_LOAD(&stopped_)) {
ret = OB_IN_STOP_STATE;
LOG_WARN("receive large request but tenant has already stopped", K(ret), K(id_));
} else if (0 != req.get_group_id()) {
req.set_large_retry_flag(true); req.set_large_retry_flag(true);
if (OB_FAIL(recv_request(req))) { if (OB_FAIL(recv_request(req))) {
LOG_WARN("tenant receive large retry request fail", K(ret)); LOG_WARN("tenant receive large retry request fail", K(ret));