fn run_fio(target: String, target_size: u64) -> Receiver<i32> {
    let (s, r) = unbounded::<i32>();
    std::thread::spawn(move || {
        if let Err(e) = s.send(common::fio_verify_size(&target, target_size)) {
            tracing::error!("Failed to send fio complete with error {}", e);
        }
    });
    r
}
/// Run fio in a spawned thread and return a receiver channel which is signalled
/// when fio completes.
Run fio in a spawned thread and return a receiver channel which is signalled
when fio completes.
Run fio in a spawned thread and return a receiver channel which is signalled when fio completes .
fn run_fio(target: String, target_size: u64) -> Receiver<i32> {
    let (s, r) = unbounded::<i32>();
    std::thread::spawn(move || {
        if let Err(e) = s.send(common::fio_verify_size(&target, target_size)) {
            tracing::error!("Failed to send fio complete with error {}", e);
        }
    });
    r
}
fn run_fio ( target : String , target_size : u64 ) -> Receiver < i32 > { let ( s , r ) = unbounded :: < i32 > ( ) ; std :: thread :: spawn ( move | | { if let Err ( e ) = s . send ( common :: fio_verify_size ( & target , target_size ) ) { tracing :: error ! ( " " e ) ; } } ) ; r }
Run fio in a spawned thread and return a receiver channel which is signalled
when fio completes.
Run fio in a spawned thread and return a receiver channel which is signalled when fio completes .
target
String
target_size
u64