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

Fix smaller log case for raw_write.

Browse Source
This commit is contained in:
obdev
2023-03-02 16:31:24 +00:00
committed by ob-robot
parent 1158aabcf8
commit 8b9ca0fa57
1 changed files with 9 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/logservice/palf/log_sliding_window.cpp
View File

@ -3150,9 +3150,18 @@ int LogSlidingWindow::submit_group_log(const LSN &lsn,
LogTaskGuard guard(this); LogTaskGuard guard(this);
int64_t group_log_data_checksum = 0; int64_t group_log_data_checksum = 0;
int64_t pos = 0; int64_t pos = 0;
LSN last_slide_end_lsn;
get_last_slide_end_lsn_(last_slide_end_lsn);
if (OB_FAIL(group_entry_header.deserialize(buf, buf_len, pos))) { if (OB_FAIL(group_entry_header.deserialize(buf, buf_len, pos))) {
PALF_LOG(WARN, "group_entry_header deserialize failed", K(ret), K_(palf_id), K_(self)); PALF_LOG(WARN, "group_entry_header deserialize failed", K(ret), K_(palf_id), K_(self));
} else if (lsn < last_slide_end_lsn && group_entry_header.get_log_id() < get_start_id()) {
// raw_write may submit an old group_log which is smaller than start log of sw,
// just return success for this case.
if (REACH_TIME_INTERVAL(1 * 1000 * 1000)) {
PALF_LOG(INFO, "this group_log has slid out, no need submit", K(ret), K_(palf_id), K_(self),
K(lsn), K(last_slide_end_lsn), K(group_entry_header));
}
} else if (!leader_can_submit_group_log_(lsn, buf_len)) { } else if (!leader_can_submit_group_log_(lsn, buf_len)) {
LSN curr_max_lsn; LSN curr_max_lsn;
(void) lsn_allocator_.get_curr_end_lsn(curr_max_lsn); (void) lsn_allocator_.get_curr_end_lsn(curr_max_lsn);