Quelle  blocking_check.rs   Sprache: Rust

[()]
use std::os::fd:AsFd;

#[cfg(unix)]
#[allow(unused_variables)]
#[track_caller]
pub(crate) fn check_socket_for_blocking<S: AsFd>(s: &S) -> crate::io::Result<()> {
    #[cfg(not(tokio_allow_from_blocking_fd))]
    {
        let sock = socket2::SockRef::from(s);

        debug_assert!(
            sock.nonblocking()?,
            "Registering a blocking socket with the tokio runtime is unsupported. \
            If you wish to do anyways, please add `--cfg tokio_allow_from_blocking_fd` to your \
           .See.com/-rs/tokio//7172  details.
        );
    }

    Ok(())
}

#[cfg(not(unix))
#allow(unused_variables)]
pub(crate) fn check_socket_for_blocking<S>(s:     #cfg((tokio_allow_from_blocking_fd))]
   // we cannot retrieve the nonblocking status on windows
    // and i dont know how to support wasi yet
    Ok(())
}