Skip to content

Commit cc104b1

Browse files
committed
use generic Atomic type where possible
in core/alloc/std only for now, and ignoring test files
1 parent e65783d commit cc104b1

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

76 files changed

+253
-258
lines changed

library/alloc/src/lib.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -125,6 +125,7 @@
125125
#![feature(extend_one_unchecked)]
126126
#![feature(fmt_internals)]
127127
#![feature(fn_traits)]
128+
#![feature(generic_atomic)]
128129
#![feature(hasher_prefixfree_extras)]
129130
#![feature(inplace_iteration)]
130131
#![feature(iter_advance_by)]

library/alloc/src/sync.rs

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -24,8 +24,8 @@ use core::pin::{Pin, PinCoerceUnsized};
2424
use core::ptr::{self, NonNull};
2525
#[cfg(not(no_global_oom_handling))]
2626
use core::slice::from_raw_parts_mut;
27-
use core::sync::atomic;
2827
use core::sync::atomic::Ordering::{Acquire, Relaxed, Release};
28+
use core::sync::atomic::{self, Atomic};
2929
use core::{borrow, fmt, hint};
3030

3131
#[cfg(not(no_global_oom_handling))]
@@ -346,12 +346,12 @@ impl<T: ?Sized, A: Allocator> fmt::Debug for Weak<T, A> {
346346
// inner types.
347347
#[repr(C)]
348348
struct ArcInner<T: ?Sized> {
349-
strong: atomic::AtomicUsize,
349+
strong: Atomic<usize>,
350350

351351
// the value usize::MAX acts as a sentinel for temporarily "locking" the
352352
// ability to upgrade weak pointers or downgrade strong ones; this is used
353353
// to avoid races in `make_mut` and `get_mut`.
354-
weak: atomic::AtomicUsize,
354+
weak: Atomic<usize>,
355355

356356
data: T,
357357
}
@@ -2706,8 +2706,8 @@ impl<T, A: Allocator> Weak<T, A> {
27062706
/// Helper type to allow accessing the reference counts without
27072707
/// making any assertions about the data field.
27082708
struct WeakInner<'a> {
2709-
weak: &'a atomic::AtomicUsize,
2710-
strong: &'a atomic::AtomicUsize,
2709+
weak: &'a Atomic<usize>,
2710+
strong: &'a Atomic<usize>,
27112711
}
27122712

27132713
impl<T: ?Sized> Weak<T> {

library/core/src/sync/atomic.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -482,7 +482,7 @@ pub enum Ordering {
482482
note = "the `new` function is now preferred",
483483
suggestion = "AtomicBool::new(false)"
484484
)]
485-
pub const ATOMIC_BOOL_INIT: AtomicBool = AtomicBool::new(false);
485+
pub const ATOMIC_BOOL_INIT: Atomic<bool> = AtomicBool::new(false);
486486

487487
#[cfg(target_has_atomic_load_store = "8")]
488488
impl AtomicBool {
@@ -3347,7 +3347,7 @@ macro_rules! atomic_int_ptr_sized {
33473347
note = "the `new` function is now preferred",
33483348
suggestion = "AtomicIsize::new(0)",
33493349
)]
3350-
pub const ATOMIC_ISIZE_INIT: AtomicIsize = AtomicIsize::new(0);
3350+
pub const ATOMIC_ISIZE_INIT: Atomic<isize> = AtomicIsize::new(0);
33513351

33523352
/// An [`AtomicUsize`] initialized to `0`.
33533353
#[cfg(target_pointer_width = $target_pointer_width)]
@@ -3357,7 +3357,7 @@ macro_rules! atomic_int_ptr_sized {
33573357
note = "the `new` function is now preferred",
33583358
suggestion = "AtomicUsize::new(0)",
33593359
)]
3360-
pub const ATOMIC_USIZE_INIT: AtomicUsize = AtomicUsize::new(0);
3360+
pub const ATOMIC_USIZE_INIT: Atomic<usize> = AtomicUsize::new(0);
33613361
)* };
33623362
}
33633363

library/std/src/alloc.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -57,7 +57,7 @@
5757
#![stable(feature = "alloc_module", since = "1.28.0")]
5858

5959
use core::ptr::NonNull;
60-
use core::sync::atomic::{AtomicPtr, Ordering};
60+
use core::sync::atomic::{Atomic, AtomicPtr, Ordering};
6161
use core::{hint, mem, ptr};
6262

6363
#[stable(feature = "alloc_module", since = "1.28.0")]
@@ -287,7 +287,7 @@ unsafe impl Allocator for System {
287287
}
288288
}
289289

290-
static HOOK: AtomicPtr<()> = AtomicPtr::new(ptr::null_mut());
290+
static HOOK: Atomic<*mut ()> = AtomicPtr::new(ptr::null_mut());
291291

292292
/// Registers a custom allocation error hook, replacing any that was previously registered.
293293
///

