Struct FakeBindingsCtx 

pub struct FakeBindingsCtx(/* private fields */);

Test-only implementation of BindingsContext.

Implementations

impl FakeBindingsCtx

pub fn timer_ctx(&self) -> impl Deref<Target = FakeTimerCtx<TimerId<Self>>> + '_

Gets the fake timer context.

pub fn state_mut(&mut self) -> impl DerefMut<Target = FakeBindingsCtxState> + '_

Returns a mutable reference guard to FakeBindingsCtxState.

pub fn copy_ethernet_frames( &mut self, ) -> Vec<(EthernetWeakDeviceId<FakeBindingsCtx>, Vec<u8>)>

Copy all ethernet frames sent so far.

Panics

Panics if the there are non-Ethernet frames stored.

pub fn take_ethernet_frames( &mut self, ) -> Vec<(EthernetWeakDeviceId<FakeBindingsCtx>, Vec<u8>)>

Take all ethernet frames sent so far.

Panics

Panics if the there are non-Ethernet frames stored.

pub fn take_ip_frames( &mut self, ) -> Vec<(PureIpDeviceAndIpVersion<FakeBindingsCtx>, Vec<u8>)>

Take all IP frames sent so far.

Panics

Panics if the there are non-IP frames stored.

pub fn take_events(&mut self) -> Vec<DispatchedEvent>

Takes all the events stored in the fake context.

pub fn take_icmp_replies<I: IpExt>( &mut self, conn: &IcmpSocketId<I, WeakDeviceId<FakeBindingsCtx>, FakeBindingsCtx>, ) -> Vec<Vec<u8>>

Takes all the received ICMP replies for a given conn.

pub fn take_udp_received<I: IpExt>( &mut self, conn: &UdpSocketId<I, WeakDeviceId<FakeBindingsCtx>, FakeBindingsCtx>, ) -> Vec<Vec<u8>>

Takes all received UDP frames from the fake bindings context.

pub fn seed_rng(&self, seed: u128)

Seed the RNG.

Trait Implementations

impl Clone for FakeBindingsCtx

fn clone(&self) -> FakeBindingsCtx

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for FakeBindingsCtx

fn default() -> FakeBindingsCtx

Returns the “default value” for a type.

impl DeferredResourceRemovalContext for FakeBindingsCtx

fn defer_removal<T: Send + 'static>( &mut self, receiver: Self::ReferenceReceiver<T>, )

Defers the removal of some resource T to bindings.

fn defer_removal_result<T>( &mut self, result: RemoveResourceResult<T, Self::ReferenceReceiver<T>>, )

where T: Send + 'static,

A shorthand for [defer_removal] that takes a ReferenceReceiver from the Deferred variant of a RemoveResourceResult.

impl DeviceLayerEventDispatcher for FakeBindingsCtx

type DequeueContext = ()

The transmit queue dequeueing context used by bindings.

fn send_ethernet_frame( &mut self, device: &EthernetDeviceId<FakeBindingsCtx>, frame: Buf<Vec<u8>>, _dequeue_context: Option<&mut Self::DequeueContext>, ) -> Result<(), DeviceSendFrameError>

Send a frame to an Ethernet device driver.

fn send_ip_packet( &mut self, device: &PureIpDeviceId<FakeBindingsCtx>, packet: Buf<Vec<u8>>, ip_version: IpVersion, _dequeue_context: Option<&mut Self::DequeueContext>, ) -> Result<(), DeviceSendFrameError>

Send an IP packet to an IP device driver.

impl DeviceLayerStateTypes for FakeBindingsCtx

type LoopbackDeviceState = ()

The state associated with loopback devices.

type EthernetDeviceState = ()

The state associated with ethernet devices.

type BlackholeDeviceState = ()

The state associated with blackhole devices.

type PureIpDeviceState = ()

The state associated with pure IP devices.

type DeviceIdentifier = MonotonicIdentifier

An opaque identifier that is available from both strong and weak device references.

impl DeviceSocketBindingsContext<DeviceId<FakeBindingsCtx>> for FakeBindingsCtx

fn receive_frame( &self, socket_id: &SocketId<Self>, device: &DeviceId<Self>, _frame: Frame<&[u8]>, raw_frame: &[u8], ) -> Result<(), ReceiveFrameError>

Called for each received frame that matches the provided socket.

impl DeviceSocketTypes for FakeBindingsCtx

