don't reexport atomic::ordering via rustc_data_structures, use std import

This commit is contained in:
klensy 2024-01-02 22:36:01 +03:00
parent 5cb2e7dfc3
commit 56173611d6
5 changed files with 13 additions and 19 deletions

View File

@ -56,9 +56,6 @@
pub use parallel::scope; pub use parallel::scope;
pub use parallel::{join, par_for_each_in, par_map, parallel_guard, try_par_for_each_in}; pub use parallel::{join, par_for_each_in, par_map, parallel_guard, try_par_for_each_in};
pub use std::sync::atomic::Ordering;
pub use std::sync::atomic::Ordering::SeqCst;
pub use vec::{AppendOnlyIndexVec, AppendOnlyVec}; pub use vec::{AppendOnlyIndexVec, AppendOnlyVec};
mod vec; mod vec;
@ -67,8 +64,7 @@
pub use freeze::{FreezeLock, FreezeReadGuard, FreezeWriteGuard}; pub use freeze::{FreezeLock, FreezeReadGuard, FreezeWriteGuard};
mod mode { mod mode {
use super::Ordering; use std::sync::atomic::{AtomicU8, Ordering};
use std::sync::atomic::AtomicU8;
const UNINITIALIZED: u8 = 0; const UNINITIALIZED: u8 = 0;
const DYN_NOT_THREAD_SAFE: u8 = 1; const DYN_NOT_THREAD_SAFE: u8 = 1;
@ -113,6 +109,7 @@ pub fn set_dyn_thread_safe_mode(mode: bool) {
cfg(not(parallel_compiler)) => { cfg(not(parallel_compiler)) => {
use std::ops::Add; use std::ops::Add;
use std::cell::Cell; use std::cell::Cell;
use std::sync::atomic::Ordering;
pub unsafe auto trait Send {} pub unsafe auto trait Send {}
pub unsafe auto trait Sync {} pub unsafe auto trait Sync {}

View File

@ -25,7 +25,6 @@
use rustc_data_structures::profiling::{ use rustc_data_structures::profiling::{
get_resident_set_size, print_time_passes_entry, TimePassesFormat, get_resident_set_size, print_time_passes_entry, TimePassesFormat,
}; };
use rustc_data_structures::sync::SeqCst;
use rustc_errors::registry::{InvalidErrorCode, Registry}; use rustc_errors::registry::{InvalidErrorCode, Registry};
use rustc_errors::{markdown, ColorConfig}; use rustc_errors::{markdown, ColorConfig};
use rustc_errors::{DiagCtxt, ErrorGuaranteed, PResult}; use rustc_errors::{DiagCtxt, ErrorGuaranteed, PResult};
@ -476,7 +475,7 @@ fn run_compiler(
eprintln!( eprintln!(
"Fuel used by {}: {}", "Fuel used by {}: {}",
sess.opts.unstable_opts.print_fuel.as_ref().unwrap(), sess.opts.unstable_opts.print_fuel.as_ref().unwrap(),
sess.print_fuel.load(SeqCst) sess.print_fuel.load(Ordering::SeqCst)
); );
} }

View File

@ -69,7 +69,7 @@ impl QueryContext for QueryCtxt<'_> {
fn next_job_id(self) -> QueryJobId { fn next_job_id(self) -> QueryJobId {
QueryJobId( QueryJobId(
NonZeroU64::new( NonZeroU64::new(
self.query_system.jobs.fetch_add(1, rustc_data_structures::sync::Ordering::Relaxed), self.query_system.jobs.fetch_add(1, std::sync::atomic::Ordering::Relaxed),
) )
.unwrap(), .unwrap(),
) )

View File

@ -4,7 +4,7 @@
use rustc_data_structures::sharded::{self, Sharded}; use rustc_data_structures::sharded::{self, Sharded};
use rustc_data_structures::stable_hasher::{HashStable, StableHasher}; use rustc_data_structures::stable_hasher::{HashStable, StableHasher};
use rustc_data_structures::steal::Steal; use rustc_data_structures::steal::Steal;
use rustc_data_structures::sync::{AtomicU32, AtomicU64, Lock, Lrc, Ordering}; use rustc_data_structures::sync::{AtomicU32, AtomicU64, Lock, Lrc};
use rustc_data_structures::unord::UnordMap; use rustc_data_structures::unord::UnordMap;
use rustc_index::IndexVec; use rustc_index::IndexVec;
use rustc_serialize::opaque::{FileEncodeResult, FileEncoder}; use rustc_serialize::opaque::{FileEncodeResult, FileEncoder};
@ -13,7 +13,7 @@
use std::fmt::Debug; use std::fmt::Debug;
use std::hash::Hash; use std::hash::Hash;
use std::marker::PhantomData; use std::marker::PhantomData;
use std::sync::atomic::Ordering::Relaxed; use std::sync::atomic::Ordering;
use super::query::DepGraphQuery; use super::query::DepGraphQuery;
use super::serialized::{GraphEncoder, SerializedDepGraph, SerializedDepNodeIndex}; use super::serialized::{GraphEncoder, SerializedDepGraph, SerializedDepNodeIndex};
@ -476,7 +476,7 @@ pub fn read_index(&self, dep_node_index: DepNodeIndex) {
let task_deps = &mut *task_deps; let task_deps = &mut *task_deps;
if cfg!(debug_assertions) { if cfg!(debug_assertions) {
data.current.total_read_count.fetch_add(1, Relaxed); data.current.total_read_count.fetch_add(1, Ordering::Relaxed);
} }
// As long as we only have a low number of reads we can avoid doing a hash // As long as we only have a low number of reads we can avoid doing a hash
@ -506,7 +506,7 @@ pub fn read_index(&self, dep_node_index: DepNodeIndex) {
} }
} }
} else if cfg!(debug_assertions) { } else if cfg!(debug_assertions) {
data.current.total_duplicate_read_count.fetch_add(1, Relaxed); data.current.total_duplicate_read_count.fetch_add(1, Ordering::Relaxed);
} }
}) })
} }
@ -976,8 +976,8 @@ pub fn exec_cache_promotions<Tcx: DepContext>(&self, tcx: Tcx) {
pub fn print_incremental_info(&self) { pub fn print_incremental_info(&self) {
if let Some(data) = &self.data { if let Some(data) = &self.data {
data.current.encoder.borrow().print_incremental_info( data.current.encoder.borrow().print_incremental_info(
data.current.total_read_count.load(Relaxed), data.current.total_read_count.load(Ordering::Relaxed),
data.current.total_duplicate_read_count.load(Relaxed), data.current.total_duplicate_read_count.load(Ordering::Relaxed),
) )
} }
} }
@ -992,7 +992,7 @@ pub fn finish_encoding(&self, profiler: &SelfProfilerRef) -> FileEncodeResult {
pub(crate) fn next_virtual_depnode_index(&self) -> DepNodeIndex { pub(crate) fn next_virtual_depnode_index(&self) -> DepNodeIndex {
debug_assert!(self.data.is_none()); debug_assert!(self.data.is_none());
let index = self.virtual_dep_node_index.fetch_add(1, Relaxed); let index = self.virtual_dep_node_index.fetch_add(1, Ordering::Relaxed);
DepNodeIndex::from_u32(index) DepNodeIndex::from_u32(index)
} }
} }

