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

[FIX] use write lock to reset calc_upper_trans_version_cache_ instead of read lock

Browse Source
This commit is contained in:
ZenoWang
2024-01-22 07:21:50 +00:00
committed by ob-robot
parent 3de97b1dd1
commit 2f1d042c88
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/storage/tx_table/ob_tx_data_table.cpp
View File

@ -1318,7 +1318,7 @@ void ObTxDataTable::disable_upper_trans_calculation()
{ {
ATOMIC_STORE(&calc_upper_trans_is_disabled_, true); ATOMIC_STORE(&calc_upper_trans_is_disabled_, true);
{ {
TCRLockGuard lock_guard(calc_upper_trans_version_cache_.lock_); TCWLockGuard lock_guard(calc_upper_trans_version_cache_.lock_);
calc_upper_trans_version_cache_.reset(); calc_upper_trans_version_cache_.reset();
} }
{ {
@ -1330,7 +1330,7 @@ void ObTxDataTable::disable_upper_trans_calculation()
void ObTxDataTable::enable_upper_trans_calculation(const share::SCN latest_transfer_scn) void ObTxDataTable::enable_upper_trans_calculation(const share::SCN latest_transfer_scn)
{ {
{ {
TCRLockGuard lock_guard(calc_upper_trans_version_cache_.lock_); TCWLockGuard lock_guard(calc_upper_trans_version_cache_.lock_);
calc_upper_trans_version_cache_.reset(); calc_upper_trans_version_cache_.reset();
} }
if (latest_transfer_scn_.is_valid()) { if (latest_transfer_scn_.is_valid()) {