ReceiveUpdates spams the log, adjust the threshold higher (#9429)
This commit is contained in:
parent
85feca305b
commit
ae5a6419d4
|
@ -1240,7 +1240,7 @@ impl ClusterInfo {
|
||||||
Protocol::PullRequest(filter, caller) => {
|
Protocol::PullRequest(filter, caller) => {
|
||||||
let start = allocated.get();
|
let start = allocated.get();
|
||||||
if !caller.verify() {
|
if !caller.verify() {
|
||||||
inc_new_counter_error!(
|
inc_new_counter_info!(
|
||||||
"cluster_info-gossip_pull_request_verify_fail",
|
"cluster_info-gossip_pull_request_verify_fail",
|
||||||
1
|
1
|
||||||
);
|
);
|
||||||
|
@ -1266,7 +1266,7 @@ impl ClusterInfo {
|
||||||
data.retain(|v| {
|
data.retain(|v| {
|
||||||
let ret = v.verify();
|
let ret = v.verify();
|
||||||
if !ret {
|
if !ret {
|
||||||
inc_new_counter_error!(
|
inc_new_counter_info!(
|
||||||
"cluster_info-gossip_pull_response_verify_fail",
|
"cluster_info-gossip_pull_response_verify_fail",
|
||||||
1
|
1
|
||||||
);
|
);
|
||||||
|
@ -1284,7 +1284,7 @@ impl ClusterInfo {
|
||||||
data.retain(|v| {
|
data.retain(|v| {
|
||||||
let ret = v.verify();
|
let ret = v.verify();
|
||||||
if !ret {
|
if !ret {
|
||||||
inc_new_counter_error!(
|
inc_new_counter_info!(
|
||||||
"cluster_info-gossip_push_msg_verify_fail",
|
"cluster_info-gossip_push_msg_verify_fail",
|
||||||
1
|
1
|
||||||
);
|
);
|
||||||
|
@ -1864,9 +1864,9 @@ impl Node {
|
||||||
}
|
}
|
||||||
|
|
||||||
fn report_time_spent(label: &str, time: &Duration, extra: &str) {
|
fn report_time_spent(label: &str, time: &Duration, extra: &str) {
|
||||||
let count = duration_as_ms(time);
|
let time_ms = duration_as_ms(time);
|
||||||
if count > 5 {
|
if time_ms > 50 {
|
||||||
info!("{} took: {} ms {}", label, count, extra);
|
info!("{} took: {} ms {}", label, time_ms, extra);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue