update archive piece context whenever iterate log
This commit is contained in:
@ -251,6 +251,7 @@ int ObRemoteLogIterator<LogEntryType>::next_entry_(LogEntryType &entry, LSN &lsn
|
|||||||
} else {
|
} else {
|
||||||
cur_lsn_ = lsn + entry.get_serialize_size();
|
cur_lsn_ = lsn + entry.get_serialize_size();
|
||||||
cur_scn_ = entry.get_scn();
|
cur_scn_ = entry.get_scn();
|
||||||
|
advance_data_gen_lsn_();
|
||||||
if (lsn < start_lsn_) {
|
if (lsn < start_lsn_) {
|
||||||
// do nothing
|
// do nothing
|
||||||
} else {
|
} else {
|
||||||
@ -279,10 +280,6 @@ int ObRemoteLogIterator<LogEntryType>::next_entry_(LogEntryType &entry, LSN &lsn
|
|||||||
if (OB_FAIL(ret) && OB_ITER_END != ret && ! is_io_error(ret)) {
|
if (OB_FAIL(ret) && OB_ITER_END != ret && ! is_io_error(ret)) {
|
||||||
mark_source_error_(ret);
|
mark_source_error_(ret);
|
||||||
}
|
}
|
||||||
|
|
||||||
if (OB_SUCC(ret)) {
|
|
||||||
advance_data_gen_lsn_();
|
|
||||||
}
|
|
||||||
return ret;
|
return ret;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Reference in New Issue
Block a user