mirror/rtic
1
0
Fork 0
mirror of https://github.com/rtic-rs/rtic.git synced 2025-12-19 06:15:45 +01:00
Code Issues Projects Releases Packages Wiki Activity

rtic-sync: re-wrap UnsafeCell instead

Browse source
This commit is contained in:
datdenkikniet 2025-03-23 12:34:59 +01:00 • committed by Emil Fresk
parent bef2e1b9f0
commit d7c6947f4e
2 changed files with 57 additions and 31 deletions
Download patch file Download diff file Expand all files Collapse all files

7
rtic-sync/src/channel.rs
View file

@ -104,9 +104,7 @@ impl<T, const N: usize> Channel<T, N> {
/// Split the queue into a `Sender`/`Receiver` pair.
pub fn split(&mut self) -> (Sender<'_, T, N>, Receiver<'_, T, N>) {
// SAFETY: we have exclusive access to `self`.
let freeq = self.freeq.get_mut();
let freeq = unsafe { freeq.deref() };
let freeq = self.freeq.as_mut();
// Fill free queue
for idx in 0..N as u8 {
@ -123,8 +121,7 @@ impl<T, const N: usize> Channel<T, N> {
debug_assert!(freeq.is_full());
// There is now 1 sender
// SAFETY: we have exclusive access to `self`.
unsafe { *self.num_senders.get_mut().deref() = 1 };
*self.num_senders.as_mut() = 1;
(Sender(self), Receiver(self))
}