type SocketState<D: Send + Sync + Debug> = Mutex<Vec<(WeakDeviceId<FakeBindingsCtx>, Vec<u8>)>>

State for the socket held by core and exposed to bindings.

impl<T: Into<DispatchedEvent>> EventContext<T> for FakeBindingsCtx

fn on_event(&mut self, event: T)

Handles event.

impl<I: IpExt> IcmpEchoBindingsContext<I, DeviceId<FakeBindingsCtx>> for FakeBindingsCtx

fn receive_icmp_echo_reply<B: BufferMut>( &mut self, conn: &IcmpSocketId<I, WeakDeviceId<FakeBindingsCtx>, FakeBindingsCtx>, _device: &DeviceId<Self>, _src_ip: I::Addr, _dst_ip: I::Addr, _id: u16, data: B, ) -> Result<(), ReceiveIcmpEchoError>

Receives an ICMP echo reply.

impl IcmpEchoBindingsTypes for FakeBindingsCtx

type ExternalData<I: Ip> = ()

Opaque bindings data held by core for a given IP version.

type SocketWritableListener = FakeSocketWritableListener

The listener notified when sockets’ writable state changes.

impl InstantBindingsTypes for FakeBindingsCtx

type Instant = FakeInstant

The type of an instant in time.

type AtomicInstant = FakeAtomicInstant

An atomic representation of Self::Instant.

impl InstantContext for FakeBindingsCtx

fn now(&self) -> FakeInstant

Returns the current instant.

fn now_atomic(&self) -> Self::AtomicInstant

Returns the current instant, as an [Self::AtomicInstant].

impl IpRoutingBindingsTypes for FakeBindingsCtx

type RoutingTableId = ()

An opaque type that represents a routing table ID from the Bindings. The Bindings implementation is responsible for providing a unique ID for each routing table.

impl<D: LinkDevice> LinkResolutionContext<D> for FakeBindingsCtx

type Notifier = NoOpLinkResolutionNotifier

A notifier held by core that can be used to inform interested parties of the result of link address resolution.

impl MatcherBindingsTypes for FakeBindingsCtx

type DeviceClass = ()

The device class type for devices installed in the netstack.

type BindingsPacketMatcher = Infallible

The type used to represent a custom filter matcher.

impl<I: IpExt> RawIpSocketsBindingsContext<I, DeviceId<FakeBindingsCtx>> for FakeBindingsCtx

fn receive_packet<B: SplitByteSlice>( &self, _socket: &RawIpSocketId<I, WeakDeviceId<Self>, Self>, _packet: &I::Packet<B>, _device: &DeviceId<Self>, ) -> Result<(), ReceivePacketError>

Called for each received IP packet that matches the provided socket.

impl RawIpSocketsBindingsTypes for FakeBindingsCtx

type RawIpSocketState<I: Ip> = ()

The bindings state (opaque to core) associated with a socket.

impl ReceiveQueueBindingsContext<BaseDeviceId<LoopbackDevice, FakeBindingsCtx>> for FakeBindingsCtx

fn wake_rx_task(&mut self, device: &LoopbackDeviceId<FakeBindingsCtx>)

Signals to bindings that RX frames are available and ready to be handled by device.

impl ReferenceNotifiers for FakeBindingsCtx

type ReferenceReceiver<T: 'static> = Infallible

The receiver for shared reference destruction notifications.

type ReferenceNotifier<T: Send + 'static> = Infallible

The notifier for shared reference destruction notifications.

fn new_reference_notifier<T: Send + 'static>( debug_references: DynDebugReferences, ) -> (Self::ReferenceNotifier<T>, Self::ReferenceReceiver<T>)

Creates a new Notifier/Receiver pair for T.

impl RngContext for FakeBindingsCtx

type Rng<'a> = FakeCryptoRng

The random number generator (RNG) provided by this RngContext.

fn rng(&mut self) -> Self::Rng<'_>

Gets the random number generator (RNG).

impl SocketOpsFilterBindingContext<DeviceId<FakeBindingsCtx>> for FakeBindingsCtx

fn socket_ops_filter(&self) -> impl SocketOpsFilter<DeviceId<FakeBindingsCtx>>

Returns the filter that should be called for socket ops.

impl TcpBindingsTypes for FakeBindingsCtx

type ReceiveBuffer = Arc<Mutex<RingBuffer>>

Receive buffer used by TCP.

type SendBuffer = TestSendBuffer

Send buffer used by TCP.

