Struct LinuxRequestDispatcher 

pub struct LinuxRequestDispatcher { /* private fields */ }

Explicit bounded dispatcher shared by one mount session.

Implementations

impl LinuxRequestDispatcher

pub fn new(runtime: Handle, max_in_flight: usize) -> Result<Self>

Creates a dispatcher backed by a caller-owned runtime.

Errors

Returns an error when validation fails or an underlying backend, store, or platform operation fails.

pub fn reserve( &self, ) -> Result<LinuxDispatchReservation, LinuxDispatchRejection>

Reserves one in-flight slot without blocking the callback thread.

Errors

Returns an error when validation fails or an underlying backend, store, or platform operation fails.

pub fn spawn_cleanup<F>(&self, future: F)

where F: Future<Output = ()> + Send + 'static,

Dispatches mandatory cleanup for an already accepted native handle.

Cleanup bypasses the normal request semaphore and closing fence because FUSE issues one final release per successful open; rejecting that cleanup would leak adapter and product-owned session state. Callers must use this only for bounded-by-open-handle terminal work, never for new backend requests.

pub fn close(&self)

Begins idempotent closing and rejects every subsequent reservation.

pub fn is_closing(&self) -> bool

Returns whether new callback work is rejected.

pub fn metrics(&self) -> LinuxDispatchMetrics

Returns an atomic metrics snapshot.

Trait Implementations

impl Clone for LinuxRequestDispatcher

fn clone(&self) -> LinuxRequestDispatcher

Returns a duplicate of the value.

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

Performs copy-assignment from source.