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

interrupt gc retain ctx when use too much time

Browse Source
This commit is contained in:
obdev 2022-11-11 07:37:18 +00:00 committed by wangzelin.wzl
parent ece07a478e
commit 0c0b91bf39
4 changed files with 18 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/storage/tx/ob_tx_loop_worker.cpp
View File

@ -102,9 +102,8 @@ void ObTxLoopWorker::run1()
can_gc_tx = true;
}
//retain ctx gc, interval = 15s
if(common::ObClockGenerator::getClock() - last_retain_ctx_gc_ts_ > TX_RETAIN_CTX_GC_INTERVAL)
{
//retain ctx gc, interval = 5s
if (common::ObClockGenerator::getClock() - last_retain_ctx_gc_ts_ > TX_RETAIN_CTX_GC_INTERVAL) {
TRANS_LOG(INFO, "try gc retain ctx");
last_retain_ctx_gc_ts_ = common::ObClockGenerator::getClock();
can_gc_retain_ctx = true;

2
src/storage/tx/ob_tx_loop_worker.h
View File

@ -39,7 +39,7 @@ public:
const static int64_t LOOP_INTERVAL = 100 * 1000; // 100ms
const static int64_t KEEP_ALIVE_PRINT_INFO_INTERVAL = 5 * 60 * 1000 * 1000; // 5min
const static int64_t TX_GC_INTERVAL = 5 * 1000 * 1000; // 5s
const static int64_t TX_RETAIN_CTX_GC_INTERVAL = 15 * 1000 * 1000; // 15s
const static int64_t TX_RETAIN_CTX_GC_INTERVAL = 5 * 1000 * 1000; // 5s
public:
ObTxLoopWorker() { reset(); }
~ObTxLoopWorker() {}

17
src/storage/tx/ob_tx_retain_ctx_mgr.cpp
View File

@ -200,6 +200,7 @@ int ObTxRetainCtxMgr::push_retain_ctx(ObIRetainCtxCheckFunctor *retain_func)
int ObTxRetainCtxMgr::try_gc_retain_ctx(storage::ObLS *ls)
{
int ret = OB_SUCCESS;
static const int64_t MAX_RUN_US = 500 * 1000;
ObTimeGuard tg(__func__, 1 * 1000 * 1000);
SpinWLockGuard guard(retain_ctx_lock_);
tg.click();
@ -207,7 +208,7 @@ int ObTxRetainCtxMgr::try_gc_retain_ctx(storage::ObLS *ls)
if (OB_ISNULL(ls)) {
ret = OB_INVALID_ARGUMENT;
TRANS_LOG(WARN, "[RetainCtxMgr] invalid argument", K(ret), KPC(ls));
} else if (OB_FAIL(for_each_remove_(&ObTxRetainCtxMgr::try_gc_, ls))) {
} else if (OB_FAIL(for_each_remove_(&ObTxRetainCtxMgr::try_gc_, ls, MAX_RUN_US))) {
TRANS_LOG(WARN, "[RetainCtxMgr] try gc all retain ctx failed", K(ret), KPC(ls));
}
return ret;
@ -221,7 +222,7 @@ int ObTxRetainCtxMgr::force_gc_retain_ctx()
SpinWLockGuard guard(retain_ctx_lock_);
tg.click();
if (OB_FAIL(for_each_remove_(&ObTxRetainCtxMgr::force_gc_, nullptr))) {
if (OB_FAIL(for_each_remove_(&ObTxRetainCtxMgr::force_gc_, nullptr, INT64_MAX))) {
TRANS_LOG(WARN, "[RetainCtxMgr] force gc all retain ctx faild", K(ret));
}
@ -300,10 +301,13 @@ int ObTxRetainCtxMgr::remove_ctx_func_(RetainCtxList::iterator remove_iter)
return ret;
}
int ObTxRetainCtxMgr::for_each_remove_(RetainFuncHandler remove_handler, storage::ObLS *ls)
int ObTxRetainCtxMgr::for_each_remove_(RetainFuncHandler remove_handler, storage::ObLS *ls,
const int64_t max_run_us)
{
int ret = OB_SUCCESS;
int64_t remove_count = 0;
bool need_remove = false;
const int64_t start_ts = ObTimeUtility::current_time();
RetainCtxList::iterator iter = retain_ctx_list_.end();
RetainCtxList::iterator last_remove_iter = retain_ctx_list_.end();
@ -314,6 +318,7 @@ int ObTxRetainCtxMgr::for_each_remove_(RetainFuncHandler remove_handler, storage
TRANS_LOG(WARN, "[RetainCtxMgr] remove from retain_ctx_list_ failed", K(ret), KPC(*last_remove_iter),
KPC(this));
} else {
remove_count++;
last_remove_iter = retain_ctx_list_.end();
}
}
@ -328,6 +333,11 @@ int ObTxRetainCtxMgr::for_each_remove_(RetainFuncHandler remove_handler, storage
} else if (need_remove) {
last_remove_iter = iter;
}
const int64_t use_ts = ObTimeUtility::current_time() - start_ts;
if (use_ts > max_run_us) {
TRANS_LOG(WARN, "remove retain ctx use too much time", K(use_ts), K(remove_count));
break;
}
}
if (OB_FAIL(ret)) {
@ -337,6 +347,7 @@ int ObTxRetainCtxMgr::for_each_remove_(RetainFuncHandler remove_handler, storage
TRANS_LOG(WARN, "[RetainCtxMgr] remove from retain_ctx_list_ failed", K(ret), KPC(*last_remove_iter),
KPC(this));
} else {
remove_count++;
last_remove_iter = retain_ctx_list_.end();
}
}

2
src/storage/tx/ob_tx_retain_ctx_mgr.h
View File

@ -126,7 +126,7 @@ public:
private:
int remove_ctx_func_(RetainCtxList::iterator remove_iter);
int for_each_remove_(RetainFuncHandler remove_handler, storage::ObLS *ls);
int for_each_remove_(RetainFuncHandler remove_handler, storage::ObLS *ls, const int64_t max_run_us);
int try_gc_(ObIRetainCtxCheckFunctor *func_ptr, bool &need_remove, storage::ObLS *ls);
int force_gc_(ObIRetainCtxCheckFunctor *func_ptr, bool &need_remove, storage::ObLS *ls);