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

[CP] Make START_TRANSFER_IN redo log as STRICT_BARRIER for replay speed limit circular dependency

Browse Source
This commit is contained in:
godyangfight
2024-07-16 10:17:33 +00:00
committed by ob-robot
parent 34d57ab6f1
commit 78e4209eaf
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
mittest/mtlenv/storage/test_transfer_barrier.cpp
View File

@ -98,7 +98,7 @@ TEST_F(TestTransferBarrier, test_transfer_barrier_redo)
//START_TRANSFER_IN //START_TRANSFER_IN
barrier_flag = ObTxLogTypeChecker::need_replay_barrier(log_type, ObTxDataSourceType::START_TRANSFER_IN); barrier_flag = ObTxLogTypeChecker::need_replay_barrier(log_type, ObTxDataSourceType::START_TRANSFER_IN);
ASSERT_EQ(barrier_flag, logservice::ObReplayBarrierType::PRE_BARRIER); ASSERT_EQ(barrier_flag, logservice::ObReplayBarrierType::STRICT_BARRIER);
//STRICT_BARRIER //STRICT_BARRIER
//FINISH_TRANSFER_IN //FINISH_TRANSFER_IN

4
src/storage/tx/ob_tx_log.cpp
View File

@ -41,14 +41,14 @@ ObTxLogTypeChecker::need_replay_barrier(const ObTxLogType log_type,
|| data_source_type == ObTxDataSourceType::START_TRANSFER_OUT || data_source_type == ObTxDataSourceType::START_TRANSFER_OUT
|| data_source_type == ObTxDataSourceType::START_TRANSFER_OUT_PREPARE || data_source_type == ObTxDataSourceType::START_TRANSFER_OUT_PREPARE
|| data_source_type == ObTxDataSourceType::FINISH_TRANSFER_OUT || data_source_type == ObTxDataSourceType::FINISH_TRANSFER_OUT
|| data_source_type == ObTxDataSourceType::START_TRANSFER_IN
|| data_source_type == ObTxDataSourceType::TABLET_BINDING) { || data_source_type == ObTxDataSourceType::TABLET_BINDING) {
barrier_flag = logservice::ObReplayBarrierType::PRE_BARRIER; barrier_flag = logservice::ObReplayBarrierType::PRE_BARRIER;
} else if (data_source_type == ObTxDataSourceType::FINISH_TRANSFER_IN } else if (data_source_type == ObTxDataSourceType::FINISH_TRANSFER_IN
|| data_source_type == ObTxDataSourceType::START_TRANSFER_OUT_V2 || data_source_type == ObTxDataSourceType::START_TRANSFER_OUT_V2
|| data_source_type == ObTxDataSourceType::TRANSFER_MOVE_TX_CTX) { || data_source_type == ObTxDataSourceType::TRANSFER_MOVE_TX_CTX
|| data_source_type == ObTxDataSourceType::START_TRANSFER_IN) {
barrier_flag = logservice::ObReplayBarrierType::STRICT_BARRIER; barrier_flag = logservice::ObReplayBarrierType::STRICT_BARRIER;
} }