Struct cros_async::sys::linux::fd_executor::RegisteredSource

pub struct RegisteredSource<F> {
    pub(crate) source: F,
    ex: Weak<RawExecutor<EpollReactor>>,
    pub(crate) duped_fd: Arc<OwnedFd>,
}

Fields

source: F

ex: Weak<RawExecutor<EpollReactor>>

duped_fd: Arc<OwnedFd>

A clone of source’s underlying FD. Allows us to ensure that the FD isn’t closed during the epoll wait call. There are well defined sematics for closing an FD in an epoll context so it might be possible to eliminate this dup if someone thinks hard about it.

Implementations

impl<F: AsRawDescriptor> RegisteredSource<F>

pub(crate) fn new(raw: &Arc<RawExecutor<EpollReactor>>, f: F) -> Result<Self>

pub fn wait_readable(&self) -> Result<PendingOperation>

pub fn wait_writable(&self) -> Result<PendingOperation>