orengine 0.7.0-alpha.1

Optimized ring engine for Rust. It is a lighter and faster asynchronous library than tokio-rs, async-std, may, and even smol.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42

use crate::io::sys::RawFd;
use crate::io::Socket;
use socket2::{Domain, Protocol, Type};
use std::net::SocketAddr;

/// Creates a new socket based on the given `SocketAddr` and `Type` (either stream or datagram).
/// This function determines the appropriate domain (IPv4 or IPv6) based on the provided address,
/// and creates a socket accordingly.
///
/// This is an asynchronous function that returns a raw file descriptor representing the new socket.
#[inline(always)]
pub(crate) async fn new_socket(
    addr: &SocketAddr,
    socket_type: Type,
    protocol: Protocol,
) -> std::io::Result<RawFd> {
    match addr {
        SocketAddr::V4(_) => Socket::new(Domain::IPV4, socket_type, protocol).await,

        SocketAddr::V6(_) => Socket::new(Domain::IPV6, socket_type, protocol).await,
    }
}

/// Creates a new TCP socket based on the provided `SocketAddr`.
/// This is a convenience wrapper around [`new_socket`]
/// that sets the socket type to `Type::STREAM` (TCP).
///
/// This function determines whether to create an IPv4 or IPv6 socket based on the address type.
#[inline(always)]
pub(crate) async fn new_tcp_socket(addr: &SocketAddr) -> std::io::Result<RawFd> {
    new_socket(addr, Type::STREAM, Protocol::TCP).await
}

/// Creates a new UDP socket based on the provided `SocketAddr`.
/// This is a convenience wrapper around [`new_socket`]
/// that sets the socket type to `Type::DGRAM` (UDP).
///
/// This function determines whether to create an IPv4 or IPv6 socket based on the address type.
#[inline(always)]
pub(crate) async fn new_udp_socket(addr: &SocketAddr) -> std::io::Result<RawFd> {
    new_socket(addr, Type::DGRAM, Protocol::UDP).await
}