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

[CP] [CdcService] Fix the process logic of OB_ITER_END

Browse Source
This commit is contained in:
zxlzxlzxlzxlzxl
2023-11-02 06:43:31 +00:00
committed by ob-robot
parent 3ba461666b
commit 48b91143ed
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/logservice/cdcservice/ob_cdc_fetcher.cpp
View File

@ -635,14 +635,16 @@ int ObCdcFetcher::ls_fetch_log_(const ObLSID &ls_id,
remote_iter.update_source_cb();
}
if (OB_ITER_END == ret) {
// has iterated to the end of block.
ret = OB_SUCCESS;
}
if (OB_SUCCESS == ret) {
// do nothing
if (ls_exist_in_palf && reach_max_lsn) {
handle_when_reach_max_lsn_in_palf_(ls_id, palf_guard, fetched_log_count, frt, resp);
}
} else if (OB_ITER_END == ret) {
// has iterated to the end of block.
ret = OB_SUCCESS;
} else if (OB_ERR_OUT_OF_LOWER_BOUND == ret) {
// log not exists
int tmp_ret = OB_SUCCESS;