Struct SpscFace 

pub struct SpscFace { /* private fields */ }

Engine-side SPSC SHM face.

Create with SpscFace::create; register with the engine via ForwarderEngine::add_face. Give the name to the application so it can call SpscHandle::connect.

Implementations

impl SpscFace

pub fn create(id: FaceId, name: &str) -> Result<Self, ShmError>

Create the SHM region and set up the wakeup mechanism.

name identifies this face (e.g. "sensor-0"); pass it to SpscHandle::connect in the application process.

pub fn create_with( id: FaceId, name: &str, capacity: u32, slot_size: u32, ) -> Result<Self, ShmError>

Create with explicit ring parameters.

Trait Implementations

impl Drop for SpscFace

fn drop(&mut self)

Executes the destructor for this type.

impl Face for SpscFace

fn id(&self) -> FaceId

fn kind(&self) -> FaceKind

async fn recv(&self) -> Result<Bytes, FaceError>

Receive the next packet. Blocks until a packet arrives or the face closes.

async fn send(&self, pkt: Bytes) -> Result<(), FaceError>

Send a packet. Must not block the caller; use internal buffering.

fn remote_uri(&self) -> Option<String>

Remote URI (e.g. udp4://192.168.1.1:6363). Returns None for face types that don’t have a meaningful remote endpoint.

fn local_uri(&self) -> Option<String>

Local URI (e.g. unix:///tmp/ndn.sock). Returns None for face types that don’t expose local binding info.

fn recv_with_addr( &self, ) -> impl Future<Output = Result<(Bytes, Option<FaceAddr>), FaceError>> + Send

Receive the next packet together with the link-layer sender address.