diff --git a/src/async_io.rs b/src/async_io.rs index 83292aa..7fc6a3e 100644 --- a/src/async_io.rs +++ b/src/async_io.rs @@ -218,11 +218,6 @@ impl IntoRawSocket for Async { } impl Async { - /// Re-registers the I/O event to wake the poller. - pub(crate) fn reregister_io_event(&self) -> io::Result<()> { - self.source.reregister_io_event() - } - /// Gets a reference to the inner I/O handle. /// /// # Examples diff --git a/src/reactor.rs b/src/reactor.rs index 6c9fb88..f4f821c 100644 --- a/src/reactor.rs +++ b/src/reactor.rs @@ -365,15 +365,6 @@ struct Wakers { } impl Source { - /// Re-registers the I/O event to wake the poller. - pub(crate) fn reregister_io_event(&self) -> io::Result<()> { - let wakers = self.wakers.lock(); - Reactor::get() - .sys - .reregister(self.raw, self.key, true, !wakers.writers.is_empty())?; - Ok(()) - } - /// Waits until the I/O source is readable. pub(crate) async fn readable(&self) -> io::Result<()> { let mut ticks = None; @@ -472,8 +463,6 @@ mod sys { use std::os::unix::io::RawFd; use std::time::Duration; - use once_cell::sync::Lazy; - use crate::sys::epoll::{ epoll_create1, epoll_ctl, epoll_wait, EpollEvent, EpollFlags, EpollOp, };