Enum PipelineError 

#[non_exhaustive]
pub enum PipelineError {
    IoUringSyscall {
        syscall: &'static str,
        errno: i32,
        fix: &'static str,
    },
    QueueFull {
        queue: &'static str,
        fix: &'static str,
    },
    NotLinux,
    NvmePassthroughDisabled,
    Backend(String),
    DrainIncomplete {
        descriptor: &'static str,
        claimed: u32,
        expected: u32,
        unit: &'static str,
    },
}

Errors surfaced by the runtime layer. Every variant carries a Fix:-bearing message so a reviewer can act on the failure.

Variants (Non-exhaustive)

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.

IoUringSyscall

Raw io_uring / libc syscall failed with an errno.

Fields

syscall: &'static str

Which syscall failed (io_uring_setup, mmap, io_uring_enter).

errno: i32

Underlying errno value.

fix: &'static str

Actionable remediation.

QueueFull

io_uring submission or completion queue was full / overflowed.

Fields

queue: &'static str

“submission” or “completion”.

fix: &'static str

Actionable remediation.

NotLinux

Attempted to use io_uring on a non-Linux platform.

NvmePassthroughDisabled

Feature required for NVMe passthrough is not enabled.

Backend(String)

Backend error bubbled up from compile or dispatch.

DrainIncomplete

A megakernel dispatch ended before its work queue drained: only claimed of expected unit were claimed, so the rest went unscanned and this dispatch’s hit set is INCOMPLETE — never a silent partial (Law 10). A first-class variant (not a Backend string) so callers such as the seg_len calibrator can EXCLUDE a too-fine geometry by matching the type, never by substring-scanning the message text.

Fields

descriptor: &'static str

Which dispatch path under-drained: "megakernel" (per-rule) or "combined megakernel" (combined-AC). Names the failing path in the operator message without a second string variant.

claimed: u32

Work-items/segments actually claimed before the dispatch ended.

expected: u32

Work-items/segments that should have been claimed (full queue length).

unit: &'static str

The unit being drained: "work-items" (per-rule) or "segments" (combined-AC). Interpolated twice for a grammatical message.

Implementations

impl PipelineError

pub fn is_drain_incomplete(&self) -> bool

True iff this is a PipelineError::DrainIncomplete: a dispatch that could not exhaust its work queue within the timeout.

Distinct from a hard backend failure — the seg_len calibrator EXCLUDES a geometry that drains incompletely (too fine to drain in the configured timeout) rather than aborting the whole calibration, while it must still PROPAGATE any other PipelineError. Match on this predicate instead of substring-scanning the Display message, which is fragile to wording changes.

Trait Implementations

impl Clone for PipelineError

fn clone(&self) -> PipelineError

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PipelineError

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Display for PipelineError

fn fmt(&self, __formatter: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Error for PipelineError

fn source(&self) -> Option<&(dyn Error + 'static)>

Returns the lower-level source of this error, if any.

fn description(&self) -> &str

👎Deprecated since 1.42.0:

use the Display impl or to_string()

fn cause(&self) -> Option<&dyn Error>

👎Deprecated since 1.33.0:

replaced by Error::source, which can support downcasting

fn provide<'a>(&'a self, request: &mut Request<'a>)

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

Provides type-based access to context intended for error reports.

impl From<BackendError> for PipelineError

fn from(err: BackendError) -> Self

Converts to this type from the input type.

impl From<PipelineError> for TenantError

fn from(source: PipelineError) -> Self

Converts to this type from the input type.

impl From<ReplayLogError> for PipelineError

Let callers bridge ReplayLogError into the unified PipelineError surface when driving the log from the megakernel pump loop.

fn from(err: ReplayLogError) -> Self

Converts to this type from the input type.