#![allow(missing_docs, nonstandard_style)]

use crate::ffi::CStr;
use crate::io::ErrorKind;

pub use self::rand::hashmap_random_keys;

#[cfg(not(target_os = "espidf"))]
#[macro_use]
pub mod weak;

pub mod alloc;
pub mod android;
pub mod args;
#[path = "../unix/cmath.rs"]
pub mod cmath;
pub mod env;
pub mod fd;
pub mod fs;
pub mod futex;
pub mod io;
#[cfg(any(target_os = "linux", target_os = "android"))]
pub mod kernel_copy;
#[cfg(target_os = "l4re")]
mod l4re;
pub mod locks;
pub mod memchr;
#[cfg(not(target_os = "l4re"))]
pub mod net;
#[cfg(target_os = "l4re")]
pub use self::l4re::net;
pub mod os;
pub mod os_str;
pub mod path;
pub mod pipe;
pub mod process;
pub mod rand;
pub mod stack_overflow;
pub mod stdio;
pub mod thread;
pub mod thread_local_dtor;
pub mod thread_local_key;
pub mod thread_parking;
pub mod time;

#[cfg(target_os = "espidf")]
pub fn init(argc: isize, argv: *const *const u8, _sigpipe: u8) {}

#[cfg(not(target_os = "espidf"))]
// SAFETY: 在运行时初始化期间只能调用一次。
// NOTE: 这不能保证运行，例如在外部调用 Rust 代码时。
// 有关 `sigpipe` 的文档，请参见 `library/std/src/rt.rs` 中的 `fn init()`。
pub unsafe fn init(argc: isize, argv: *const *const u8, sigpipe: u8) {
    // 标准流可能会在应用程序启动时关闭。
    // 为防止 `std::io::{stdin，stdout，stderr}` 对象使用稍后打开的其他不相关文件资源，我们在关闭标准流后会重新打开它们。
    //
    sanitize_standard_fds();

    // 默认情况下，某些平台会在否则会传递 EPIPE 错误的情况下发送 *信号*。
    // 此运行时未安装 SIGPIPE 处理程序，导致它终止了程序，这不正是我们想要的！
    //
    //
    // 因此，为了防止出现此问题，我们将 SIGPIPE 设置为在程序启动时忽略。
    // 在 `fn main()` 上方添加 `#[unix_sigpipe = "..."]` 以更改此行为。
    //
    //
    reset_sigpipe(sigpipe);

    stack_overflow::init();
    args::init(argc, argv);

    // 通常，`thread::spawn` 会调用 `Thread::set_name`，但由于该线程已经存在，我们必须自己调用它。
    // 我们只在 macos 上这样做，因为一些类似 unix 的操作系统，例如 Linux 共享主线程的 process-id 和 thread-id，因此重命名主线程将重命名进程，我们只想在我们已经启用的平台上启用它测试。
    //
    //
    //
    if cfg!(target_os = "macos") {
        thread::Thread::set_name(&CStr::from_bytes_with_nul_unchecked(b"main\0"));
    }

    unsafe fn sanitize_standard_fds() {
        // 带有 poll() 的系统的单个 syscall 的快速路径
        #[cfg(not(any(
            miri,
            target_os = "emscripten",
            target_os = "fuchsia",
            target_os = "vxworks",
            // 达尔文 (Darwin) 的民意调查并未为封闭的 fds 设置 POLLNVAL。
            target_os = "macos",
            target_os = "ios",
            target_os = "watchos",
            target_os = "redox",
            target_os = "l4re",
            target_os = "horizon",
            target_os = "vita",
        )))]
        'poll: {
            use crate::sys::os::errno;
            #[cfg(not(all(target_os = "linux", target_env = "gnu")))]
            use libc::open as open64;
            #[cfg(all(target_os = "linux", target_env = "gnu"))]
            use libc::open64;
            let pfds: &mut [_] = &mut [
                libc::pollfd { fd: 0, events: 0, revents: 0 },
                libc::pollfd { fd: 1, events: 0, revents: 0 },
                libc::pollfd { fd: 2, events: 0, revents: 0 },
            ];

            while libc::poll(pfds.as_mut_ptr(), 3, 0) == -1 {
                match errno() {
                    libc::EINTR => continue,
                    libc::EINVAL | libc::EAGAIN | libc::ENOMEM => {
                        // RLIMIT_NOFILE 或临时分配失败可能会阻止使用 poll()，回退到 fcntl
                        //
                        break 'poll;
                    }
                    _ => libc::abort(),
                }
            }
            for pfd in pfds {
                if pfd.revents & libc::POLLNVAL == 0 {
                    continue;
                }
                if open64("/dev/null\0".as_ptr().cast(), libc::O_RDWR, 0) == -1 {
                    // 如果流已关闭，但未能重新打开它，则中止该进程。
                    // 否则，我们不会在相应的 Rust 对象 Stdin、Stdout 或 Stderr 上保持操作的安全性。
                    //
                    //
                    libc::abort();
                }
            }
            return;
        }

        // 如果轮询不可用或受 RLIMIT_NOFILE 限制，则回退
        #[cfg(not(any(
            // 标准 fds 始终在 Miri 中可用。
            miri,
            target_os = "emscripten",
            target_os = "fuchsia",
            target_os = "vxworks",
            target_os = "l4re",
            target_os = "horizon",
            target_os = "vita",
        )))]
        {
            use crate::sys::os::errno;
            #[cfg(not(all(target_os = "linux", target_env = "gnu")))]
            use libc::open as open64;
            #[cfg(all(target_os = "linux", target_env = "gnu"))]
            use libc::open64;
            for fd in 0..3 {
                if libc::fcntl(fd, libc::F_GETFD) == -1 && errno() == libc::EBADF {
                    if open64("/dev/null\0".as_ptr().cast(), libc::O_RDWR, 0) == -1 {
                        // 如果流已关闭，但未能重新打开它，则中止该进程。
                        // 否则，我们不会在相应的 Rust 对象 Stdin、Stdout 或 Stderr 上保持操作的安全性。
                        //
                        //
                        libc::abort();
                    }
                }
            }
        }
    }

    unsafe fn reset_sigpipe(#[allow(unused_variables)] sigpipe: u8) {
        #[cfg(not(any(
            target_os = "emscripten",
            target_os = "fuchsia",
            target_os = "horizon",
            target_os = "vita"
        )))]
        {
            // 我们不想将其作为公共类型添加到 std，也不想从编译器 `include!` 文件 (例如，这会破坏 Miri 和 xargo)，因此我们选择从 `compiler/rustc_session/src/config/sigpipe.rs` 复制这些常量。
            //
            // 有关文档，请参见其他文件。注意: 确保它们保持同步!
            //
            //
            //
            mod sigpipe {
                pub const DEFAULT: u8 = 0;
                pub const INHERIT: u8 = 1;
                pub const SIG_IGN: u8 = 2;
                pub const SIG_DFL: u8 = 3;
            }

            let (sigpipe_attr_specified, handler) = match sigpipe {
                sigpipe::DEFAULT => (false, Some(libc::SIG_IGN)),
                sigpipe::INHERIT => (true, None),
                sigpipe::SIG_IGN => (true, Some(libc::SIG_IGN)),
                sigpipe::SIG_DFL => (true, Some(libc::SIG_DFL)),
                _ => unreachable!(),
            };
            if sigpipe_attr_specified {
                UNIX_SIGPIPE_ATTR_SPECIFIED.store(true, crate::sync::atomic::Ordering::Relaxed);
            }
            if let Some(handler) = handler {
                rtassert!(signal(libc::SIGPIPE, handler) != libc::SIG_ERR);
            }
        }
    }
}

