Struct polling::Event

source ·
pub struct Event {
    pub key: usize,
    pub readable: bool,
    pub writable: bool,
    /* private fields */
}
Expand description

Indicates that a file descriptor or socket can read or write without blocking.

Fields§

§key: usize

Key identifying the file descriptor or socket.

§readable: bool

Can it do a read operation without blocking?

§writable: bool

Can it do a write operation without blocking?

Implementations§

source§

impl Event

source

pub const fn new(key: usize, readable: bool, writable: bool) -> Event

Create a new event.

source

pub const fn all(key: usize) -> Event

All kinds of events (readable and writable).

Equivalent to: Event::new(key, true, true)

source

pub const fn readable(key: usize) -> Event

Only the readable event.

Equivalent to: Event::new(key, true, false)

source

pub const fn writable(key: usize) -> Event

Only the writable event.

Equivalent to: Event::new(key, false, true)

source

pub const fn none(key: usize) -> Event

No events.

Equivalent to: Event::new(key, false, false)

source

pub fn set_interrupt(&mut self, active: bool)

Add interruption events to this interest.

This usually indicates that the file descriptor or socket has been closed. It corresponds to the EPOLLHUP and POLLHUP events.

Interruption events are only supported on the following platforms:

  • epoll
  • poll
  • IOCP
  • Event Ports

On other platforms, this function is a no-op.

source

pub fn with_interrupt(self) -> Self

Add interruption events to this interest.

This usually indicates that the file descriptor or socket has been closed. It corresponds to the EPOLLHUP and POLLHUP events.

Interruption events are only supported on the following platforms:

  • epoll
  • poll
  • IOCP
  • Event Ports

On other platforms, this function is a no-op.

source

pub fn set_priority(&mut self, active: bool)

Add priority events to this interest.

This indicates that there is urgent data to read. It corresponds to the EPOLLPRI and POLLPRI events.

Priority events are only supported on the following platforms:

  • epoll
  • poll
  • IOCP
  • Event Ports

On other platforms, this function is a no-op.

source

pub fn with_priority(self) -> Self

Add priority events to this interest.

This indicates that there is urgent data to read. It corresponds to the EPOLLPRI and POLLPRI events.

Priority events are only supported on the following platforms:

  • epoll
  • poll
  • IOCP
  • Event Ports

On other platforms, this function is a no-op.

source

pub fn is_interrupt(&self) -> bool

Tell if this event is the result of an interrupt notification.

This usually indicates that the file descriptor or socket has been closed. It corresponds to the EPOLLHUP and POLLHUP events.

Interruption events are only supported on the following platforms:

  • epoll
  • poll
  • IOCP
  • Event Ports

On other platforms, this always returns false.

source

pub fn is_priority(&self) -> bool

Tell if this event is the result of a priority notification.

This indicates that there is urgent data to read. It corresponds to the EPOLLPRI and POLLPRI events.

Priority events are only supported on the following platforms:

  • epoll
  • poll
  • IOCP
  • Event Ports

On other platforms, this always returns false.

source

pub fn is_connect_failed(&self) -> Option<bool>

👎Deprecated since 3.4.0: use is_err in combination of is_hup instead, see documentation for is_err

Tells if this event is the result of a connection failure.

This function checks if a TCP connection has failed. It corresponds to the EPOLLERR or EPOLLHUP event in Linux and CONNECT_FAILED event in Windows IOCP.

§Examples
use std::{io, net};
// Assuming polling and socket2 are included as dependencies in Cargo.toml
use polling::Event;
use socket2::Type;

fn main() -> io::Result<()> {
    let socket = socket2::Socket::new(socket2::Domain::IPV4, Type::STREAM, None)?;
    let poller = polling::Poller::new()?;
    unsafe {
        poller.add(&socket, Event::new(0, true, true))?;
    }
    let addr = net::SocketAddr::new(net::Ipv4Addr::LOCALHOST.into(), 8080);
    socket.set_nonblocking(true)?;
    let _ = socket.connect(&addr.into());

    let mut events = polling::Events::new();

    events.clear();
    poller.wait(&mut events, None)?;

    let event = events.iter().next();

    let event = match event {
        Some(event) => event,
        None => {
            println!("no event");
            return Ok(());
        },
    };

    println!("event: {:?}", event);
    if event
        .is_connect_failed()
        .unwrap_or_default()
    {
        println!("connect failed");
    }

    Ok(())
}
§Returns

Returns Some(true) if the connection has failed, Some(false) if the connection has not failed, or None if the platform does not support detecting this condition.

source

pub fn is_err(&self) -> Option<bool>

Tells if this event is the result of a connection failure.

This function checks if an error exist, particularly useful in detecting if TCP connection failed. It corresponds to the EPOLLERR event in Linux and CONNECT_FAILED event in Windows IOCP.

§Caveats

In epoll, a TCP connection failure is indicated by EPOLLERR + EPOLLHUP, though just EPOLLERR is enough to indicate a connection failure. EPOLLHUP may happen when we haven’t event called connect on the socket, but it is still a valid event to check for.

Returns Some(true) if the connection has failed, Some(false) if there is no error, or None if the platform does not support detecting this condition.

source

pub fn clear_extra(&mut self)

Remove any extra information from this event.

source

pub fn with_no_extra(self) -> Self

Get a version of this event with no extra information.

This is useful for comparing events with ==.

Trait Implementations§

source§

impl Clone for Event

source§

fn clone(&self) -> Event

Returns a copy of the value. Read more
1.0.0 · source§

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source. Read more
source§

impl Debug for Event

source§

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

Formats the value using the given formatter. Read more
source§

impl PartialEq for Event

source§

fn eq(&self, other: &Event) -> bool

This method tests for self and other values to be equal, and is used by ==.
1.0.0 · source§

fn ne(&self, other: &Rhs) -> bool

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.
source§

impl Copy for Event

source§

impl Eq for Event

source§

impl StructuralPartialEq for Event

Auto Trait Implementations§

§

impl Freeze for Event

§

impl RefUnwindSafe for Event

§

impl Send for Event

§

impl Sync for Event

§

impl Unpin for Event

§

impl UnwindSafe for Event

Blanket Implementations§

source§

impl<T> Any for T
where T: 'static + ?Sized,

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
source§

impl<T> Borrow<T> for T
where T: ?Sized,

source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
source§

impl<T> CloneToUninit for T
where T: Copy,

source§

unsafe fn clone_to_uninit(&self, dst: *mut T)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dst. Read more
source§

impl<T> CloneToUninit for T
where T: Clone,

source§

default unsafe fn clone_to_uninit(&self, dst: *mut T)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dst. Read more
source§

impl<T> From<T> for T

source§

fn from(t: T) -> T

Returns the argument unchanged.

source§

impl<T> Instrument for T

source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
source§

impl<T, U> Into<U> for T
where U: From<T>,

source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

source§

impl<T> ToOwned for T
where T: Clone,

§

type Owned = T

The resulting type after obtaining ownership.
source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

§

type Error = Infallible

The type returned in the event of a conversion error.
source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
source§

impl<T> WithSubscriber for T

source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more