type ReturnedBuffers = ClientBuffers

The object that will be returned by the state machine when a passive open connection becomes established. The bindings can use this object to read/write bytes from/into the created buffers.

type ListenerNotifierOrProvidedBuffers = ProvidedBuffers

The extra information provided by the Bindings that implements platform dependent behaviors. It serves as a ListenerNotifier if the socket was used as a listener and it will be used to provide buffers if used to establish connections.

fn new_passive_open_buffers( buffer_sizes: BufferSizes, ) -> (Self::ReceiveBuffer, Self::SendBuffer, Self::ReturnedBuffers)

Creates new buffers and returns the object that Bindings need to read/write from/into the created buffers.

impl TimerBindingsTypes for FakeBindingsCtx

type Timer = <FakeTimerCtx<TimerId<FakeBindingsCtx>> as TimerBindingsTypes>::Timer

State for a timer created through TimerContext.

type DispatchId = TimerId<FakeBindingsCtx>

The type used to dispatch fired timers from bindings to core.

type UniqueTimerId = <FakeTimerCtx<TimerId<FakeBindingsCtx>> as TimerBindingsTypes>::UniqueTimerId

A value that uniquely identifiers a Timer. It is given along with the DispatchId whenever a timer is fired.

impl TimerContext for FakeBindingsCtx

fn new_timer(&mut self, id: Self::DispatchId) -> Self::Timer

Creates a new timer that dispatches id back to core when fired.

fn schedule_timer_instant( &mut self, time: Self::Instant, timer: &mut Self::Timer, ) -> Option<Self::Instant>

Schedule a timer to fire at some point in the future. Returns the previously scheduled instant, if this timer was scheduled.

fn cancel_timer(&mut self, timer: &mut Self::Timer) -> Option<Self::Instant>

Cancel a timer.

fn scheduled_instant(&self, timer: &mut Self::Timer) -> Option<Self::Instant>

Get the instant a timer will fire, if one is scheduled.

fn unique_timer_id(&self, timer: &Self::Timer) -> Self::UniqueTimerId

Retrieves the timer id for timer.

fn schedule_timer( &mut self, duration: Duration, timer: &mut Self::Timer, ) -> Option<Self::Instant>

Like [schedule_timer_instant] but schedules a time for duration in the future.

impl<D: Clone + Into<DeviceId<Self>>> TransmitQueueBindingsContext<D> for FakeBindingsCtx

fn wake_tx_task(&mut self, device: &D)

Signals to bindings that TX frames are available and ready to be sent over the device.

impl TxMetadataBindingsTypes for FakeBindingsCtx

type TxMetadata = CoreTxMetadata<FakeBindingsCtx>

The metadata associated with a TX frame.

impl UdpBindingsTypes for FakeBindingsCtx

type ExternalData<I: Ip> = ()

Opaque bindings data held by core for a given IP version.

type SocketWritableListener = FakeSocketWritableListener

The listener notified when sockets’ writable state changes.

impl<I: IpExt> UdpReceiveBindingsContext<I, DeviceId<FakeBindingsCtx>> for FakeBindingsCtx

fn receive_udp( &mut self, id: &UdpSocketId<I, WeakDeviceId<Self>, FakeBindingsCtx>, _device_id: &DeviceId<Self>, _meta: UdpPacketMeta<I>, body: &[u8], ) -> Result<(), ReceiveUdpError>

Receives a UDP packet on a socket.

impl WithFakeFrameContext<DispatchedFrame> for FakeBindingsCtx

fn with_fake_frame_ctx_mut<O, F: FnOnce(&mut FakeFrameCtx<DispatchedFrame>) -> O>( &mut self, f: F, ) -> O

Calls the callback with a mutable reference to the FakeFrameCtx.

impl WithFakeTimerContext<TimerId<FakeBindingsCtx>> for FakeBindingsCtx

fn with_fake_timer_ctx<O, F: FnOnce(&FakeTimerCtx<TimerId<FakeBindingsCtx>>) -> O>( &self, f: F, ) -> O

Calls the callback with a borrow of FakeTimerCtx.

fn with_fake_timer_ctx_mut<O, F: FnOnce(&mut FakeTimerCtx<TimerId<FakeBindingsCtx>>) -> O>( &mut self, f: F, ) -> O

Calls the callback with a mutable borrow of FakeTimerCtx.

impl AlwaysDefaultsSettingsContext for FakeBindingsCtx