Added readiness and interest for interrupt

src/loop_logic.rs

@@ -1630,6 +1630,7 @@ mod tests {
                         Readiness {
                             readable: true,
                             writable: false,
+                            interrupted: false,
                             error: false,
                         },
                         token,

src/sys.rs

@@ -56,31 +56,45 @@ pub struct Interest {
 
     /// Wait for the FD to be writable
     pub writable: bool,
+
+    /// Wait for the FD to be interrupted
+    pub interrupted: bool,
 }
 
 impl Interest {
     /// Shorthand for empty interest
     pub const EMPTY: Interest = Interest {
         readable: false,
         writable: false,
+        interrupted: false,
     };
 
     /// Shorthand for read interest
     pub const READ: Interest = Interest {
         readable: true,
         writable: false,
+        interrupted: false,
     };
 
     /// Shorthand for write interest
     pub const WRITE: Interest = Interest {
         readable: false,
         writable: true,
+        interrupted: false,
+    };
+
+    /// Shorthand for interrupt interest
+    pub const INTERRUPT: Interest = Interest {
+        readable: false,
+        writable: false,
+        interrupted: true,
     };
 
     /// Shorthand for read and write interest
-    pub const BOTH: Interest = Interest {
+    pub const ALL: Interest = Interest {
         readable: true,
         writable: true,
+        interrupted: true,
     };
 }
 
@@ -93,6 +107,9 @@ pub struct Readiness {
     /// Is the FD writable
     pub writable: bool,
 
+    /// Is the FD interrupted
+    pub interrupted: bool,
+
     /// Is the FD in an error state
     pub error: bool,
 }
@@ -102,6 +119,7 @@ impl Readiness {
     pub const EMPTY: Readiness = Readiness {
         readable: false,
         writable: false,
+        interrupted: false,
         error: false,
     };
 }
@@ -252,6 +270,7 @@ impl Poll {
                     readiness: Readiness {
                         readable: ev.readable,
                         writable: ev.writable,
+                        interrupted: ev.is_interrupt(),
                         error: false,
                     },
                     token: Token {
@@ -271,6 +290,7 @@ impl Poll {
                 readiness: Readiness {
                     readable: true,
                     writable: false,
+                    interrupted: false,
                     error: false,
                 },
                 token,
@@ -431,6 +451,7 @@ fn cvt_interest(interest: Interest, tok: Token) -> Event {
     let mut event = Event::none(tok.inner.into());
     event.readable = interest.readable;
     event.writable = interest.writable;
+    event.set_interrupt(interest.interrupted);
     event
 }