Enum UdpStreamParallelism 

pub enum UdpStreamParallelism {
    Auto,
    Specific(NonZeroUsize),
}

Determines how many parallel readers or writer sockets should be bound in ConnectedUdpStream.

Each UDP socket is bound with SO_REUSEADDR and SO_REUSEPORT to facilitate parallel processing of send and/or receive operations.

NOTE: This is a Linux-specific optimization, and it will have no effect on other systems.

• If some Specific value n > 0 is given, the ConnectedUdpStream will bind n sockets.
• If Auto is given, the number of sockets bound by ConnectedUdpStream is determined by std::thread::available_parallelism.

The default is Specific(1).

Always use into_num_tasks or split_evenly_with to determine the correct number of sockets to spawn.

Variants

Auto

Bind as many sender or receiver sockets as given by std::thread::available_parallelism.

Specific(NonZeroUsize)

Bind a specific number of sender or receiver sockets.

Implementations

impl UdpStreamParallelism

pub fn split_evenly_with(self, other: UdpStreamParallelism) -> (usize, usize)

Returns the number of sockets for this and the other instance when they evenly split the available CPU parallelism.

pub fn into_num_tasks(self) -> usize

Calculates the actual number of tasks for this instance.

The returned value is never more than the maximum available CPU parallelism.

Trait Implementations

impl Clone for UdpStreamParallelism

fn clone(&self) -> UdpStreamParallelism

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for UdpStreamParallelism

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

Formats the value using the given formatter.

impl Default for UdpStreamParallelism

fn default() -> Self

Returns the “default value” for a type.

impl From<Option<usize>> for UdpStreamParallelism

fn from(value: Option<usize>) -> Self

Converts to this type from the input type.

impl From<usize> for UdpStreamParallelism

fn from(value: usize) -> Self

Converts to this type from the input type.

impl PartialEq for UdpStreamParallelism

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Copy for UdpStreamParallelism

impl Eq for UdpStreamParallelism

impl StructuralPartialEq for UdpStreamParallelism