Struct UdpSocket 

pub struct UdpSocket { /* private fields */ }

Available on crate feature net only.

A UDP socket.

UDP is “connectionless”, unlike TCP. Meaning, regardless of what address you’ve bound to, a UdpSocket is free to communicate with many different remotes. There are basically two main ways to use UdpSocket:

• one to many: bind and use send_to and recv_from to communicate with many different addresses
• one to one: connect and associate with a single address, using send and recv to communicate only with that remote address

Examples

Bind and connect a pair of sockets and send a packet:

use std::net::SocketAddr;

use compio_net::UdpSocket;

let first_addr: SocketAddr = "127.0.0.1:0".parse().unwrap();
let second_addr: SocketAddr = "127.0.0.1:0".parse().unwrap();

// bind sockets
let mut socket = UdpSocket::bind(first_addr).await.unwrap();
let first_addr = socket.local_addr().unwrap();
let mut other_socket = UdpSocket::bind(second_addr).await.unwrap();
let second_addr = other_socket.local_addr().unwrap();

// connect sockets
socket.connect(second_addr).await.unwrap();
other_socket.connect(first_addr).await.unwrap();

let buf = Vec::with_capacity(12);

// write data
socket.send("Hello world!").await.unwrap();

// read data
let (n_bytes, buf) = other_socket.recv(buf).await.unwrap();

assert_eq!(n_bytes, buf.len());
assert_eq!(buf, b"Hello world!");

Send and receive packets without connecting:

use std::net::SocketAddr;

use compio_net::UdpSocket;
use socket2::SockAddr;

let first_addr: SocketAddr = "127.0.0.1:0".parse().unwrap();
let second_addr: SocketAddr = "127.0.0.1:0".parse().unwrap();

// bind sockets
let mut socket = UdpSocket::bind(first_addr).await.unwrap();
let first_addr = socket.local_addr().unwrap();
let mut other_socket = UdpSocket::bind(second_addr).await.unwrap();
let second_addr = other_socket.local_addr().unwrap();

let buf = Vec::with_capacity(32);

// write data
socket.send_to("hello world", second_addr).await.unwrap();

// read data
let ((n_bytes, addr), buf) = other_socket.recv_from(buf).await.unwrap();

assert_eq!(addr, first_addr);
assert_eq!(n_bytes, buf.len());
assert_eq!(buf, b"hello world");

Implementations

impl UdpSocket

pub async fn bind(addr: impl ToSocketAddrsAsync) -> Result<UdpSocket, Error>

Creates a new UDP socket and attempt to bind it to the addr provided.

pub async fn bind_with_options( addr: impl ToSocketAddrsAsync, opts: &SocketOpts, ) -> Result<UdpSocket, Error>

Creates a new UDP socket with SocketOpts and attempt to bind it to the addr provided.

pub async fn connect(&self, addr: impl ToSocketAddrsAsync) -> Result<(), Error>

Connects this UDP socket to a remote address, allowing the send and recv to be used to send data and also applies filters to only receive data from the specified address.

Note that usually, a successful connect call does not specify that there is a remote server listening on the port, rather, such an error would only be detected after the first send.

pub fn from_std(socket: UdpSocket) -> Result<UdpSocket, Error>

Creates new UdpSocket from a std::net::UdpSocket.

pub fn close(self) -> impl Future<Output = Result<(), Error>>

Close the socket. If the returned future is dropped before polling, the socket won’t be closed.

pub fn peer_addr(&self) -> Result<SocketAddr, Error>

Returns the socket address of the remote peer this socket was connected to.

Examples

use std::net::{Ipv4Addr, SocketAddr, SocketAddrV4};

use compio_net::UdpSocket;
use socket2::SockAddr;

let socket = UdpSocket::bind("127.0.0.1:34254")
    .await
    .expect("couldn't bind to address");
socket
    .connect("192.168.0.1:41203")
    .await
    .expect("couldn't connect to address");
assert_eq!(
    socket.peer_addr().unwrap(),
    SocketAddr::V4(SocketAddrV4::new(Ipv4Addr::new(192, 168, 0, 1), 41203))
);

pub fn local_addr(&self) -> Result<SocketAddr, Error>

Returns the local address that this socket is bound to.

Example

use std::net::SocketAddr;

use compio_net::UdpSocket;
use socket2::SockAddr;

let addr: SocketAddr = "127.0.0.1:8080".parse().unwrap();
let sock = UdpSocket::bind(&addr).await.unwrap();
// the address the socket is bound to
let local_addr = sock.local_addr().unwrap();
assert_eq!(local_addr, addr);

