Struct ZxioBackedSocket 

pub struct ZxioBackedSocket { /* private fields */ }

A socket backed by an underlying Zircon I/O object.

Implementations

impl ZxioBackedSocket

pub fn new( locked: &mut Locked<FileOpsCore>, current_task: &CurrentTask, domain: SocketDomain, socket_type: SocketType, protocol: SocketProtocol, ) -> Result<ZxioBackedSocket, Errno>

pub fn new_with_zxio(current_task: &CurrentTask, zxio: Zxio) -> ZxioBackedSocket

pub fn get_socket_cookie(&self) -> Result<u64, Errno>

Trait Implementations

impl SocketOps for ZxioBackedSocket

fn get_socket_info( &self, ) -> Result<(SocketDomain, SocketType, SocketProtocol), Errno>

Returns the domain, type and protocol of the socket. This is only used for socket that are build without previous knowledge of this information, and can be ignored if all sockets are build with it.

fn connect( &self, locked: &mut Locked<FileOpsCore>, socket: &SocketHandle, current_task: &CurrentTask, peer: SocketPeer, ) -> Result<(), Errno>

Connect the socket to the listening peer. On success a new socket is created and added to the accept queue.

fn listen( &self, _locked: &mut Locked<FileOpsCore>, _socket: &Socket, backlog: i32, _credentials: ucred, ) -> Result<(), Errno>

Start listening at the bound address for connect calls.

fn accept( &self, _locked: &mut Locked<FileOpsCore>, socket: &Socket, current_task: &CurrentTask, ) -> Result<SocketHandle, Errno>

Returns the eariest socket on the accept queue of this listening socket. Returns EAGAIN if the queue is empty.

fn bind( &self, locked: &mut Locked<FileOpsCore>, socket: &Socket, current_task: &CurrentTask, socket_address: SocketAddress, ) -> Result<(), Errno>

Binds this socket to a socket_address.

fn read( &self, locked: &mut Locked<FileOpsCore>, socket: &Socket, current_task: &CurrentTask, data: &mut dyn OutputBuffer, flags: SocketMessageFlags, ) -> Result<MessageReadInfo, Errno>

Reads the specified number of bytes from the socket, if possible.

fn write( &self, locked: &mut Locked<FileOpsCore>, socket: &Socket, current_task: &CurrentTask, data: &mut dyn InputBuffer, dest_address: &mut Option<SocketAddress>, ancillary_data: &mut Vec<AncillaryData>, ) -> Result<usize, Errno>

Writes the data in the provided user buffers to this socket.

fn wait_async( &self, _locked: &mut Locked<FileOpsCore>, _socket: &Socket, _current_task: &CurrentTask, waiter: &Waiter, events: FdEvents, handler: EventHandler, ) -> WaitCanceler

Queues an asynchronous wait for the specified events on the waiter. Note that no wait occurs until a wait functions is called on the waiter.

fn query_events( &self, _locked: &mut Locked<FileOpsCore>, _socket: &Socket, _current_task: &CurrentTask, ) -> Result<FdEvents, Errno>

Return the events that are currently active on the socket.

fn shutdown( &self, _locked: &mut Locked<FileOpsCore>, _socket: &Socket, how: SocketShutdownFlags, ) -> Result<(), Errno>

Shuts down this socket according to how, preventing any future reads and/or writes.

fn close( &self, locked: &mut Locked<FileOpsCore>, current_task: &CurrentTask, socket: &Socket, )

Close this socket.

fn getsockname( &self, _locked: &mut Locked<FileOpsCore>, socket: &Socket, ) -> Result<SocketAddress, Errno>

Returns the name of this socket.

fn getpeername( &self, _locked: &mut Locked<FileOpsCore>, _socket: &Socket, ) -> Result<SocketAddress, Errno>

Returns the name of the peer of this socket, if such a peer exists.

fn setsockopt( &self, _locked: &mut Locked<FileOpsCore>, _socket: &Socket, current_task: &CurrentTask, level: u32, optname: u32, optval: SockOptValue, ) -> Result<(), Errno>

Sets socket-specific options.

fn getsockopt( &self, _locked: &mut Locked<FileOpsCore>, _socket: &Socket, _current_task: &CurrentTask, level: u32, optname: u32, optlen: u32, ) -> Result<Vec<u8>, Errno>

Retrieves socket-specific options.

fn to_handle( &self, _socket: &Socket, _current_task: &CurrentTask, ) -> Result<Option<NullableHandle>, Errno>

Return a handle that allows access to this file descritor through the zxio protocols.

fn ioctl( &self, locked: &mut Locked<Unlocked>, _socket: &Socket, file: &FileObject, current_task: &CurrentTask, request: u32, arg: SyscallArg, ) -> Result<SyscallResult, Errno>

Implements ioctl.