Fix rust fmt (#11537)
This commit is contained in:
parent
713851b68d
commit
2910fd467f
@ -394,21 +394,17 @@ impl CrdsGossipPull {
|
|||||||
}
|
}
|
||||||
let mut total_skipped = 0;
|
let mut total_skipped = 0;
|
||||||
for v in crds.table.values() {
|
for v in crds.table.values() {
|
||||||
recent
|
recent.iter().enumerate().for_each(|(i, (caller, filter))| {
|
||||||
.iter()
|
//skip values that are too new
|
||||||
.enumerate()
|
if v.value.wallclock() > caller.wallclock().checked_add(jitter).unwrap_or_else(|| 0)
|
||||||
.for_each(|(i, (caller, filter))| {
|
{
|
||||||
//skip values that are too new
|
total_skipped += 1;
|
||||||
if v.value.wallclock()
|
return;
|
||||||
> caller.wallclock().checked_add(jitter).unwrap_or_else(|| 0)
|
}
|
||||||
{
|
if !filter.contains(&v.value_hash) {
|
||||||
total_skipped += 1;
|
ret[i].push(v.value.clone());
|
||||||
return;
|
}
|
||||||
}
|
});
|
||||||
if !filter.contains(&v.value_hash) {
|
|
||||||
ret[i].push(v.value.clone());
|
|
||||||
}
|
|
||||||
});
|
|
||||||
}
|
}
|
||||||
inc_new_counter_info!("gossip_filter_crds_values-dropped_values", total_skipped);
|
inc_new_counter_info!("gossip_filter_crds_values-dropped_values", total_skipped);
|
||||||
ret
|
ret
|
||||||
|
Loading…
x
Reference in New Issue
Block a user