Add counters for gossip verification failures (#2094)

This commit is contained in:
Sagar Dhawan 2018-12-18 09:42:50 +05:30 committed by anatoly yakovenko
parent 29776c0283
commit ffdc1814c6
1 changed files with 16 additions and 2 deletions

View File

@ -880,12 +880,24 @@ impl ClusterInfo {
Self::handle_pull_request(me, filter, caller, from_addr)
}
Protocol::PullResponse(from, mut data) => {
data.retain(|v| v.verify());
data.retain(|v| {
let ret = v.verify();
if !ret {
inc_new_counter_info!("cluster_info-gossip_pull_response_verify_fail", 1);
}
ret
});
Self::handle_pull_response(me, from, data);
vec![]
}
Protocol::PushMessage(from, mut data) => {
data.retain(|v| v.verify());
data.retain(|v| {
let ret = v.verify();
if !ret {
inc_new_counter_info!("cluster_info-gossip_push_msg_verify_fail", 1);
}
ret
});
Self::handle_push_message(me, from, &data)
}
Protocol::PruneMessage(from, data) => {
@ -908,6 +920,8 @@ impl ClusterInfo {
Err(_) => (),
Ok(_) => (),
}
} else {
inc_new_counter_info!("cluster_info-gossip_prune_msg_verify_fail", 1);
}
vec![]
}