monocoque-rs 0.1.0

High-performance ZeroMQ-compatible messaging runtime built on io_uring
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

//! Common utilities for ZeroMQ socket implementations.

use std::io;

/// Convert a channel send error to an IO error.
///
/// Used by all socket types to convert flume channel errors
/// into standard IO errors with BrokenPipe kind.
pub fn channel_to_io_error<T, E>(result: Result<T, E>) -> io::Result<T>
where
    E: std::error::Error + Send + Sync + 'static,
{
    result.map_err(|e| io::Error::new(io::ErrorKind::BrokenPipe, e))
}

/// Parse a TCP endpoint string into a `SocketAddr`.
///
/// Accepts both URL form (`tcp://127.0.0.1:5555`) and bare form (`127.0.0.1:5555`).
pub(super) fn parse_tcp_endpoint(endpoint: &str) -> io::Result<std::net::SocketAddr> {
    if let Ok(monocoque_core::endpoint::Endpoint::Tcp(addr)) =
        monocoque_core::endpoint::Endpoint::parse(endpoint)
    {
        Ok(addr)
    } else {
        endpoint
            .parse::<std::net::SocketAddr>()
            .map_err(|e| io::Error::new(io::ErrorKind::InvalidInput, e))
    }
}