Struct VsockConnectionManager 

pub struct VsockConnectionManager {
    pub backend_rxq: VecDeque<VsockConnectionId>,
    /* private fields */
}

Manages all active host-initiated vsock connections for the HV backend.

Thread-safe: wrapped in Arc<Mutex<>> and shared between the daemon threads (which call allocate) and vCPU threads (which call poll methods via VsockHostConnections trait).

Fields

backend_rxq: VecDeque<VsockConnectionId>

FIFO of connection IDs with pending RX operations. Consumed by poll_vsock_rx → recv_pkt.

Implementations

impl VsockConnectionManager

pub fn new() -> VsockConnectionManager

Creates a new empty connection manager.

pub fn set_doorbell(&mut self, doorbell: Arc<dyn Fn() + Send + Sync>)

Installs the doorbell rung when new host→guest RX work appears.

pub fn allocate( &mut self, guest_port: u32, guest_cid: u64, internal_fd: OwnedFd, ) -> (VsockConnectionId, Receiver<()>)

Allocates a new connection to guest_port, returning a unique ID.

The internal_fd is the internal end of a socketpair; the external end was returned to the daemon caller. Ownership of internal_fd transfers to the manager — it will be closed automatically when the connection is removed.

Enqueues RxOps::REQUEST and pushes to backend_rxq so the next poll_vsock_rx sends OP_REQUEST to the guest. Allocates a new connection to guest_port, returning the ID and a receiver that signals when the connection is established (OP_RESPONSE) or rejected (OP_RST). The daemon should wait on this receiver before using the socketpair for data transfer. Allocates a new connection. Returns the ID and a receiver that fires when the vCPU thread has injected the OP_REQUEST into guest memory. The daemon MUST wait on this receiver before using the fd.

pub fn connected_fds(&self) -> Vec<(VsockConnectionId, i32)>

Returns a snapshot of all connected (id, raw_fd) pairs for polling.

The caller uses these to libc::read from each fd and, if data is available, enqueue RxOps::RW and push to backend_rxq.

pub fn get_mut( &mut self, id: &VsockConnectionId, ) -> Option<&mut VsockConnection>

Returns a mutable reference to a connection.

pub fn get(&self, id: &VsockConnectionId) -> Option<&VsockConnection>

Returns a reference to a connection.

pub fn enqueue_rw(&mut self, id: VsockConnectionId)

Enqueues a data-available RX op for a connected stream.

pub fn enqueue_reset(&mut self, id: VsockConnectionId)

Enqueues a reset for a connection (e.g., when host stream closes).

pub fn remove(&mut self, id: &VsockConnectionId)

Removes a connection and closes its fd.

pub fn connections_with_pending_rx(&self) -> Vec<VsockConnectionId>

Returns IDs of connections that have pending RX ops but are NOT already in the backend_rxq. Used after TX processing to pick up newly-enqueued ops (e.g., CreditUpdate after guest OP_CREDIT_REQUEST).

Trait Implementations

impl Default for VsockConnectionManager

fn default() -> VsockConnectionManager

Returns the “default value” for a type.

impl VsockHostConnections for VsockConnectionManager

fn fd_for(&self, guest_port: u32, host_port: u32) -> Option<i32>

Returns the host fd for a connection identified by (guest_port, host_port).

fn mark_connected(&mut self, guest_port: u32, host_port: u32)

Marks a connection as established (called when OP_RESPONSE is received).

fn remove_connection(&mut self, guest_port: u32, host_port: u32)

Removes a connection and closes the associated fd (called on OP_RST).

fn update_peer_credit( &mut self, guest_port: u32, host_port: u32, buf_alloc: u32, fwd_cnt: u32, )

Updates peer credit state from an incoming guest packet. Called for every TX packet to keep credit info in sync.

fn advance_fwd_cnt( &mut self, guest_port: u32, host_port: u32, bytes: u32, ) -> bool

Advances fwd_cnt after writing guest data to the host stream. Returns true if the host has pending RX data as a result (CreditUpdate).

fn enqueue_credit_update(&mut self, guest_port: u32, host_port: u32)

Enqueues a CreditUpdate to be sent on the next RX fill.

fn handle_shutdown(&mut self, guest_port: u32, host_port: u32, flags: u32)

Handles a guest-originated OP_SHUTDOWN with its flags bitmask.