Struct EventedFd

pub struct EventedFd<'a>(pub &'a RawFd);

Adapter for RawFd providing an Evented implementation.

EventedFd enables registering any type with an FD with Poll.

While only implementations for TCP and UDP are provided, retty-io supports registering any FD that can be registered with the underlying OS selector. EventedFd provides the necessary bridge.

Note that EventedFd takes a &RawFd. This is because EventedFd does not take ownership of the FD. Specifically, it will not manage any lifecycle related operations, such as closing the FD on drop. It is expected that the EventedFd is constructed right before a call to Poll::register. See the examples for more detail.

Examples

Basic usage

use retty_io::{Ready, Poll, PollOpt, Token};
use retty_io::unix::EventedFd;

use std::os::unix::io::AsRawFd;
use std::net::TcpListener;

// Bind a std listener
let listener = TcpListener::bind("127.0.0.1:0")?;

let poll = Poll::new()?;

// Register the listener
poll.register(&EventedFd(&listener.as_raw_fd()),
             Token(0), Ready::readable(), PollOpt::edge())?;

Implementing Evented for a custom type backed by a RawFd.

use retty_io::{Ready, Poll, PollOpt, Token};
use retty_io::event::Evented;
use retty_io::unix::EventedFd;

use std::os::unix::io::RawFd;
use std::io;

pub struct MyIo {
    fd: RawFd,
}

impl Evented for MyIo {
    fn register(&self, poll: &Poll, token: Token, interest: Ready, opts: PollOpt)
        -> io::Result<()>
    {
        EventedFd(&self.fd).register(poll, token, interest, opts)
    }

    fn reregister(&self, poll: &Poll, token: Token, interest: Ready, opts: PollOpt)
        -> io::Result<()>
    {
        EventedFd(&self.fd).reregister(poll, token, interest, opts)
    }

    fn deregister(&self, poll: &Poll) -> io::Result<()> {
        EventedFd(&self.fd).deregister(poll)
    }
}

Tuple Fields

0: &'a RawFd

Trait Implementations

impl<'a> Debug for EventedFd<'a>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'a> Evented for EventedFd<'a>

fn register( &self, poll: &Poll, token: Token, interest: Ready, opts: PollOpt, ) -> Result<()>

Register self with the given Poll instance.

fn reregister( &self, poll: &Poll, token: Token, interest: Ready, opts: PollOpt, ) -> Result<()>

Re-register self with the given Poll instance.

fn deregister(&self, poll: &Poll) -> Result<()>

Deregister self from the given Poll instance