mirror of
https://github.com/tokio-rs/tokio.git
synced 2026-08-19 00:00:09 +02:00
chore: use just std instead of ::std in paths (#2049)
This commit is contained in:
committed by
Carl Lerche
parent
f0006006ed
commit
dcfa895b51
@@ -139,7 +139,7 @@ impl<T> Inner<T> {
|
||||
} else {
|
||||
// Spin... but investigate a better strategy
|
||||
|
||||
::std::thread::yield_now();
|
||||
std::thread::yield_now();
|
||||
cx.waker().wake_by_ref();
|
||||
|
||||
Poll::Pending
|
||||
|
||||
@@ -125,10 +125,7 @@ pub(crate) mod impl_solaris {
|
||||
fn ucred_geteuid(cred: *const ucred_t) -> super::uid_t;
|
||||
fn ucred_getegid(cred: *const ucred_t) -> super::gid_t;
|
||||
|
||||
fn getpeerucred(
|
||||
fd: ::std::os::raw::c_int,
|
||||
cred: *mut *mut ucred_t,
|
||||
) -> ::std::os::raw::c_int;
|
||||
fn getpeerucred(fd: std::os::raw::c_int, cred: *mut *mut ucred_t) -> std::os::raw::c_int;
|
||||
}
|
||||
|
||||
pub(crate) fn get_peer_cred(sock: &UnixStream) -> io::Result<super::UCred> {
|
||||
|
||||
@@ -63,7 +63,7 @@ pub(crate) fn exit<F: FnOnce() -> R, R>(f: F) -> R {
|
||||
|
||||
let reset = Reset;
|
||||
let ret = f();
|
||||
::std::mem::forget(reset);
|
||||
std::mem::forget(reset);
|
||||
|
||||
ENTERED.with(|c| {
|
||||
assert!(!c.get(), "closure claimed permanent executor");
|
||||
|
||||
@@ -294,7 +294,7 @@ enum Kind {
|
||||
}
|
||||
|
||||
/// After thread starts / before thread stops
|
||||
type Callback = ::std::sync::Arc<dyn Fn() + Send + Sync>;
|
||||
type Callback = std::sync::Arc<dyn Fn() + Send + Sync>;
|
||||
|
||||
impl Runtime {
|
||||
/// Create a new runtime instance with default configuration values.
|
||||
|
||||
@@ -13,7 +13,7 @@ impl<T> fmt::Display for SendError<T> {
|
||||
}
|
||||
}
|
||||
|
||||
impl<T: fmt::Debug> ::std::error::Error for SendError<T> {}
|
||||
impl<T: fmt::Debug> std::error::Error for SendError<T> {}
|
||||
|
||||
// ===== TrySendError =====
|
||||
|
||||
|
||||
@@ -57,7 +57,7 @@ pub mod error {
|
||||
}
|
||||
}
|
||||
|
||||
impl ::std::error::Error for RecvError {}
|
||||
impl std::error::Error for RecvError {}
|
||||
|
||||
// ===== impl TryRecvError =====
|
||||
|
||||
@@ -70,7 +70,7 @@ pub mod error {
|
||||
}
|
||||
}
|
||||
|
||||
impl ::std::error::Error for TryRecvError {}
|
||||
impl std::error::Error for TryRecvError {}
|
||||
}
|
||||
|
||||
use self::error::*;
|
||||
|
||||
@@ -826,7 +826,7 @@ impl fmt::Display for AcquireError {
|
||||
}
|
||||
}
|
||||
|
||||
impl ::std::error::Error for AcquireError {}
|
||||
impl std::error::Error for AcquireError {}
|
||||
|
||||
// ===== impl TryAcquireError =====
|
||||
|
||||
@@ -858,7 +858,7 @@ impl fmt::Display for TryAcquireError {
|
||||
}
|
||||
}
|
||||
|
||||
impl ::std::error::Error for TryAcquireError {}
|
||||
impl std::error::Error for TryAcquireError {}
|
||||
|
||||
// ===== impl Waiter =====
|
||||
|
||||
|
||||
@@ -117,7 +117,7 @@ pub mod error {
|
||||
}
|
||||
}
|
||||
|
||||
impl<T: fmt::Debug> ::std::error::Error for SendError<T> {}
|
||||
impl<T: fmt::Debug> std::error::Error for SendError<T> {}
|
||||
}
|
||||
|
||||
#[derive(Debug)]
|
||||
|
||||
@@ -535,7 +535,7 @@ rt_test! {
|
||||
|
||||
impl Drop for Boom {
|
||||
fn drop(&mut self) {
|
||||
assert!(::std::thread::panicking());
|
||||
assert!(std::thread::panicking());
|
||||
self.0.take().unwrap().send(()).unwrap();
|
||||
}
|
||||
}
|
||||
|
||||
@@ -1,7 +1,7 @@
|
||||
#![warn(rust_2018_idioms)]
|
||||
#![cfg(feature = "full")]
|
||||
|
||||
fn is_error<T: ::std::error::Error + Send + Sync>() {}
|
||||
fn is_error<T: std::error::Error + Send + Sync>() {}
|
||||
|
||||
#[test]
|
||||
fn mpsc_error_bound() {
|
||||
|
||||
Reference in New Issue
Block a user