6/51

1 files changed, 6 insertions, 2 deletions

diff --git a/monoio/src/driver/legacy/mod.rs b/monoio/src/driver/legacy/mod.rs
index a92a702..483cd70 100644
--- a/monoio/src/driver/legacy/mod.rs
+++ b/monoio/src/driver/legacy/mod.rs
@@ -26,7 +26,7 @@ mod waker;
 pub(crate) use waker::UnparkHandle;
 
 pub(crate) struct LegacyInner {
-    pub(crate) io_dispatch: Slab<ScheduledIo>,
+    pub(crate) io_dispatch: Slab<ScheduledIo>, // 
     #[cfg(unix)]
     events: Option<mio::Events>,
     #[cfg(unix)]
@@ -260,7 +260,7 @@ impl LegacyInner {
 
     pub(crate) fn poll_op<T: OpAble>(
         this: &Rc<UnsafeCell<Self>>,
-        data: &mut T,
+        data: &mut T, // 实际上是个 OpAble
         cx: &mut Context<'_>,
     ) -> Poll<CompletionMeta> {
         let inner = unsafe { &mut *this.get() };
@@ -269,6 +269,7 @@ impl LegacyInner {
             None => {
                 // if there is no index provided, it means the action does not rely on fd
                 // readiness. do syscall right now.
+                // 如果没有提供索引,则表示该操作不依赖于 fd 的准备就绪.立即执行系统调用.
                 return Poll::Ready(CompletionMeta {
                     result: OpAble::legacy_call(data),
                     flags: 0,
@@ -277,14 +278,17 @@ impl LegacyInner {
         };
 
         // wait io ready and do syscall
+        // 等待 io 准备就绪并执行系统调用
         let mut scheduled_io = inner.io_dispatch.get(index).expect("scheduled_io lost");
         let ref_mut = scheduled_io.as_mut();
         loop {
             let readiness = ready!(ref_mut.poll_readiness(cx, direction));
 
             // check if canceled
+            // 检查是否已取消
             if readiness.is_canceled() {
                 // clear CANCELED part only
+                // 只清除 CANCELED 部分
                 ref_mut.clear_readiness(readiness & Ready::CANCELED);
                 return Poll::Ready(CompletionMeta {
                     result: Err(io::Error::from_raw_os_error(125)),