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

optimize retained tx ctx gc condition

Browse Source
This commit is contained in:
obdev
2023-02-07 20:20:55 +08:00
committed by ob-robot
parent 8e2037671b
commit b34367a7ab
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@ -271,6 +271,7 @@ void ObTxRetainCtxMgr::try_advance_retain_ctx_gc(share::ObLSID ls_id)
const int64_t CUR_LS_CNT = MTL(ObLSService *)->get_ls_map()->get_ls_count(); const int64_t CUR_LS_CNT = MTL(ObLSService *)->get_ls_map()->get_ls_count();
const int64_t IDLE_GC_INTERVAL = 30 * 60 * 1000 * 1000; // 30 min const int64_t IDLE_GC_INTERVAL = 30 * 60 * 1000 * 1000; // 30 min
const int64_t MIN_RETAIN_CTX_GC_THRESHOLD = 5000;
ObTimeGuard tg(__func__, 1 * 1000 * 1000); ObTimeGuard tg(__func__, 1 * 1000 * 1000);
SpinRLockGuard guard(retain_ctx_lock_); SpinRLockGuard guard(retain_ctx_lock_);
@ -281,7 +282,7 @@ void ObTxRetainCtxMgr::try_advance_retain_ctx_gc(share::ObLSID ls_id)
ObAdvanceLSCkptTask *task = nullptr; ObAdvanceLSCkptTask *task = nullptr;
if (retain_ctx_list_.size() <= 0) { if (retain_ctx_list_.size() <= 0) {
//do nothing //do nothing
} else if (retain_ctx_list_.size() <= MAX_PART_CTX_COUNT / 10 / CUR_LS_CNT } else if (retain_ctx_list_.size() <= std::min(MAX_PART_CTX_COUNT / 10 / CUR_LS_CNT, MIN_RETAIN_CTX_GC_THRESHOLD)
&& (OB_INVALID_TIMESTAMP == last_push_gc_task_ts_ && (OB_INVALID_TIMESTAMP == last_push_gc_task_ts_
|| (OB_INVALID_TIMESTAMP != last_push_gc_task_ts_ || (OB_INVALID_TIMESTAMP != last_push_gc_task_ts_
&& cur_time - last_push_gc_task_ts_ <= IDLE_GC_INTERVAL))) { && cur_time - last_push_gc_task_ts_ <= IDLE_GC_INTERVAL))) {