Struct FrameStreamBridge 

pub struct FrameStreamBridge { /* private fields */ }

Running libkrun unix-stream bridge for one virtio NIC.

The bridge owns:

• the shared AF_UNIX stream socket (used to trigger shutdown via shutdown)
• a reader thread for guest->host frames
• a writer thread for host->guest frames

The transport is an AF_UNIX stream socket, wrapped in socket2::Socket so the same code serves Unix hosts and Windows (10 1809+ has native AF_UNIX). On Unix the launcher hands us one end of a socketpair; on Windows it hands us the socket it accepted from libkrun on a per-VM path.

The socket is shared via Arc and the reader/writer threads use it through &Socket (socket2 implements Read/Write for &Socket), rather than try_clone-ing it three ways: duplicating an AF_UNIX socket handle is unreliable on Windows (a clone may not observe the peer’s writes), which silently stalled all guest traffic. Concurrent read + write on one socket is safe — the directions are independent.

Trait Implementations

impl Drop for FrameStreamBridge

fn drop(&mut self)

Request shutdown and join the reader/writer workers.

shutdown(Shutdown::Both) is the important part here: it forces any blocking read/write on the shared socket to wake up and fail, which lets the threads notice shutdown and return.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.