Struct IpDefragPool 

pub struct IpDefragPool<Timestamp = (), CustomChannelId = ()>
where
    Timestamp: Sized + Debug + Clone,
    CustomChannelId: Sized + Debug + Clone + Hash + Eq + PartialEq,
{ /* private fields */ }

Available on crate feature std only.

Pool of buffers to reconstruct multiple fragmented IP packets in parallel (re-uses buffers to minimize allocations).

It differentiates the packets based on their inner & outer vlan as well as source and destination ip address and allows the user to add their own custom “channel id” type to further differentiate different streams. The custom channel id can be used to

This implementation is NOT safe against “Out of Memory” attacks

If you use the IpDefragPool in an untrusted environment an attacker could cause an “out of memory error” by opening up multiple parallel TP streams, never ending them and filling them up with as much data as possible.

Mitigations will hopefully be offered in future versions but if you have take care right now you can still use IpDefragBuf directly and implement the connection handling and mitigation yourself.

Implementations

impl<Timestamp, CustomChannelId> IpDefragPool<Timestamp, CustomChannelId>

where Timestamp: Sized + Debug + Clone, CustomChannelId: Sized + Debug + Clone + Hash + Eq + PartialEq,

pub fn new() -> IpDefragPool<Timestamp, CustomChannelId>

pub fn process_sliced_packet( &mut self, slice: &SlicedPacket<'_>, timestamp: Timestamp, channel_id: CustomChannelId, ) -> Result<Option<IpDefragPayloadVec>, IpDefragError>

Add data from a sliced packet.

pub fn return_buf(&mut self, buf: IpDefragPayloadVec)

Returns a buffer to the pool so it can be re-used.

pub fn retain<F>(&mut self, f: F)

where F: Fn(&Timestamp) -> bool,

Retains only the elements specified by the predicate.

Trait Implementations

impl<Timestamp, CustomChannelId> Clone for IpDefragPool<Timestamp, CustomChannelId>

where Timestamp: Sized + Debug + Clone + Clone, CustomChannelId: Sized + Debug + Clone + Hash + Eq + PartialEq + Clone,

fn clone(&self) -> IpDefragPool<Timestamp, CustomChannelId>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<Timestamp, CustomChannelId> Debug for IpDefragPool<Timestamp, CustomChannelId>

where Timestamp: Sized + Debug + Clone + Debug, CustomChannelId: Sized + Debug + Clone + Hash + Eq + PartialEq + Debug,

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<Timestamp, CustomChannelId> Default for IpDefragPool<Timestamp, CustomChannelId>

where Timestamp: Sized + Debug + Clone, CustomChannelId: Sized + Debug + Clone + Hash + Eq + PartialEq,

fn default() -> Self

Returns the “default value” for a type.