// 这是在 reset_sigpipe 中设置的 (最多一次)。
#[cfg(not(any(
    target_os = "espidf",
    target_os = "emscripten",
    target_os = "fuchsia",
    target_os = "horizon",
    target_os = "vita"
)))]
static UNIX_SIGPIPE_ATTR_SPECIFIED: crate::sync::atomic::AtomicBool =
    crate::sync::atomic::AtomicBool::new(false);

#[cfg(not(any(
    target_os = "espidf",
    target_os = "emscripten",
    target_os = "fuchsia",
    target_os = "horizon",
    target_os = "vita",
)))]
pub(crate) fn unix_sigpipe_attr_specified() -> bool {
    UNIX_SIGPIPE_ATTR_SPECIFIED.load(crate::sync::atomic::Ordering::Relaxed)
}

// SAFETY: 在运行时清理期间只能调用一次。
// NOTE: 这不能保证运行，例如当程序中止时。
pub unsafe fn cleanup() {
    stack_overflow::cleanup();
}

#[cfg(target_os = "android")]
pub use crate::sys::android::signal;
#[cfg(not(target_os = "android"))]
pub use libc::signal;

pub fn decode_error_kind(errno: i32) -> ErrorKind {
    use ErrorKind::*;
    match errno as libc::c_int {
        libc::E2BIG => ArgumentListTooLong,
        libc::EADDRINUSE => AddrInUse,
        libc::EADDRNOTAVAIL => AddrNotAvailable,
        libc::EBUSY => ResourceBusy,
        libc::ECONNABORTED => ConnectionAborted,
        libc::ECONNREFUSED => ConnectionRefused,
        libc::ECONNRESET => ConnectionReset,
        libc::EDEADLK => Deadlock,
        libc::EDQUOT => FilesystemQuotaExceeded,
        libc::EEXIST => AlreadyExists,
        libc::EFBIG => FileTooLarge,
        libc::EHOSTUNREACH => HostUnreachable,
        libc::EINTR => Interrupted,
        libc::EINVAL => InvalidInput,
        libc::EISDIR => IsADirectory,
        libc::ELOOP => FilesystemLoop,
        libc::ENOENT => NotFound,
        libc::ENOMEM => OutOfMemory,
        libc::ENOSPC => StorageFull,
        libc::ENOSYS => Unsupported,
        libc::EMLINK => TooManyLinks,
        libc::ENAMETOOLONG => InvalidFilename,
        libc::ENETDOWN => NetworkDown,
        libc::ENETUNREACH => NetworkUnreachable,
        libc::ENOTCONN => NotConnected,
        libc::ENOTDIR => NotADirectory,
        libc::ENOTEMPTY => DirectoryNotEmpty,
        libc::EPIPE => BrokenPipe,
        libc::EROFS => ReadOnlyFilesystem,
        libc::ESPIPE => NotSeekable,
        libc::ESTALE => StaleNetworkFileHandle,
        libc::ETIMEDOUT => TimedOut,
        libc::ETXTBSY => ExecutableFileBusy,
        libc::EXDEV => CrossesDevices,

        libc::EACCES | libc::EPERM => PermissionDenied,

        // 这两个常量在某些系统上可以具有相同的值，但在其他系统上可以具有不同的值，因此我们不能使用 match 子句
        //
        //
        x if x == libc::EAGAIN || x == libc::EWOULDBLOCK => WouldBlock,

        _ => Uncategorized,
    }
}

