Struct netstack3_core::testutil::FakeBindingsCtx

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

Test-only implementation of crate::BindingsContext.

Implementations

impl FakeBindingsCtx

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.

Trait Implementations

impl Clone for FakeBindingsCtx

fn clone(&self) -> FakeBindingsCtx

Returns a copy 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

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

Signals to the dispatcher that RX frames are available and ready to be handled by [handle_queued_rx_packets].

fn wake_tx_task(&mut self, device: &DeviceId<FakeBindingsCtx>)

Signals to the dispatcher that TX frames are available and ready to be sent by [transmit_queued_tx_frames].

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

Send a frame to an Ethernet device driver.

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

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 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, state: &Self::SocketState, device: &DeviceId<Self>, _frame: Frame<&[u8]>, raw_frame: &[u8] )

Called for each received frame that matches the provided socket.

impl DeviceSocketTypes for FakeBindingsCtx

type SocketState = 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 FilterBindingsTypes for FakeBindingsCtx

type DeviceClass = ()

The device class type for devices installed in the netstack.

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 )

Receives an ICMP echo reply.

impl IcmpEchoBindingsTypes for FakeBindingsCtx

type ExternalData<I: Ip> = ()

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

impl InstantBindingsTypes for FakeBindingsCtx

type Instant = FakeInstant

The type of an instant in time.

impl InstantContext for FakeBindingsCtx

fn now(&self) -> FakeInstant

Returns the current instant.

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

type Notifier = ()

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

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<XorShiftRng>

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

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

Gets the random number generator (RNG).

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.

fn default_buffer_sizes() -> BufferSizes

The buffer sizes to use when creating new sockets.

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.

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 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 TracingContext for FakeBindingsCtx

type DurationScope = ()

The scope of a trace duration.

fn duration(&self, _: &'static CStr)

Writes a duration event which ends when the returned scope is dropped.

impl UdpBindingsTypes for FakeBindingsCtx

type ExternalData<I: Ip> = ()

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

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

fn receive_udp<B: BufferMut>( &mut self, id: &UdpSocketId<I, WeakDeviceId<Self>, FakeBindingsCtx>, _device: &DeviceId<Self>, _dst_addr: (I::Addr, NonZeroU16), _src_addr: (I::Addr, Option<NonZeroU16>), body: &B )

Receives a UDP packet on a socket.

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.