View File

@ -14,9 +14,7 @@
use rustc_data_structures::fx::{FxHashMap, FxIndexSet}; use rustc_data_structures::fx::{FxHashMap, FxIndexSet};
use rustc_data_structures::jobserver::{self, Client}; use rustc_data_structures::jobserver::{self, Client};
use rustc_data_structures::profiling::{SelfProfiler, SelfProfilerRef}; use rustc_data_structures::profiling::{SelfProfiler, SelfProfilerRef};
use rustc_data_structures::sync::{ use rustc_data_structures::sync::{AtomicU64, DynSend, DynSync, Lock, Lrc, OneThread};
AtomicU64, DynSend, DynSync, Lock, Lrc, OneThread, Ordering::SeqCst,
};
use rustc_errors::annotate_snippet_emitter_writer::AnnotateSnippetEmitter; use rustc_errors::annotate_snippet_emitter_writer::AnnotateSnippetEmitter;
use rustc_errors::emitter::{DynEmitter, HumanEmitter, HumanReadableErrorType}; use rustc_errors::emitter::{DynEmitter, HumanEmitter, HumanReadableErrorType};
use rustc_errors::json::JsonEmitter; use rustc_errors::json::JsonEmitter;
@ -44,7 +42,7 @@
use std::ops::{Div, Mul}; use std::ops::{Div, Mul};
use std::path::{Path, PathBuf}; use std::path::{Path, PathBuf};
use std::str::FromStr; use std::str::FromStr;
use std::sync::{atomic::AtomicBool, Arc}; use std::sync::{atomic::AtomicBool, atomic::Ordering::SeqCst, Arc};
struct OptimizationFuel { struct OptimizationFuel {
/// If `-zfuel=crate=n` is specified, initially set to `n`, otherwise `0`. /// If `-zfuel=crate=n` is specified, initially set to `n`, otherwise `0`.