mirror of https://github.com/stjepang/smol
Delete more dead code
This commit is contained in:
parent
bb75ee645c
commit
0e93b92744
|
@ -218,11 +218,6 @@ impl<T: IntoRawSocket> IntoRawSocket for Async<T> {
|
||||||
}
|
}
|
||||||
|
|
||||||
impl<T> Async<T> {
|
impl<T> Async<T> {
|
||||||
/// 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.
|
/// Gets a reference to the inner I/O handle.
|
||||||
///
|
///
|
||||||
/// # Examples
|
/// # Examples
|
||||||
|
|
|
@ -365,15 +365,6 @@ struct Wakers {
|
||||||
}
|
}
|
||||||
|
|
||||||
impl Source {
|
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.
|
/// Waits until the I/O source is readable.
|
||||||
pub(crate) async fn readable(&self) -> io::Result<()> {
|
pub(crate) async fn readable(&self) -> io::Result<()> {
|
||||||
let mut ticks = None;
|
let mut ticks = None;
|
||||||
|
@ -472,8 +463,6 @@ mod sys {
|
||||||
use std::os::unix::io::RawFd;
|
use std::os::unix::io::RawFd;
|
||||||
use std::time::Duration;
|
use std::time::Duration;
|
||||||
|
|
||||||
use once_cell::sync::Lazy;
|
|
||||||
|
|
||||||
use crate::sys::epoll::{
|
use crate::sys::epoll::{
|
||||||
epoll_create1, epoll_ctl, epoll_wait, EpollEvent, EpollFlags, EpollOp,
|
epoll_create1, epoll_ctl, epoll_wait, EpollEvent, EpollFlags, EpollOp,
|
||||||
};
|
};
|
||||||
|
|
Loading…
Reference in New Issue