chore: refactor driver module (#180)

This change renames the top-level driver module to "io" and moves the
driver and Op to a driver module within the runtime module.

Author: Noah-Kennedy

src/fs/directory.rs

@@ -1,5 +1,4 @@
-use crate::driver::Op;
-
+use crate::runtime::driver::op::Op;
 use std::io;
 use std::path::Path;
 

src/fs/file.rs

@@ -1,7 +1,8 @@
 use crate::buf::{BoundedBuf, BoundedBufMut, IoBuf, IoBufMut, Slice};
-use crate::driver::{Op, SharedFd};
 use crate::fs::OpenOptions;
+use crate::io::SharedFd;
 
+use crate::runtime::driver::op::Op;
 use std::fmt;
 use std::io;
 use std::os::unix::io::{AsRawFd, FromRawFd, IntoRawFd, RawFd};

src/fs/open_options.rs

@@ -1,6 +1,6 @@
-use crate::driver::Op;
 use crate::fs::File;
 
+use crate::runtime::driver::op::Op;
 use std::io;
 use std::os::unix::fs::OpenOptionsExt;
 use std::path::Path;

src/driver/accept.rs renamed to src/io/accept.rs

@@ -1,5 +1,6 @@
-use crate::driver::op::{self, Completable};
-use crate::driver::{Op, SharedFd, Socket};
+use crate::io::{SharedFd, Socket};
+use crate::runtime::driver::op;
+use crate::runtime::driver::op::{Completable, Op};
 use std::net::SocketAddr;
 use std::{boxed::Box, io};
 

src/driver/bind.rs renamed to src/io/bind.rs

@@ -1,6 +1,5 @@
-use crate::driver::Op;
-
-use crate::driver::op::{self, Completable};
+use crate::runtime::driver::op;
+use crate::runtime::driver::op::{Completable, Op};
 use std::io;
 use std::os::unix::io::RawFd;
 

src/driver/close.rs renamed to src/io/close.rs

@@ -1,5 +1,5 @@
-use crate::driver::op::{self, Completable};
-use crate::driver::{Op, SharedFd};
+use crate::io::SharedFd;
+use crate::runtime::driver::op::{Completable, CqeResult, Op};
 use socket2::SockAddr;
 use std::io;
 
@@ -36,7 +36,7 @@ impl Op<Connect> {
 impl Completable for Connect {
     type Output = io::Result<()>;
 
-    fn complete(self, cqe: op::CqeResult) -> Self::Output {
+    fn complete(self, cqe: CqeResult) -> Self::Output {
         cqe.result.map(|_| ())
     }
 }

src/driver/connect.rs renamed to src/io/connect.rs

@@ -1,8 +1,7 @@
-use crate::driver::{Op, SharedFd};
-
 use std::io;
 
-use crate::driver::op::{self, Completable};
+use crate::io::SharedFd;
+use crate::runtime::driver::op::{Completable, CqeResult, Op};
 use io_uring::{opcode, types};
 
 pub(crate) struct Fsync {
@@ -28,7 +27,7 @@ impl Op<Fsync> {
 impl Completable for Fsync {
     type Output = io::Result<()>;
 
-    fn complete(self, cqe: op::CqeResult) -> Self::Output {
+    fn complete(self, cqe: CqeResult) -> Self::Output {
         cqe.result.map(|_| ())
     }
 }

src/driver/fsync.rs renamed to src/io/fsync.rs

@@ -0,0 +1,39 @@
+mod accept;
+
+mod close;
+pub(crate) use close::Close;
+
+mod connect;
+
+mod fsync;
+
+mod noop;
+pub(crate) use noop::NoOp;
+
+mod open;
+
+mod read;
+
+mod readv;
+
+mod recv_from;
+
+mod rename_at;
+
+mod send_to;
+
+mod send_zc;
+
+mod shared_fd;
+pub(crate) use shared_fd::SharedFd;
+
+mod socket;
+pub(crate) use socket::Socket;
+
+mod unlink_at;
+
+mod util;
+
+mod write;
+
+mod writev;

src/io/mod.rs

@@ -1,7 +1,4 @@
-use crate::driver::{
-    op::{self, Completable},
-    Op,
-};
+use crate::runtime::driver::op::{Completable, CqeResult, Op};
 use std::io;
 
 /// No operation. Just posts a completion event, nothing else.
@@ -20,7 +17,7 @@ impl Op<NoOp> {
 impl Completable for NoOp {
     type Output = io::Result<()>;
 
-    fn complete(self, cqe: op::CqeResult) -> Self::Output {
+    fn complete(self, cqe: CqeResult) -> Self::Output {
         cqe.result.map(|_| ())
     }
 }