Struct Context 

pub struct Context<'a, 'd> { /* private fields */ }

Implementations

impl<'a, 'd> Context<'a, 'd>

pub fn reborrow(&mut self) -> Context<'_, 'd>

pub fn region_token(&mut self) -> &mut Token<'d>

pub fn driver_ref(&self) -> Reference<'d>

pub fn timer(&self) -> &'d Timer<'d>

pub fn deadline_now(&self) -> Deadline<'d>

pub fn turn_now(&self) -> Instant

Trait Implementations

impl<'d> Bootstrap<'d> for Context<'_, 'd>

fn bind_listener_slot( &mut self, addr: SocketAddr, backlog: i32, config: &ListenerConfig, ) -> Result<(Descriptor<'d>, SocketAddr)>

fn bind_datagram_slot( &mut self, addr: SocketAddr, ) -> Result<(DatagramDescriptor<'d>, SocketAddr)>

impl Buffers for Context<'_, '_>

fn buffer_len(&self) -> usize

fn buffer_count(&self) -> usize

fn accept_capacity(&self) -> usize

fn outbound_capacity(&self) -> usize

impl<'d> Control<'d> for Context<'_, 'd>

where Uring: Socket,

fn reserve_route(&mut self, id: u8) -> bool

fn release_route(&mut self, id: u8)

fn submit_socket<Tag: Tag>( &mut self, flights: &Slots<'d, Tag>, request: Bound<'d, Tag, SocketSlot<'d>>, socket: StreamSpec, ) -> Result<CreatingSocket<'d>, SubmitError>

fn submit_tuning<Tag: Tag>( &mut self, request: Bound<'d, Tag, Descriptor<'d>>, options: StreamOptions, ) -> Result<Tuning<'d>, Descriptor<'d>>

fn cancel_tuning( &mut self, pending: TuningPending<'d>, ) -> Result<TuningPending<'d, Cancelled>, (TuningPending<'d>, SubmitError)>

fn cancel_connection( &mut self, pending: ConnectionPending<'d>, ) -> Result<ConnectionPending<'d, Cancelled>, (ConnectionPending<'d>, SubmitError)>

impl<'d> Files<'d> for Context<'_, 'd>

fn close(&mut self, fd: impl Into<Descriptor<'d>>)

fn reserve_outbound<const ID: u8>( &mut self, count: u32, ) -> Result<OutboundReservation<'d, ID>>

impl<'d> Poll<'d> for Context<'_, 'd>

fn commit(&mut self, work: Reactor<'_, 'd>) -> Result<Commit>

fn wait( &mut self, work: Reactor<'_, 'd>, timeout: Option<Duration>, ) -> Result<()>

impl<'d> Source<'d> for Context<'_, 'd>

impl<'d> Submit<'d> for Context<'_, 'd>

where Uring: Source,

fn cancel<Tag: Tag>( &mut self, flight: &mut Flight<'d>, target: Operation<'d, Tag>, ) -> Result<(), SubmitError>