netstack3_base::socket

Struct BoundSocketMap

Source 
pub struct BoundSocketMap<I: Ip, D: DeviceIdentifier, A: SocketMapAddrSpec, S: SocketMapStateSpec> { /* private fields */ }
Expand description

A map from socket addresses to sockets.

The types of keys and IDs is determined by the SocketMapStateSpec parameter. Each listener and connected socket stores additional state. Listener and connected sockets are keyed independently, but share the same address vector space. Conflicts are detected on attempted insertion of new sockets.

Listener addresses map to listener-address-specific state, and likewise with connected addresses. Depending on protocol (determined by the SocketMapStateSpec protocol), these address states can hold one or more socket identifiers (e.g. UDP sockets with SO_REUSEPORT set can share an address).

Implementations§

Source§

impl<I: Ip, D: DeviceIdentifier, A: SocketMapAddrSpec, S: SocketMapStateSpec> BoundSocketMap<I, D, A, S>

Source

pub fn len(&self) -> usize

Returns the number of entries in the map.

Source§

impl<I: Ip, D: DeviceIdentifier, A: SocketMapAddrSpec, S> BoundSocketMap<I, D, A, S>
where AddrVec<I, D, A>: IterShadows, S: SocketMapStateSpec,

Source

pub fn listeners( &self, ) -> Sockets<&SocketMap<AddrVec<I, D, A>, Bound<S>>, Listener>
where S: SocketMapConflictPolicy<ListenerAddr<ListenerIpAddr<I::Addr, A::LocalIdentifier>, D>, <S as SocketMapStateSpec>::ListenerSharingState, I, D, A>, S::ListenerAddrState: SocketMapAddrStateSpec<Id = S::ListenerId, SharingState = S::ListenerSharingState>,

Returns an iterator over the listeners on the socket map.

Source

pub fn listeners_mut( &mut self, ) -> Sockets<&mut SocketMap<AddrVec<I, D, A>, Bound<S>>, Listener>
where S: SocketMapConflictPolicy<ListenerAddr<ListenerIpAddr<I::Addr, A::LocalIdentifier>, D>, <S as SocketMapStateSpec>::ListenerSharingState, I, D, A>, S::ListenerAddrState: SocketMapAddrStateSpec<Id = S::ListenerId, SharingState = S::ListenerSharingState>,

Returns a mutable iterator over the listeners on the socket map.

Source

pub fn conns( &self, ) -> Sockets<&SocketMap<AddrVec<I, D, A>, Bound<S>>, Connection>
where S: SocketMapConflictPolicy<ConnAddr<ConnIpAddr<I::Addr, A::LocalIdentifier, A::RemoteIdentifier>, D>, <S as SocketMapStateSpec>::ConnSharingState, I, D, A>, S::ConnAddrState: SocketMapAddrStateSpec<Id = S::ConnId, SharingState = S::ConnSharingState>,

Returns an iterator over the connections on the socket map.

Source

pub fn conns_mut( &mut self, ) -> Sockets<&mut SocketMap<AddrVec<I, D, A>, Bound<S>>, Connection>
where S: SocketMapConflictPolicy<ConnAddr<ConnIpAddr<I::Addr, A::LocalIdentifier, A::RemoteIdentifier>, D>, <S as SocketMapStateSpec>::ConnSharingState, I, D, A>, S::ConnAddrState: SocketMapAddrStateSpec<Id = S::ConnId, SharingState = S::ConnSharingState>,

Returns a mutable iterator over the connections on the socket map.

Source

pub fn get_shadower_counts(&self, addr: &AddrVec<I, D, A>) -> usize

Gets the number of shadower entries for addr.

Source§

impl<I, D, A, S> BoundSocketMap<I, D, A, S>
where I: BroadcastIpExt<Addr: MulticastAddress>, D: DeviceIdentifier, A: SocketMapAddrSpec, S: SocketMapStateSpec + SocketMapConflictPolicy<ListenerAddr<ListenerIpAddr<I::Addr, A::LocalIdentifier>, D>, <S as SocketMapStateSpec>::ListenerSharingState, I, D, A> + SocketMapConflictPolicy<ConnAddr<ConnIpAddr<I::Addr, A::LocalIdentifier, A::RemoteIdentifier>, D>, <S as SocketMapStateSpec>::ConnSharingState, I, D, A>,

Source

pub fn iter_receivers( &self, (src_ip, src_port): (Option<SocketIpAddr<I::Addr>>, Option<A::RemoteIdentifier>), (dst_ip, dst_port): (SocketIpAddr<I::Addr>, A::LocalIdentifier), device: D, broadcast: Option<I::BroadcastMarker>, ) -> Option<FoundSockets<AddrEntry<'_, I, D, A, S>, impl Iterator<Item = AddrEntry<'_, I, D, A, S>> + '_>>

Finds the socket(s) that should receive an incoming packet.

Uses the provided addresses and receiving device to look up sockets that should receive a matching incoming packet. Returns None if no sockets were found, or the results of the lookup.

Trait Implementations§

Source§

impl<I: Ip, D: DeviceIdentifier, A: SocketMapAddrSpec, S: SocketMapStateSpec> Default for BoundSocketMap<I, D, A, S>

Source§

fn default() -> Self

Returns the “default value” for a type. Read more

Auto Trait Implementations§

§

impl<I, D, A, S> Freeze for BoundSocketMap<I, D, A, S>

§

