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

[MDS] flush directly advance rec_scn consider about flushing_scn

Browse Source
This commit is contained in:
obdev 2024-02-07 13:36:01 +00:00 committed by ob-robot
parent e5e905fb84
commit b50f5ca438
1 changed files with 9 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/storage/multi_data_source/mds_table_impl.ipp
View File

@ -956,11 +956,15 @@ int MdsTableImpl<MdsTableType>::flush(share::SCN need_advanced_rec_scn_lower_lim
} else if (MDS_FAIL(calculate_flush_scn_and_need_dumped_nodes_cnt_(do_flush_scn, undump_node_cnt))) {
MDS_LOG_FLUSH(WARN, "fail to call calculate_flush_scn_and_need_dumped_nodes_cnt_");
} else if (undump_node_cnt == 0) {// no need do flush actually
// mds_ckpt_scn on tablet won't be advanced,
// replay will cost more time after restart process, but saved cpu and io for dump dag
MDS_LOG_FLUSH(INFO, "no undump nodes below do flush scn, directly advance rec_scn");
flushing_scn_ = do_flush_scn;// will be resetted in on_flush_()
on_flush_(do_flush_scn, OB_SUCCESS);
if (flushing_scn_.is_valid()) {
MDS_LOG_FLUSH(INFO, "there is a merge dag running, can not advance rec_scn here");
} else {
// mds_ckpt_scn on tablet won't be advanced,
// replay will cost more time after restart process, but saved cpu and io for dump dag
MDS_LOG_FLUSH(INFO, "no undump nodes below do flush scn, directly advance rec_scn");
flushing_scn_ = do_flush_scn;// will be resetted in on_flush_()
on_flush_(do_flush_scn, OB_SUCCESS);
}
} else {
#ifndef UNITTEST_DEBUG
if (MDS_FAIL(merge(construct_sequence_, do_flush_scn))) {