#[doc(hidden)]
pub trait IsMinusOne {
    fn is_minus_one(&self) -> bool;
}

macro_rules! impl_is_minus_one {
    ($($t:ident)*) => ($(impl IsMinusOne for $t {
        fn is_minus_one(&self) -> bool {
            *self == -1
        }
    })*)
}

impl_is_minus_one! { i8 i16 i32 i64 isize }

pub fn cvt<T: IsMinusOne>(t: T) -> crate::io::Result<T> {
    if t.is_minus_one() { Err(crate::io::Error::last_os_error()) } else { Ok(t) }
}

pub fn cvt_r<T, F>(mut f: F) -> crate::io::Result<T>
where
    T: IsMinusOne,
    F: FnMut() -> T,
{
    loop {
        match cvt(f()) {
            Err(ref e) if e.kind() == ErrorKind::Interrupted => {}
            other => return other,
        }
    }
}

#[allow(dead_code)] // 并非在所有平台上都使用。
pub fn cvt_nz(error: libc::c_int) -> crate::io::Result<()> {
    if error == 0 { Ok(()) } else { Err(crate::io::Error::from_raw_os_error(error)) }
}

// libc::abort () 将运行 SIGABRT 处理程序。这很好，因为任何安装 SIGABRT 处理程序的人都必须期望它在非常糟糕的情况下运行 (例如，malloc 崩溃)。
//
// 当前 glibc 的 abort() 函数解除对 SIGABRT 的阻塞，引发 SIGABRT，清除 SIGABRT 处理程序并再次引发它，然后开始发挥创意。
//
// 有关进一步讨论，请参见 `intrinsics::abort()` 和 `process::abort()` 的公共文档。
//
// 关于 libc::abort () 是否刷新标准输入输出流存在混淆。
// ISO C 99 (7.14.1.1p5) 要求 libc::abort () 是异步信号安全的，因此刷新流至少非常困难，如果不是完全不可能的话。
//
// 但是，某些版本的 POSIX (例如 IEEE Std 1003.1-2001) 需要中止来执行此操作。在 1003.1-2004 中，这是确定的。
//
// glibc 的实现在 glibc 提交之前不安全地进行了刷新
// Florian Weimer 的 91e7cf982d01 `abort: Do not flush stdio streams [BZ #15436]`。根据 glibc 的新闻：
//
//    abort 函数立即中止该过程，而不刷新标准输入输出流。以前的 glibc 版本用于刷新流，导致死锁和进一步的数据损坏。
//    由于断言失败，此更改还会影响进程中止。
//
// 这是对问题的准确描述。
// 对于非平凡使用 C 标准输入输出的程序，唯一的解决方案是固定的 libc - 一个不会尝试在中止中刷新 - 因为即使是 libc 内部错误，以及由 C 产生的断言失败，也会通过 abort()。
//
//
// 在具有旧的 buggy、libcs 的系统上，对多线程 C 程序的影响可能很严重。Rust 的严重程度要低得多，因为 Rust stdlib 不使用 libc 标准输入输出缓冲。
// 在典型的 Rust 程序中，不使用 C 标准输入输出，即使是 buggy libc::abort () 实际上也是安全的。
//
//
//
//
//
//
//
//
//
//
//
//
pub fn abort_internal() -> ! {
    unsafe { libc::abort() }
}

