Struct de_net::connection::book::ConnectionBook

pub(super) struct ConnectionBook<T: Connection> {
    next_index: usize,
    addrs: Vec<SocketAddr>,
    records: AHashMap<SocketAddr, ConnectionRecord<T>>,
}

Bookkeeping of per connection data.

It behaves like a connection storage and a custom cyclic connection “iterator”.

Fields

next_index: usize

addrs: Vec<SocketAddr>

records: AHashMap<SocketAddr, ConnectionRecord<T>>

Implementations

impl<T: Connection> ConnectionBook<T>

pub(super) fn new() -> Self

pub(super) fn update<E>( &mut self, time: Instant, addr: SocketAddr, value: E ) -> &mut T

where E: Fn() -> T,

Ensures that a connection record exists and its last update time is time. Mutable reference to the connection value object is returned.

pub(super) fn clean(&mut self, time: Instant)

Forget all connections which:

• has not been actively used for longer than MAX_CONN_AGE,
• have no pending activity.

pub(super) fn next(&mut self) -> Option<(SocketAddr, &mut T)>

Yields an element (one by one) from the book. Once all elements are yielded, None is returned and the “iterator” is restarted.

fn next_inner(&mut self) -> Option<(SocketAddr, &mut ConnectionRecord<T>)>

pub(super) fn remove_current(&mut self)

Remove last yielded item by Self::next from the book.

Panics

• Panics if Self::next yielded None when last called.

• May panic if it called repeatedly between individual calls to Self::next.