move mio utils crates to conflux-chain org

Author: Pana

Cargo.lock

@@ -325,8 +325,8 @@ async-trait = "0.1"
 tower = "0.4"
 pin-project = "1.0"
 mio = { version = "1.0.4", features = ["os-ext", "net", "os-poll"] }
-mio-timer = { git = "https://github.com/Pana/mio-timer", rev = "251170b" }
-mio-misc = { git = "https://github.com/Pana/mio-misc", rev = "27ad80f" }
+mio-timer = { git = "https://github.com/Conflux-Chain/mio-timer", rev = "91a02cc" }
+mio-misc = { git = "https://github.com/Conflux-Chain/mio-misc", rev = "27ad80f" }
 reqwest = "0.12"
 
 # crypto & hash

Cargo.toml

@@ -387,10 +387,7 @@ impl Connection {
             recv_buf: BytesMut::new(),
             send_queue: PrioritySendQueue::default(),
             sending_packet: None,
-            interest: Interest::READABLE, /* previously(mio0.6) use
-                                           * Ready::hup() |
-                                           * Ready::readable(), Ready::hub()
-                                           * is removed from 0.7 */
+            interest: Interest::READABLE,
             registered: AtomicBool::new(false),
             assembler: Box::new(PacketWithLenAssembler::default()),
         }

crates/network/src/connection.rs

@@ -1772,7 +1772,7 @@ impl IoHandler<NetworkIoMessage> for NetworkServiceInner {
                     .register(
                         &mut *self.tcp_listener.lock(),
                         Token(TCP_ACCEPT),
-                        Interest::READABLE | Interest::WRITABLE, // previously(mio0.6) Ready::all() is used here
+                        Interest::READABLE | Interest::WRITABLE,
                     )
                     .expect("Error registering stream");
             }
@@ -1781,7 +1781,7 @@ impl IoHandler<NetworkIoMessage> for NetworkServiceInner {
                     .register(
                         &mut *self.udp_socket.lock(),
                         reg,
-                        Interest::READABLE | Interest::WRITABLE, // previously(mio0.6) Ready::all() is used here
+                        Interest::READABLE | Interest::WRITABLE,
                     )
                     .expect("Error registering UDP socket");
             }
@@ -1828,7 +1828,7 @@ impl IoHandler<NetworkIoMessage> for NetworkServiceInner {
                 .reregister(
                     &mut *self.tcp_listener.lock(),
                     Token(TCP_ACCEPT),
-                    Interest::READABLE | Interest::WRITABLE, // previously(mio0.6) Ready::all() is used here
+                    Interest::READABLE | Interest::WRITABLE,
                 )
                 .expect("Error reregistering stream"),
             UDP_MESSAGE => {
@@ -1841,11 +1841,7 @@ impl IoHandler<NetworkIoMessage> for NetworkServiceInner {
                     Interest::READABLE
                 };
                 poll_registry
-                    .reregister(
-                        &mut *udp_socket,
-                        reg,
-                        registration,
-                    )
+                    .reregister(&mut *udp_socket, reg, registration)
                     .expect("Error reregistering UDP socket");
             }
             _ => warn!("Unexpected stream update"),

crates/network/src/service.rs

@@ -1,7 +1,6 @@
 // Re-export the io::Result / Error types for convenience
 pub use std::io::{Error, ErrorKind, Read, Result, Write};
 
-// TODO: Delete this
 /// A helper trait to provide the map_non_block function on Results.
 pub trait MapNonBlock<T> {
     /// Maps a `Result<T>` to a `Result<Option<T>>` by converting