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

Fix restore case

Browse Source
This commit is contained in:
obdev
2024-06-17 15:06:53 +00:00
committed by ob-robot
parent 54d6db1801
commit afce251ee6
1 changed files with 10 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
src/logservice/restoreservice/ob_remote_fetch_log_worker.cpp
View File

@ -280,6 +280,16 @@ int ObRemoteFetchWorker::handle_single_task_()
if (is_fatal_error_(ret) && need_fetch_log_(task->id_)) { if (is_fatal_error_(ret) && need_fetch_log_(task->id_)) {
report_error_(id, ret, cur_lsn, ObLogRestoreErrorContext::ErrorType::FETCH_LOG); report_error_(id, ret, cur_lsn, ObLogRestoreErrorContext::ErrorType::FETCH_LOG);
} }
//errsim: inject restore failed error
#ifdef ERRSIM
if (OB_SUCC(ret)) {
ret = OB_E(EventTable::EN_RESTORE_LOG_FAILED) OB_SUCCESS;
if (OB_FAIL(ret) && is_fatal_error_(ret)) {
report_error_(id, ret, cur_lsn, ObLogRestoreErrorContext::ErrorType::FETCH_LOG);
LOG_WARN("inject restore failed error", K(ret));
}
}
#endif
} }
return ret; return ret;
} }
@ -329,12 +339,6 @@ int ObRemoteFetchWorker::handle_fetch_log_task_(ObFetchLogTask *task)
LOG_WARN("retire task failed", K(tmp_ret), KP(task)); LOG_WARN("retire task failed", K(tmp_ret), KP(task));
} }
} }
#ifdef ERRSIM
if (OB_SUCC(ret)) {
ret = OB_E(EventTable::EN_RESTORE_LOG_FAILED) OB_SUCCESS;
}
#endif
return ret; return ret;
} }