qubit-fs 0.2.2

Provider-neutral synchronous and asynchronous filesystem abstraction for Rust
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40

// =============================================================================
//    Copyright (c) 2026 Haixing Hu.
//
//    SPDX-License-Identifier: Apache-2.0
//
//    Licensed under the Apache License, Version 2.0.
// =============================================================================

//! Retry policy for recoverable synchronous stream interruptions.

use std::io;

use qubit_io::Input;

use crate::error::FsEffectState;
use crate::error::FsError;
use crate::error::FsErrorKind;

fn retryable(error: &io::Error) -> bool {
    if let Some(fs_error) = error.get_ref().and_then(|source| source.downcast_ref::<FsError>()) {
        return fs_error.kind() == FsErrorKind::Interrupted
            && matches!(fs_error.effect_state(), None | Some(FsEffectState::Unchanged));
    }
    error.kind() == io::ErrorKind::Interrupted
}

/// Reads once or retries a recoverable synchronous interruption.
pub(crate) fn read_retry_interrupted<I: Input<Item = u8> + ?Sized>(
    input: &mut I,
    output: &mut [u8],
    mut before_read: impl FnMut() -> io::Result<()>,
) -> io::Result<usize> {
    loop {
        before_read()?;
        match Input::read(input, output) {
            Err(error) if retryable(&error) => {}
            result => return result,
        }
    }
}