Skip to content

Commit

Permalink
chore: update tokio_uring
Browse files Browse the repository at this point in the history
  • Loading branch information
KKould committed Sep 30, 2024
1 parent 5e6f3a4 commit 2a8991b
Show file tree
Hide file tree
Showing 3 changed files with 10 additions and 8 deletions.
4 changes: 1 addition & 3 deletions fusio/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -179,9 +179,7 @@ impl<W: Write> Write for &mut W {

#[cfg(test)]
mod tests {
use std::future::Future;

use super::{MaybeSend, Read, Write};
use super::{Read, Write};
use crate::{buf::IoBufMut, Error, IoBuf, Seek};

#[allow(unused)]
Expand Down
4 changes: 1 addition & 3 deletions fusio/src/local/tokio_uring/mod.rs
Original file line number Diff line number Diff line change
@@ -1,11 +1,9 @@
#[cfg(feature = "fs")]
pub mod fs;

use std::future::Future;

use tokio_uring::fs::File;

use crate::{Error, IoBuf, IoBufMut, MaybeSend, Read, Seek, Write};
use crate::{Error, IoBuf, IoBufMut, Read, Seek, Write};

#[repr(transparent)]
struct TokioUringBuf<B> {
Expand Down
10 changes: 8 additions & 2 deletions fusio/src/options.rs
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,10 @@ use crate::{DynFs, Error};
#[derive(Clone)]
#[non_exhaustive]
pub enum FsOptions {
#[cfg(all(feature = "fs", any(feature = "tokio", feature = "monoio")))]
#[cfg(all(
feature = "fs",
any(feature = "tokio", feature = "monoio", feature = "tokio-uring")
))]
Local,
#[cfg(feature = "aws")]
S3 {
Expand All @@ -20,7 +23,10 @@ pub enum FsOptions {
impl FsOptions {
pub fn parse(self) -> Result<Arc<dyn DynFs>, Error> {
match self {
#[cfg(all(feature = "fs", any(feature = "tokio", feature = "monoio")))]
#[cfg(all(
feature = "fs",
any(feature = "tokio", feature = "monoio", feature = "tokio-uring")
))]
FsOptions::Local => Ok(Arc::new(crate::local::LocalFs {})),
#[cfg(all(feature = "aws", feature = "object_store"))]
FsOptions::S3 {
Expand Down

0 comments on commit 2a8991b

Please sign in to comment.