impl<I, D, A, S> RefUnwindSafe for BoundSocketMap<I, D, A, S>
where <A as SocketMapAddrSpec>::LocalIdentifier: RefUnwindSafe, D: RefUnwindSafe, <S as SocketMapStateSpec>::ListenerAddrState: RefUnwindSafe, <S as SocketMapStateSpec>::ConnAddrState: RefUnwindSafe, <A as SocketMapAddrSpec>::RemoteIdentifier: RefUnwindSafe, <I as Ip>::Addr: RefUnwindSafe, <S as SocketMapStateSpec>::AddrVecTag: RefUnwindSafe,

§

impl<I, D, A, S> Send for BoundSocketMap<I, D, A, S>
where <S as SocketMapStateSpec>::ListenerAddrState: Send, <S as SocketMapStateSpec>::ConnAddrState: Send, <S as SocketMapStateSpec>::AddrVecTag: Send,

§

impl<I, D, A, S> Sync for BoundSocketMap<I, D, A, S>
where <S as SocketMapStateSpec>::ListenerAddrState: Sync, <S as SocketMapStateSpec>::ConnAddrState: Sync, <S as SocketMapStateSpec>::AddrVecTag: Sync,

§

impl<I, D, A, S> Unpin for BoundSocketMap<I, D, A, S>
where <A as SocketMapAddrSpec>::LocalIdentifier: Unpin, D: Unpin, <S as SocketMapStateSpec>::ListenerAddrState: Unpin, <S as SocketMapStateSpec>::ConnAddrState: Unpin, <A as SocketMapAddrSpec>::RemoteIdentifier: Unpin, <I as Ip>::Addr: Unpin, <S as SocketMapStateSpec>::AddrVecTag: Unpin,

§

impl<I, D, A, S> UnwindSafe for BoundSocketMap<I, D, A, S>
where <A as SocketMapAddrSpec>::LocalIdentifier: UnwindSafe, D: UnwindSafe, <S as SocketMapStateSpec>::ListenerAddrState: UnwindSafe, <S as SocketMapStateSpec>::ConnAddrState: UnwindSafe, <A as SocketMapAddrSpec>::RemoteIdentifier: UnwindSafe, <I as Ip>::Addr: UnwindSafe, <S as SocketMapStateSpec>::AddrVecTag: RefUnwindSafe + UnwindSafe,

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<O, BC> BuildableCoreContext<BC> for O
where O: Default,

Source§

type Builder = ()

The builder type that can build this core context.
Source§

fn build(_bindings_ctx: &mut BC, _: ()) -> O

Consumes this builder and returns the context.
§

impl<T, D> Encode<Ambiguous1, D> for T
where D: ResourceDialect,

§

unsafe fn encode( self, _encoder: &mut Encoder<'_, D>, _offset: usize, _depth: Depth, ) -> Result<(), Error>

Encodes the object into the encoder’s buffers. Any handles stored in the object are swapped for Handle::INVALID. Read more
§

impl<T, D> Encode<Ambiguous2, D> for T
where D: ResourceDialect,

§

unsafe fn encode( self, _encoder: &mut Encoder<'_, D>, _offset: usize, _depth: Depth, ) -> Result<(), Error>

Encodes the object into the encoder’s buffers. Any handles stored in the object are swapped for Handle::INVALID. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> IntoEither for T

Source§

fn into_either(self, into_left: bool) -> Either<Self, Self>

Converts self into a Left variant of Either<Self, Self> if into_left is true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

Converts self into a Left variant of Either<Self, Self> if into_left(&self) returns true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
§

impl<T> Pointable for T

§

const ALIGN: usize

The alignment of pointer.
§

type Init = T

The type for initializers.
§

unsafe fn init(init: <T as Pointable>::Init) -> usize

Initializes a with the given initializer. Read more
§

unsafe fn deref<'a>(ptr: usize) -> &'a T

Dereferences the given pointer. Read more
§

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

Mutably dereferences the given pointer. Read more
§

unsafe fn drop(ptr: usize)

Drops the object pointed to by the given pointer. Read more
Source§

impl<CC, BC, Meta> RecvFrameContext<Meta, BC> for CC
where Meta: ReceivableFrameMeta<CC, BC>,

Source§

fn receive_frame<B>(&mut self, bindings_ctx: &mut BC, metadata: Meta, frame: B)
where B: BufferMut + Debug,

Receive a frame. Read more
Source§

impl<CC, BC, Meta> SendFrameContext<BC, Meta> for CC
where Meta: SendableFrameMeta<CC, BC>,

Source§

fn send_frame<S>( &mut self, bindings_ctx: &mut BC, metadata: Meta, frame: S, ) -> Result<(), ErrorAndSerializer<SendFrameErrorReason, S>>
where S: Serializer, <S as Serializer>::Buffer: BufferMut,

Send a frame. Read more
Source§

impl<Id, CC, BC> TimerHandler<BC, Id> for CC
where BC: TimerBindingsTypes, Id: HandleableTimer<CC, BC>,

Source§

fn handle_timer( &mut self, bindings_ctx: &mut BC, dispatch: Id, timer: <BC as TimerBindingsTypes>::UniqueTimerId, )

Handle a timer firing. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
§

impl<L, T> UnlockedAccess<L> for T
where L: UnlockedAccessMarkerFor<T>,

§

type Data = <L as UnlockedAccessMarkerFor<T>>::Data

The type of state being accessed.
§

type Guard<'l> = &'l <L as UnlockedAccessMarkerFor<T>>::Data where T: 'l

A guard providing read access to the data.
§

fn access(&self) -> <T as UnlockedAccess<L>>::Guard<'_>

How to access the state.
§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

§

fn vzip(self) -> V

§

impl<B, A> LockBefore<B> for A
where B: LockAfter<A>,