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

BUGFIX: check server active before send rpc.

Browse Source
This commit is contained in:
obdev
2024-05-09 12:29:58 +00:00
committed by ob-robot
parent 59499d30ba
commit f2109bccb6
1 changed files with 14 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
src/pl/sys_package/ob_dbms_limit_calculator_mysql.cpp
View File

@ -16,6 +16,7 @@
#include "lib/utility/ob_macro_utils.h"
#include "lib/utility/utility.h"
#include "share/inner_table/ob_inner_table_schema_constants.h"
#include "share/ob_all_server_tracer.h"
#include "share/resource_limit_calculator/ob_resource_limit_calculator.h"
#include "share/ob_unit_table_operator.h"
#include "share/ob_all_server_tracer.h"
@ -91,6 +92,7 @@ int ObDBMSLimitCalculator::phy_res_calculate_by_unit(
char* ptr = NULL;
int64_t pos = 0;
int64_t timeout = -1;
bool is_active = false;
const int64_t curr_tenant_id = MTL_ID();
if (!is_sys_tenant(curr_tenant_id)) {
ret = OB_OP_NOT_ALLOW;
@ -103,6 +105,18 @@ int ObDBMSLimitCalculator::phy_res_calculate_by_unit(
} else if (FALSE_IT(addr_str = params.at(1).get_varchar())) {
} else if (OB_FAIL(addr.parse_from_string(addr_str))) {
LOG_WARN("parse address failed", K(ret), K(addr_str));
} else if (OB_FAIL(SVR_TRACER.check_server_alive(addr, is_active))) {
LOG_WARN("check server active failed", K(ret), K(addr));
if (OB_ENTRY_NOT_EXIST == ret) {
is_active = false;
ret = OB_SUCCESS;
}
}
if (OB_FAIL(ret)) {
} else if (!is_active) {
ret = OB_INVALID_ARGUMENT;
LOG_USER_ERROR(OB_INVALID_ARGUMENT, "calculate physical resource needed by unit. "
"The observer is not active or not in cluster.");
} else if (OB_ISNULL(ptr = static_cast<char *>(ctx.get_allocator().alloc(MAX_RES_LEN)))) {
ret = OB_ALLOCATE_MEMORY_FAILED;
LOG_WARN("allocate memory failed", K(ret), K(MAX_RES_LEN));