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

update partition audit info cache in trans_end

Browse Source
This commit is contained in:
kongfy
2021-10-22 17:30:45 +08:00
committed by LINxiansheng
parent 3be156a115
commit 7c7749fb13
1 changed files with 1 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
src/storage/memtable/ob_memtable_context.cpp
View File

@ -795,6 +795,7 @@ int ObMemtableCtx::do_trans_end(const bool commit, const int64_t trans_version,
if (OB_UNLIKELY(ATOMIC_LOAD(&callback_alloc_count_) != ATOMIC_LOAD(&callback_free_count_))) { if (OB_UNLIKELY(ATOMIC_LOAD(&callback_alloc_count_) != ATOMIC_LOAD(&callback_free_count_))) {
TRANS_LOG(ERROR, "callback alloc and free count not match", K(*this)); TRANS_LOG(ERROR, "callback alloc and free count not match", K(*this));
} }
(void)partition_audit_info_cache_.stmt_end_update_audit_info(commit);
// flush partition audit statistics cached in ctx to partition // flush partition audit statistics cached in ctx to partition
if (NULL != ATOMIC_LOAD(&ctx_) && OB_UNLIKELY(OB_SUCCESS != (tmp_ret = flush_audit_partition_cache_(commit)))) { if (NULL != ATOMIC_LOAD(&ctx_) && OB_UNLIKELY(OB_SUCCESS != (tmp_ret = flush_audit_partition_cache_(commit)))) {
TRANS_LOG(WARN, "flush audit partition cache error", K(tmp_ret), K(commit), K(*ctx_)); TRANS_LOG(WARN, "flush audit partition cache error", K(tmp_ret), K(commit), K(*ctx_));