Struct UnixSocket 

pub struct UnixSocket { /* private fields */ }

A Unix domain socket.

Implementations

impl UnixSocket

pub fn new(transport: impl Into<Transport>) -> Self

Create a new Unix socket with the given transport.

Trait Implementations

impl Configurable for UnixSocket

fn get_option_inner(&self, opt: &mut GetSocketOption<'_>) -> NetResult<bool>

Get a socket option, returns true if the socket supports the option.

fn set_option_inner(&self, opt: SetSocketOption<'_>) -> NetResult<bool>

Set a socket option, returns true if the socket supports the option.

fn get_option(&self, opt: GetSocketOption<'_>) -> NetResult

Get a socket option. Dispatches to Configurable::get_option_inner.

fn set_option(&self, opt: SetSocketOption<'_>) -> NetResult

Set a socket option. Dispatches to Configurable::set_option_inner.

impl From<Box<UnixSocket>> for Socket

fn from(v: Box<UnixSocket>) -> Socket

Converts to this type from the input type.

impl From<UnixSocket> for Socket

fn from(socket: UnixSocket) -> Self

Converts to this type from the input type.

impl Pollable for UnixSocket

fn poll(&self) -> IoEvents

Polls for I/O events.

unsafe fn register_shared( &self, sink: &mut dyn SharedRegistrationSink, events: IoEvents, )

Registers a shared readiness observer.

unsafe fn register_exclusive( &self, sink: &mut dyn ExclusiveRegistrationSink, events: IoEvents, )

Registers a consumer that may sleep until readiness changes.

impl SocketOps for UnixSocket

fn bind(&self, local_addr: SocketAddrEx) -> NetResult

Binds an unbound socket to the given address and port.

fn start_connect(&self, remote_addr: SocketAddrEx) -> NetResult<ConnectStatus>

Starts a connection without waiting for asynchronous completion.

fn listen(&self, _backlog: usize) -> NetResult

Starts listening on the bound address and port.

fn is_listening(&self) -> bool

Returns whether this socket currently accepts incoming connections.

fn try_accept(&self) -> NetResult<Socket>

Attempts to accept one connection without parking the caller.

fn try_send( &self, src: impl Read + IoBuf, options: &mut SendOptions, ) -> NetResult<usize>

Attempts to send data without parking the caller.

fn try_recv( &self, dst: impl Write, options: &mut RecvOptions<'_>, ) -> NetResult<usize>

Attempts to receive data without parking the caller.

fn local_addr(&self) -> NetResult<SocketAddrEx>

Get the local endpoint of the socket.

fn peer_addr(&self) -> NetResult<SocketAddrEx>

Get the remote endpoint of the socket.

fn shutdown(&self, how: Shutdown) -> NetResult

Shutdown the socket, closing the connection.

fn connect_status(&self) -> NetResult<ConnectStatus>

Checks a previously started asynchronous connection.

fn recv_available(&self) -> NetResult<usize>

Returns the number of bytes that can be read without blocking.

fn send_wait_policy( &self, extra_nonblocking: bool, ) -> NetResult<SocketWaitPolicy>

Returns the send wait policy without acquiring scheduler ownership.

fn recv_wait_policy( &self, extra_nonblocking: bool, ) -> NetResult<SocketWaitPolicy>

Returns the receive wait policy without acquiring scheduler ownership.

impl TryInto<Box<UnixSocket>> for Socket

type Error = &'static str

The type returned in the event of a conversion error.

fn try_into( self, ) -> Result<Box<UnixSocket>, <Self as TryInto<Box<UnixSocket>>>::Error>

Performs the conversion.