Struct TpPool 

pub struct TpPool<ChannelId, Timestamp>
where
    ChannelId: Hash + Eq + PartialEq + Clone + Sized,
    Timestamp: Sized + Debug + Clone,
{ /* private fields */ }

Pool of buffers to reconstruct multiple SOMEIP TP packet streams in parallel (re-uses buffers to minimize allocations).

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

If you use the TpPool 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 TpBuf directly and implement the connection handling and mitigation yourself.

Implementations

impl<ChannelId, Timestamp> TpPool<ChannelId, Timestamp>

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

pub fn new(buf_config: TpBufConfig) -> TpPool<ChannelId, Timestamp>

pub fn with_capacity( buf_config: TpBufConfig, initial_bufs_count: usize, ) -> TpPool<ChannelId, Timestamp>

pub fn reserve(&mut self, additional: usize)

Reserves the given number as buffers.

pub fn active_bufs(&self) -> &HashMap<(ChannelId, u32), (TpBuf, Timestamp)>

pub fn finished_bufs(&self) -> &Vec<TpBuf>

pub fn buf_config(&self) -> &TpBufConfig

pub fn consume<'a: 'c, 'b: 'c, 'c: 'a + 'b>( &'a mut self, id: ChannelId, timestamp: Timestamp, someip_slice: SomeipMsgSlice<'b>, ) -> Result<Option<SomeipMsgSlice<'c>>, TpReassembleError>

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

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

Retains only the elements specified by the predicate.

Trait Implementations

impl<ChannelId, Timestamp> Clone for TpPool<ChannelId, Timestamp>

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

fn clone(&self) -> TpPool<ChannelId, Timestamp>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<ChannelId, Timestamp> Debug for TpPool<ChannelId, Timestamp>

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

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

Formats the value using the given formatter.

impl<ChannelId, Timestamp> PartialEq for TpPool<ChannelId, Timestamp>

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

fn eq(&self, other: &Self) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl<ChannelId, Timestamp> Eq for TpPool<ChannelId, Timestamp>

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