diff --git a/tokio/src/io/driver/mod.rs b/tokio/src/io/driver/mod.rs index fb892bcc1d2..c34e8a7a7fb 100644 --- a/tokio/src/io/driver/mod.rs +++ b/tokio/src/io/driver/mod.rs @@ -71,10 +71,10 @@ pub(super) struct Inner { resources: Mutex>>, /// Registers I/O resources. - #[cfg(not(target_arch = "wasm32"))] + //#[cfg(not(target_arch = "wasm32"))] registry: mio::Registry, - #[cfg(target_arch = "wasm32")] - registry: Arc, + //#[cfg(target_arch = "wasm32")] + //registry: Arc, /// Allocates `ScheduledIo` handles when creating new resources. pub(super) io_dispatch: slab::Allocator, @@ -127,10 +127,12 @@ impl Driver { #[cfg(not(target_os = "wasi"))] let waker = mio::Waker::new(poll.registry(), TOKEN_WAKEUP)?; - #[cfg(not(target_os = "wasi"))] + //#[cfg(not(target_os = "wasi"))] let registry = poll.registry().try_clone()?; - #[cfg(target_os = "wasi")] - let registry = poll.registry(); + //#[cfg(target_os = "wasi")] + //let registry = poll.registry(); + + // let registry = poll.registry().clone(); let slab = Slab::new(); let allocator = slab.allocator(); @@ -142,7 +144,7 @@ impl Driver { resources: Some(slab), inner: Arc::new(Inner { resources: Mutex::new(None), - registry: registry, + registry, io_dispatch: allocator, #[cfg(not(target_os = "wasi"))] waker, diff --git a/tokio/src/io/driver/registration.rs b/tokio/src/io/driver/registration.rs index 181d2349f86..5bc8485620d 100644 --- a/tokio/src/io/driver/registration.rs +++ b/tokio/src/io/driver/registration.rs @@ -247,14 +247,11 @@ cfg_io_readiness! { } pub(crate) async fn async_io(&self, interest: Interest, mut f: impl FnMut() -> io::Result) -> io::Result { - println!("Tokio Registration::async_io() {}:{}", file!(), line!()); loop { let event = self.readiness(interest).await?; - println!("Tokio Registration::async_io() self.readiness({:?}) = {:?} returned @ {}:{}", interest, event, file!(), line!()); match f() { Err(ref e) if e.kind() == io::ErrorKind::WouldBlock => { self.clear_readiness(event); - println!("Tokio Registration::async_io() self.clear_readiness() {}:{}", file!(), line!()); } x => return x, }