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

bug fix, ignore error code of server down when clear_autoinc_cache and refresh_sync_value failed

Browse Source
This commit is contained in:
obdev
2023-02-13 03:41:27 +00:00
committed by ob-robot
parent 51a269bf73
commit 16eb893f90
1 changed files with 14 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
src/share/ob_autoincrement_service.cpp
View File

@ -53,6 +53,11 @@ namespace share
#define UINT24_MAX (16777215U) #define UINT24_MAX (16777215U)
#endif #endif
static bool is_rpc_error(int error_code)
{
return (is_timeout_err(error_code) || is_server_down_error(error_code));
}
int CacheNode::combine_cache_node(CacheNode &new_node) int CacheNode::combine_cache_node(CacheNode &new_node)
{ {
int ret = OB_SUCCESS; int ret = OB_SUCCESS;
@ -625,7 +630,7 @@ int ObAutoincrementService::clear_autoinc_cache_all(const uint64_t tenant_id,
.by(tenant_id) .by(tenant_id)
.timeout(sync_timeout) .timeout(sync_timeout)
.clear_autoinc_cache(arg))) { .clear_autoinc_cache(arg))) {
if (is_timeout_err(ret) || is_server_down_error(ret) || autoinc_is_order) { if (is_rpc_error(ret) || autoinc_is_order) {
// ignore time out and clear ordered auto increment cache error, go on // ignore time out and clear ordered auto increment cache error, go on
LOG_WARN("rpc call time out, ignore the error", "server", iter->first, LOG_WARN("rpc call time out, ignore the error", "server", iter->first,
K(tenant_id), K(table_id), K(autoinc_is_order), K(ret)); K(tenant_id), K(table_id), K(autoinc_is_order), K(ret));
@ -1187,7 +1192,7 @@ int ObAutoincrementService::sync_value_to_other_servers(
if (OB_FAIL(srv_proxy_->to(iter->first) if (OB_FAIL(srv_proxy_->to(iter->first)
.timeout(sync_us) .timeout(sync_us)
.refresh_sync_value(arg))) { .refresh_sync_value(arg))) {
if (OB_TIMEOUT == ret) { if (is_rpc_error(ret)) {
LOG_WARN("sync rpc call time out", "server", iter->first, K(sync_us), K(param), K(ret)); LOG_WARN("sync rpc call time out", "server", iter->first, K(sync_us), K(param), K(ret));
if (!THIS_WORKER.is_timeout()) { if (!THIS_WORKER.is_timeout()) {
// reach SYNC_TIMEOUT, go on // reach SYNC_TIMEOUT, go on
@ -1280,10 +1285,15 @@ int ObAutoincrementService::sync_auto_increment_all(const uint64_t tenant_id,
if (OB_FAIL(srv_proxy_->to(iter->first) if (OB_FAIL(srv_proxy_->to(iter->first)
.timeout(sync_timeout) .timeout(sync_timeout)
.refresh_sync_value(arg))) { .refresh_sync_value(arg))) {
if (OB_TIMEOUT == ret) { if (is_rpc_error(ret)) {
// ignore time out, go on // ignore time out, go on
LOG_WARN("rpc call time out", "server", iter->first, K(ret)); LOG_WARN("rpc call time out", "server", iter->first, K(ret));
if (!THIS_WORKER.is_timeout()) {
// reach SYNC_TIMEOUT, go on
// ignore time out
ret = OB_SUCCESS; ret = OB_SUCCESS;
break;
}
} else { } else {
LOG_WARN("failed to send rpc call", K(ret)); LOG_WARN("failed to send rpc call", K(ret));
} }