pub struct PendingPathRequests<C>where
C: PendingPathRequestTable,{ /* private fields */ }Implementations§
Source§impl<C> PendingPathRequests<C>where
C: PendingPathRequestTable,
impl<C> PendingPathRequests<C>where
C: PendingPathRequestTable,
Sourcepub fn track(
&mut self,
request: PendingPathRequest,
) -> Option<CulledPathRequest>
pub fn track( &mut self, request: PendingPathRequest, ) -> Option<CulledPathRequest>
A full table evicts its soonest-expiring row, always favoring the newer request; the dropped one still settles, typed, through the returned cull. At capacity zero the new request is itself the cull.
pub fn earliest_timeout_at(&self) -> Option<InstantMillis>
Sourcepub fn contains(&self, destination: &DestinationHash) -> bool
pub fn contains(&self, destination: &DestinationHash) -> bool
Whether RNS 1.4.2 Transport.inbound would exempt destination from announce ingress limiting because a request for it is active.
pub fn pop_settled_for( &mut self, destination: &DestinationHash, ) -> Option<SettledPathRequest>
Sourcepub fn pop_expired(&mut self, now: InstantMillis) -> Option<ExpiredPathRequest>
pub fn pop_expired(&mut self, now: InstantMillis) -> Option<ExpiredPathRequest>
Pop one request whose timeout has passed. Call repeatedly until None to fully drain.
pub fn len(&self) -> usize
pub fn is_empty(&self) -> bool
Trait Implementations§
Source§impl<C> Debug for PendingPathRequests<C>where
C: Debug + PendingPathRequestTable,
impl<C> Debug for PendingPathRequests<C>where
C: Debug + PendingPathRequestTable,
Source§impl<C> Default for PendingPathRequests<C>where
C: Default + PendingPathRequestTable,
impl<C> Default for PendingPathRequests<C>where
C: Default + PendingPathRequestTable,
Source§fn default() -> PendingPathRequests<C>
fn default() -> PendingPathRequests<C>
Returns the “default value” for a type. Read more
Auto Trait Implementations§
impl<C> Freeze for PendingPathRequests<C>where
C: Freeze,
impl<C> RefUnwindSafe for PendingPathRequests<C>where
C: RefUnwindSafe,
impl<C> Send for PendingPathRequests<C>where
C: Send,
impl<C> Sync for PendingPathRequests<C>where
C: Sync,
impl<C> Unpin for PendingPathRequests<C>where
C: Unpin,
impl<C> UnsafeUnpin for PendingPathRequests<C>where
C: UnsafeUnpin,
impl<C> UnwindSafe for PendingPathRequests<C>where
C: UnwindSafe,
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more