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

[CP] Fix the locks timeout args for auto-increment broadcast

Browse Source
This commit is contained in:
hezuojiao 2024-12-17 13:45:03 +00:00 committed by ob-robot
parent 3689721d99
commit 11a8b4aee6
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/share/ob_global_autoinc_service.cpp
View File

@ -688,9 +688,10 @@ int ObGlobalAutoIncService::deserialize_autoinc_cache(DESERIAL_PARAMS)
int ObGlobalAutoIncService::wait_all_requests_to_finish()
{
int ret = OB_SUCCESS;
const int64_t abs_timeout_us = ObTimeUtility::current_time() + BROADCAST_OP_TIMEOUT;
for (int64_t i = 0; OB_SUCC(ret) && i < MUTEX_NUM; i++) {
// wait for all working threads to finish
if (OB_FAIL(op_mutex_[i].lock(BROADCAST_OP_TIMEOUT))) {
if (OB_FAIL(op_mutex_[i].lock(abs_timeout_us))) {
LOG_WARN("fail to lock mutex", K(ret), K(i));
} else {
op_mutex_[i].unlock();