From 79e7f31eefa3c951b6fd102f6688dfa7826c998f Mon Sep 17 00:00:00 2001 From: Ming Lei Date: Wed, 5 Feb 2025 12:54:08 +0000 Subject: [PATCH] debug: force sqe async For debug purpose Signed-off-by: Ming Lei --- src/zoned.rs | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/src/zoned.rs b/src/zoned.rs index 0dcedb5..4e26637 100644 --- a/src/zoned.rs +++ b/src/zoned.rs @@ -17,7 +17,7 @@ use libublk::{ctrl::UblkCtrl, io::UblkDev, io::UblkIOCtx, io::UblkQueue}; use anyhow::bail; use bitflags::bitflags; -use io_uring::{opcode, types}; +use io_uring::{opcode, squeue, types}; use libc::{c_void, memset, pread, pwrite}; use log::trace; use std::fs::{File, OpenOptions}; @@ -804,7 +804,8 @@ async fn handle_read( //read to temp buffer from backed-file let sqe = opcode::Read::new(types::Fd(zfd), buf_addr as *mut u8, bytes as u32) .offset(zf_offset) - .build(); + .build() + .flags(squeue::Flags::ASYNC); let res = q.ublk_submit_sqe(sqe).await; if res < 0 { return Err(anyhow::anyhow!("io uring read failure {}", res)); @@ -846,7 +847,8 @@ async fn handle_plain_write( // handle the write let sqe = opcode::Write::new(types::Fd(zfd), buf_addr as *const u8, bytes as u32) .offset(zf_offset) - .build(); + .build() + .flags(squeue::Flags::ASYNC); q.ublk_submit_sqe(sqe).await } else { let off = start_sector << 9;