Skip to content

Commit

Permalink
resolve conflicts
Browse files Browse the repository at this point in the history
  • Loading branch information
jstarry committed Jan 21, 2022
1 parent 3bae2bf commit a2feee0
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 15 deletions.
7 changes: 3 additions & 4 deletions perf/benches/dedup.rs
Expand Up @@ -30,10 +30,9 @@ fn do_bench_dedup_packets(bencher: &mut Bencher, mut batches: Vec<PacketBatch>)
// reset
bloom.clear_for_tests();
batches.iter_mut().for_each(|batch| {
batch
.packets
.iter_mut()
.for_each(|p| p.meta.set_discard(false))
batch.packets.iter_mut().for_each(|p| {
p.meta.discard = false;
})
});
})
}
Expand Down
13 changes: 2 additions & 11 deletions perf/src/sigverify.rs
Expand Up @@ -396,20 +396,11 @@ fn dedup_packet(count: &AtomicU64, packet: &mut Packet, bloom: &AtomicBloom<&[u8
return;
}

<<<<<<< HEAD
if bloom.contains(&&packet.data[..]) {
packet.meta.discard = true;
=======
// If this packet was not newly added, it's a dup and should be discarded
if !bloom.add(&&packet.data.as_slice()[0..packet.meta.size]) {
packet.meta.set_discard(true);
>>>>>>> a2d251ce1 (Speed up packet dedup and fix benches (#22592))
if !bloom.add(&&packet.data[0..packet.meta.size]) {
packet.meta.discard = true;
count.fetch_add(1, Ordering::Relaxed);
}
<<<<<<< HEAD
bloom.add(&&packet.data[..]);
=======
>>>>>>> a2d251ce1 (Speed up packet dedup and fix benches (#22592))
}

pub fn dedup_packets(bloom: &AtomicBloom<&[u8]>, batches: &mut [PacketBatch]) -> u64 {
Expand Down

0 comments on commit a2feee0

Please sign in to comment.