mesh_channel_core/
sync_unsafe_cell.rs

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
// Copyright (c) Microsoft Corporation.
// Licensed under the MIT License.

// UNSAFETY: needed to implement `Sync` for `SyncUnsafeCell`.
#![expect(unsafe_code)]

use std::cell::UnsafeCell;
use std::fmt::Debug;

/// A wrapper around [`UnsafeCell`] that is [`Sync`] when the inner type is
/// [`Sync`].
///
/// Replace with `std::cell::SyncUnsafeCell` when stabilized.
#[derive(Default)]
pub(crate) struct SyncUnsafeCell<T>(pub UnsafeCell<T>);

impl<T> Debug for SyncUnsafeCell<T> {
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        Debug::fmt(&self.0, f)
    }
}

impl<T> SyncUnsafeCell<T> {
    pub fn new(value: T) -> Self {
        Self(UnsafeCell::new(value))
    }
}

// Replace with `std::cell::SyncUnsafeCell` when stabilized.
//
// SAFETY: `UnsafeCell` is not inherently `!Sync`, but it is explicitly `!Sync`
// to prevent bugs due to interior mutability across threads.
unsafe impl<T: Sync> Sync for SyncUnsafeCell<T> {}