pub async fn recv<T>(&self, buffer: T) -> BufResult<usize, T>

where T: IoBufMut,

Receives a packet of data from the socket into the buffer, returning the original buffer and quantity of data received.

pub async fn recv_vectored<T>(&self, buffer: T) -> BufResult<usize, T>

where T: IoVectoredBufMut,

Receives a packet of data from the socket into the buffer, returning the original buffer and quantity of data received.

pub async fn recv_managed<'a>( &self, buffer_pool: &'a BufferPool, len: usize, ) -> Result<BorrowedBuffer<'a>, Error>

Read some bytes from this source with BufferPool and return a BorrowedBuffer.

If len == 0, will use BufferPool inner buffer size as the max len, if len > 0, min(len, inner buffer size) will be the read max len

pub async fn send<T>(&self, buffer: T) -> BufResult<usize, T>

where T: IoBuf,

Sends some data to the socket from the buffer, returning the original buffer and quantity of data sent.

pub async fn send_vectored<T>(&self, buffer: T) -> BufResult<usize, T>

where T: IoVectoredBuf,

Sends some data to the socket from the buffer, returning the original buffer and quantity of data sent.

pub async fn recv_from<T>(&self, buffer: T) -> BufResult<(usize, SocketAddr), T>

where T: IoBufMut,

Receives a single datagram message on the socket. On success, returns the number of bytes received and the origin.

pub async fn recv_from_vectored<T>( &self, buffer: T, ) -> BufResult<(usize, SocketAddr), T>

where T: IoVectoredBufMut,

Receives a single datagram message on the socket. On success, returns the number of bytes received and the origin.

pub async fn recv_msg<T, C>( &self, buffer: T, control: C, ) -> BufResult<(usize, usize, SocketAddr), (T, C)>

where T: IoBufMut, C: IoBufMut,

Receives a single datagram message and ancillary data on the socket. On success, returns the number of bytes received and the origin.

pub async fn recv_msg_vectored<T, C>( &self, buffer: T, control: C, ) -> BufResult<(usize, usize, SocketAddr), (T, C)>

where T: IoVectoredBufMut, C: IoBufMut,

Receives a single datagram message and ancillary data on the socket. On success, returns the number of bytes received and the origin.

pub async fn send_to<T>( &self, buffer: T, addr: impl ToSocketAddrsAsync, ) -> BufResult<usize, T>

where T: IoBuf,

Sends data on the socket to the given address. On success, returns the number of bytes sent.

pub async fn send_to_vectored<T>( &self, buffer: T, addr: impl ToSocketAddrsAsync, ) -> BufResult<usize, T>

where T: IoVectoredBuf,

Sends data on the socket to the given address. On success, returns the number of bytes sent.

pub async fn send_msg<T, C>( &self, buffer: T, control: C, addr: impl ToSocketAddrsAsync, ) -> BufResult<usize, (T, C)>

where T: IoBuf, C: IoBuf,

Sends data on the socket to the given address accompanied by ancillary data. On success, returns the number of bytes sent.

pub async fn send_msg_vectored<T, C>( &self, buffer: T, control: C, addr: impl ToSocketAddrsAsync, ) -> BufResult<usize, (T, C)>

where T: IoVectoredBuf, C: IoBuf,

Sends data on the socket to the given address accompanied by ancillary data. On success, returns the number of bytes sent.

pub unsafe fn get_socket_option<T>( &self, level: i32, name: i32, ) -> Result<T, Error>

where T: Copy,

Gets a socket option.

Safety

The caller must ensure T is the correct type for level and name.

pub unsafe fn set_socket_option<T>( &self, level: i32, name: i32, value: &T, ) -> Result<(), Error>

where T: Copy,

Sets a socket option.

Safety

The caller must ensure T is the correct type for level and name.

Trait Implementations

impl AsFd for UdpSocket

Available on Unix only.

fn as_fd(&self) -> BorrowedFd<'_>

Borrows the file descriptor.

impl AsRawFd for UdpSocket

fn as_raw_fd(&self) -> i32

Extracts the raw file descriptor.

impl Clone for UdpSocket

fn clone(&self) -> UdpSocket

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for UdpSocket

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

Formats the value using the given formatter.

impl FromRawFd for UdpSocket

Available on Unix only.

unsafe fn from_raw_fd(fd: i32) -> UdpSocket

Constructs a new instance of Self from the given raw file descriptor.

impl ToSharedFd<Socket> for UdpSocket

fn to_shared_fd(&self) -> SharedFd<Socket>

Return a cloned SharedFd.