cfg_if::cfg_if! {
    if #[cfg(target_os = "android")] {
        #[link(name = "dl", kind = "static", modifiers = "-bundle",
            cfg(target_feature = "crt-static"))]
        #[link(name = "dl", cfg(not(target_feature = "crt-static")))]
        #[link(name = "log", cfg(not(target_feature = "crt-static")))]
        extern "C" {}
    } else if #[cfg(target_os = "freebsd")] {
        #[link(name = "execinfo")]
        #[link(name = "pthread")]
        extern "C" {}
    } else if #[cfg(target_os = "netbsd")] {
        #[link(name = "pthread")]
        #[link(name = "rt")]
        extern "C" {}
    } else if #[cfg(any(target_os = "dragonfly", target_os = "openbsd"))] {
        #[link(name = "pthread")]
        extern "C" {}
    } else if #[cfg(target_os = "solaris")] {
        #[link(name = "socket")]
        #[link(name = "posix4")]
        #[link(name = "pthread")]
        #[link(name = "resolv")]
        extern "C" {}
    } else if #[cfg(target_os = "illumos")] {
        #[link(name = "socket")]
        #[link(name = "posix4")]
        #[link(name = "pthread")]
        #[link(name = "resolv")]
        #[link(name = "nsl")]
        // 对 (malloc-compatible) 分配器使用 libumem
        #[link(name = "umem")]
        extern "C" {}
    } else if #[cfg(target_os = "macos")] {
        #[link(name = "System")]
        extern "C" {}
    } else if #[cfg(any(target_os = "ios", target_os = "watchos"))] {
        #[link(name = "System")]
        #[link(name = "objc")]
        #[link(name = "Security", kind = "framework")]
        #[link(name = "Foundation", kind = "framework")]
        extern "C" {}
    } else if #[cfg(target_os = "fuchsia")] {
        #[link(name = "zircon")]
        #[link(name = "fdio")]
        extern "C" {}
    } else if #[cfg(all(target_os = "linux", target_env = "uclibc"))] {
        #[link(name = "dl")]
        extern "C" {}
    }
}

#[cfg(any(target_os = "espidf", target_os = "horizon", target_os = "vita"))]
mod unsupported {
    use crate::io;

    pub fn unsupported<T>() -> io::Result<T> {
        Err(unsupported_err())
    }

    pub fn unsupported_err() -> io::Error {
        io::const_io_error!(io::ErrorKind::Unsupported, "operation not supported on this platform",)
    }
}