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

flush slowest callback-list'log to make instant log progress

Browse Source
This commit is contained in:
chinaxing
2024-02-09 00:25:15 +00:00
committed by ob-robot
parent 21ed6b014a
commit 3f9ee73ade
1 changed files with 16 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
src/storage/memtable/mvcc/ob_mvcc_trans_ctx.cpp
View File

@ -788,6 +788,7 @@ int ObTransCallbackMgr::get_log_guard(const transaction::ObTxSEQ &write_seq,
int64_t my_epoch = list->get_log_epoch(); int64_t my_epoch = list->get_log_epoch();
int64_t min_epoch = 0; int64_t min_epoch = 0;
int min_epoch_idx =-1; int min_epoch_idx =-1;
bool flush_min_epoch_list = false;
common::ObByteLock *log_lock = NULL; common::ObByteLock *log_lock = NULL;
if (my_epoch == INT64_MAX) { if (my_epoch == INT64_MAX) {
ret = OB_ENTRY_NOT_EXIST; ret = OB_ENTRY_NOT_EXIST;
@ -800,12 +801,27 @@ int ObTransCallbackMgr::get_log_guard(const transaction::ObTxSEQ &write_seq,
TRANS_LOG(WARN, "has smaller epoch unlogged", KPC(this), TRANS_LOG(WARN, "has smaller epoch unlogged", KPC(this),
K(list_idx), K(write_seq), K(my_epoch), K(min_epoch), K(min_epoch_idx), KP(to_log_memtable)); K(list_idx), K(write_seq), K(my_epoch), K(min_epoch), K(min_epoch_idx), KP(to_log_memtable));
} }
// if current list pending size too large, try to submit the min_epoch list
if (OB_UNLIKELY(list->pending_log_too_large(GCONF._private_buffer_size * 10))) {
flush_min_epoch_list = true;
}
} else { } else {
lock_guard.set(log_lock); lock_guard.set(log_lock);
} }
if (OB_FAIL(ret) && log_lock) { if (OB_FAIL(ret) && log_lock) {
log_lock->unlock(); log_lock->unlock();
} }
if (OB_UNLIKELY(flush_min_epoch_list)) {
ObTxCallbackList *min_epoch_list = get_callback_list_(min_epoch_idx, false);
if (OB_ISNULL(log_lock = min_epoch_list->try_lock_log())) {
// lock conflict, acquired by others
} else {
TRANS_LOG(INFO, "decide to flush callback list with min_epoch", KPC(this), K(min_epoch), K(min_epoch_idx));
list_idx = min_epoch_idx;
lock_guard.set(log_lock);
ret = OB_SUCCESS;
}
}
} }
return ret; return ret;
} }