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

[PALF] adjusts the interval for fetching log notifications

Browse Source
This commit is contained in:
BinChenn 2023-05-11 13:36:32 +00:00 committed by ob-robot
parent 8dc9ed868a
commit 0b0f5a2336
2 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/logservice/palf/log_reconfirm.cpp
View File

@ -422,7 +422,7 @@ bool LogReconfirm::is_majority_catch_up_()
} else if (majority_match_lsn < majority_max_lsn_) {
PALF_LOG_RET(WARN, OB_SUCCESS, "majority_match_lsn is smaller than majority_max_lsn_, need wait", K_(palf_id),
K_(majority_max_lsn), K(majority_match_lsn));
if (palf_reach_time_interval(500 * 1000, last_fetch_log_time_us_)) {
if (palf_reach_time_interval(100 * 1000, last_notify_fetch_time_us_)) {
ObMemberList lagged_list;
if (OB_SUCCESS != (tmp_ret = sw_->get_lagged_member_list(majority_max_lsn_, lagged_list))) {
PALF_LOG_RET(WARN, tmp_ret, "get_lagged_member_list_ failed", K(tmp_ret), K_(palf_id));

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

@ -1887,7 +1887,8 @@ int LogSlidingWindow::try_fetch_log(const FetchTriggerType &fetch_log_type,
}
} else if (false == need_execute_fetch_(fetch_log_type)) {
if (palf_reach_time_interval(5 * 1000 * 1000, fetch_failure_print_time_)) {
PALF_LOG(INFO, "no need execute fetch", K(ret), K_(palf_id), K_(self), K(fetch_log_type));
PALF_LOG(INFO, "no need execute fetch", K(ret), K_(palf_id), K_(self), K(fetch_log_type),
K_(last_fetch_trigger_type), K_(last_fetch_req_time));
}
} else if (FetchTriggerType::MODE_META_BARRIER == fetch_log_type) {
int64_t last_slide_log_id = OB_INVALID_LOG_ID;