Forwarder: clean up packet_vec filter (#30921)
This commit is contained in:
parent
932301583c
commit
b72be0f086
|
@ -165,13 +165,9 @@ impl Forwarder {
|
|||
self.update_data_budget();
|
||||
|
||||
let packet_vec: Vec<_> = forwardable_packets
|
||||
.filter_map(|p| {
|
||||
if !p.meta().forwarded() && self.data_budget.take(p.meta().size) {
|
||||
Some(p.data(..)?.to_vec())
|
||||
} else {
|
||||
None
|
||||
}
|
||||
})
|
||||
.filter(|p| !p.meta().forwarded())
|
||||
.filter(|p| self.data_budget.take(p.meta().size))
|
||||
.filter_map(|p| p.data(..).map(|data| data.to_vec()))
|
||||
.collect();
|
||||
|
||||
let packet_vec_len = packet_vec.len();
|
||||
|
|
Loading…
Reference in New Issue