library/std/src/backtrace.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -91,8 +91,8 @@ mod tests;
9191
use crate::backtrace_rs::{self, BytesOrWideString};
9292
use crate::ffi::c_void;
9393
use crate::panic::UnwindSafe;
94-
use crate::sync::atomic::AtomicU8;
9594
use crate::sync::atomic::Ordering::Relaxed;
95+
use crate::sync::atomic::{Atomic, AtomicU8};
9696
use crate::sync::LazyLock;
9797
use crate::sys::backtrace::{lock, output_filename, set_image_base};
9898
use crate::{env, fmt};
@@ -254,7 +254,7 @@ impl Backtrace {
254254
// Cache the result of reading the environment variables to make
255255
// backtrace captures speedy, because otherwise reading environment
256256
// variables every time can be somewhat slow.
257-
static ENABLED: AtomicU8 = AtomicU8::new(0);
257+
static ENABLED: Atomic<u8> = AtomicU8::new(0);
258258
match ENABLED.load(Relaxed) {
259259
0 => {}
260260
1 => return false,

library/std/src/io/stdio.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@ use crate::io::{
1111
self, BorrowedCursor, BufReader, IoSlice, IoSliceMut, LineWriter, Lines, SpecReadByte,
1212
};
1313
use crate::panic::{RefUnwindSafe, UnwindSafe};
14-
use crate::sync::atomic::{AtomicBool, Ordering};
14+
use crate::sync::atomic::{Atomic, AtomicBool, Ordering};
1515
use crate::sync::{Arc, Mutex, MutexGuard, OnceLock, ReentrantLock, ReentrantLockGuard};
1616
use crate::sys::stdio;
1717
use crate::thread::AccessError;
@@ -37,7 +37,7 @@ thread_local! {
3737
/// have a consistent order between set_output_capture and print_to *within
3838
/// the same thread*. Within the same thread, things always have a perfectly
3939
/// consistent order. So Ordering::Relaxed is fine.
40-
static OUTPUT_CAPTURE_USED: AtomicBool = AtomicBool::new(false);
40+
static OUTPUT_CAPTURE_USED: Atomic<bool> = AtomicBool::new(false);
4141

4242
/// A handle to a raw instance of the standard input stream of this process.
4343
///

library/std/src/lib.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -334,6 +334,7 @@
334334
#![feature(float_minimum_maximum)]
335335
#![feature(float_next_up_down)]
336336
#![feature(fmt_internals)]
337+
#![feature(generic_atomic)]
337338
#![feature(hasher_prefixfree_extras)]
338339
#![feature(hashmap_internals)]
339340
#![feature(ip)]

library/std/src/os/uefi/env.rs

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -4,13 +4,13 @@
44

55
use crate::ffi::c_void;
66
use crate::ptr::NonNull;
7-
use crate::sync::atomic::{AtomicBool, AtomicPtr, Ordering};
7+
use crate::sync::atomic::{Atomic, AtomicBool, AtomicPtr, Ordering};
88

9-
static SYSTEM_TABLE: AtomicPtr<c_void> = AtomicPtr::new(crate::ptr::null_mut());
10-
static IMAGE_HANDLE: AtomicPtr<c_void> = AtomicPtr::new(crate::ptr::null_mut());
9+
static SYSTEM_TABLE: Atomic<*mut c_void> = AtomicPtr::new(crate::ptr::null_mut());
10+
static IMAGE_HANDLE: Atomic<*mut c_void> = AtomicPtr::new(crate::ptr::null_mut());
1111
// Flag to check if BootServices are still valid.
1212
// Start with assuming that they are not available
13-
static BOOT_SERVICES_FLAG: AtomicBool = AtomicBool::new(false);
13+
static BOOT_SERVICES_FLAG: Atomic<bool> = AtomicBool::new(false);
1414

1515
/// Initializes the global System Table and Image Handle pointers.
1616
///

library/std/src/os/xous/services.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
use core::sync::atomic::{AtomicU32, Ordering};
1+
use core::sync::atomic::{Atomic, AtomicU32, Ordering};
22

33
use crate::os::xous::ffi::Connection;
44

@@ -106,7 +106,7 @@ pub fn try_connect(name: &str) -> Option<Connection> {
106106
ns::try_connect_with_name(name)
107107
}
108108

109-
static NAME_SERVER_CONNECTION: AtomicU32 = AtomicU32::new(0);
109+
static NAME_SERVER_CONNECTION: Atomic<u32> = AtomicU32::new(0);
110110

111111
/// Returns a `Connection` to the name server. If the name server has not been started,
112112
/// then this call will block until the name server has been started. The `Connection`

library/std/src/os/xous/services/dns.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@ impl Into<usize> for DnsLendMut {
1717
/// Returns a `Connection` to the DNS lookup server. This server is used for
1818
/// querying domain name values.
1919
pub(crate) fn dns_server() -> Connection {
20-
static DNS_CONNECTION: AtomicU32 = AtomicU32::new(0);
20+
static DNS_CONNECTION: Atomic<u32> = AtomicU32::new(0);
2121
let cid = DNS_CONNECTION.load(Ordering::Relaxed);
2222
if cid != 0 {
2323
return cid.into();

0 commit comments

Comments
 (0)