Rollup merge of #105120 - solid-rs:patch/kmc-solid/maintainance, r=thomcc
kmc-solid: `std::sys` code maintenance Includes a set of changes to fix the [`*-kmc-solid_*`](https://doc.rust-lang.org/nightly/rustc/platform-support/kmc-solid.html) Tier 3 targets and make some other improvements. - Address `fuzzy_provenance_casts` by using `expose_addr` and `from_exposed_addr` for pointer-integer casts - Add a stub implementation of `is_terminal` (#98070) - Address `unused_imports` and `unused_unsafe` - Stop doing `Box::from_raw(&*(x: Box<T>) as *const T as *mut T)`
This commit is contained in:
commit
cd936cc812
@ -71,7 +71,7 @@ pub unsafe fn wait(&self, mutex: &Mutex) {
|
||||
}
|
||||
}
|
||||
|
||||
unsafe { mutex.lock() };
|
||||
mutex.lock();
|
||||
}
|
||||
|
||||
pub unsafe fn wait_timeout(&self, mutex: &Mutex, dur: Duration) -> bool {
|
||||
@ -109,7 +109,7 @@ pub unsafe fn wait_timeout(&self, mutex: &Mutex, dur: Duration) -> bool {
|
||||
// we woke up because of `notify_*`.
|
||||
let success = self.waiters.with_locked(|waiters| unsafe { !waiters.remove(waiter) });
|
||||
|
||||
unsafe { mutex.lock() };
|
||||
mutex.lock();
|
||||
success
|
||||
}
|
||||
}
|
||||
|
@ -72,7 +72,7 @@ fn drop(&mut self) {
|
||||
impl<'a> MutexGuard<'a> {
|
||||
#[inline]
|
||||
pub(super) fn lock(x: &'a Mutex) -> Self {
|
||||
unsafe { x.lock() };
|
||||
x.lock();
|
||||
Self(x)
|
||||
}
|
||||
}
|
||||
|
@ -11,18 +11,25 @@
|
||||
ffi::CStr,
|
||||
hint, io,
|
||||
mem::ManuallyDrop,
|
||||
ptr::NonNull,
|
||||
sync::atomic::{AtomicUsize, Ordering},
|
||||
sys::thread_local_dtor::run_dtors,
|
||||
time::Duration,
|
||||
};
|
||||
|
||||
pub struct Thread {
|
||||
inner: ManuallyDrop<Box<ThreadInner>>,
|
||||
p_inner: NonNull<ThreadInner>,
|
||||
|
||||
/// The ID of the underlying task.
|
||||
task: abi::ID,
|
||||
}
|
||||
|
||||
// Safety: There's nothing in `Thread` that ties it to the original creator. It
|
||||
// can be dropped by any threads.
|
||||
unsafe impl Send for Thread {}
|
||||
// Safety: `Thread` provides no methods that take `&self`.
|
||||
unsafe impl Sync for Thread {}
|
||||
|
||||
/// State data shared between a parent thread and child thread. It's dropped on
|
||||
/// a transition to one of the final states.
|
||||
struct ThreadInner {
|
||||
@ -90,8 +97,9 @@ pub unsafe fn new(stack: usize, p: Box<dyn FnOnce()>) -> io::Result<Thread> {
|
||||
});
|
||||
|
||||
unsafe extern "C" fn trampoline(exinf: isize) {
|
||||
let p_inner: *mut ThreadInner = crate::ptr::from_exposed_addr_mut(exinf as usize);
|
||||
// Safety: `ThreadInner` is alive at this point
|
||||
let inner = unsafe { &*(exinf as *const ThreadInner) };
|
||||
let inner = unsafe { &*p_inner };
|
||||
|
||||
// Safety: Since `trampoline` is called only once for each
|
||||
// `ThreadInner` and only `trampoline` touches `start`,
|
||||
@ -119,13 +127,13 @@ pub unsafe fn new(stack: usize, p: Box<dyn FnOnce()>) -> io::Result<Thread> {
|
||||
// No one will ever join, so we'll ask the collector task to
|
||||
// delete the task.
|
||||
|
||||
// In this case, `inner`'s ownership has been moved to us,
|
||||
// And we are responsible for dropping it. The acquire
|
||||
// In this case, `*p_inner`'s ownership has been moved to
|
||||
// us, and we are responsible for dropping it. The acquire
|
||||
// ordering is not necessary because the parent thread made
|
||||
// no memory access needing synchronization since the call
|
||||
// to `acre_tsk`.
|
||||
// Safety: See above.
|
||||
let _ = unsafe { Box::from_raw(inner as *const _ as *mut ThreadInner) };
|
||||
let _ = unsafe { Box::from_raw(p_inner) };
|
||||
|
||||
// Safety: There are no pinned references to the stack
|
||||
unsafe { terminate_and_delete_current_task() };
|
||||
@ -162,13 +170,14 @@ pub unsafe fn new(stack: usize, p: Box<dyn FnOnce()>) -> io::Result<Thread> {
|
||||
}
|
||||
}
|
||||
|
||||
let inner_ptr = (&*inner) as *const ThreadInner;
|
||||
// Safety: `Box::into_raw` returns a non-null pointer
|
||||
let p_inner = unsafe { NonNull::new_unchecked(Box::into_raw(inner)) };
|
||||
|
||||
let new_task = ItronError::err_if_negative(unsafe {
|
||||
abi::acre_tsk(&abi::T_CTSK {
|
||||
// Activate this task immediately
|
||||
tskatr: abi::TA_ACT,
|
||||
exinf: inner_ptr as abi::EXINF,
|
||||
exinf: p_inner.as_ptr().expose_addr() as abi::EXINF,
|
||||
// The entry point
|
||||
task: Some(trampoline),
|
||||
// Inherit the calling task's base priority
|
||||
@ -180,7 +189,7 @@ pub unsafe fn new(stack: usize, p: Box<dyn FnOnce()>) -> io::Result<Thread> {
|
||||
})
|
||||
.map_err(|e| e.as_io_error())?;
|
||||
|
||||
Ok(Self { inner: ManuallyDrop::new(inner), task: new_task })
|
||||
Ok(Self { p_inner, task: new_task })
|
||||
}
|
||||
|
||||
pub fn yield_now() {
|
||||
@ -197,8 +206,9 @@ pub fn sleep(dur: Duration) {
|
||||
}
|
||||
}
|
||||
|
||||
pub fn join(mut self) {
|
||||
let inner = &*self.inner;
|
||||
pub fn join(self) {
|
||||
// Safety: `ThreadInner` is alive at this point
|
||||
let inner = unsafe { self.p_inner.as_ref() };
|
||||
// Get the current task ID. Panicking here would cause a resource leak,
|
||||
// so just abort on failure.
|
||||
let current_task = task::current_task_id_aborting();
|
||||
@ -243,8 +253,8 @@ pub fn join(mut self) {
|
||||
unsafe { terminate_and_delete_task(self.task) };
|
||||
|
||||
// In either case, we are responsible for dropping `inner`.
|
||||
// Safety: The contents of `self.inner` will not be accessed hereafter
|
||||
let _inner = unsafe { ManuallyDrop::take(&mut self.inner) };
|
||||
// Safety: The contents of `*p_inner` will not be accessed hereafter
|
||||
let _inner = unsafe { Box::from_raw(self.p_inner.as_ptr()) };
|
||||
|
||||
// Skip the destructor (because it would attempt to detach the thread)
|
||||
crate::mem::forget(self);
|
||||
@ -253,13 +263,16 @@ pub fn join(mut self) {
|
||||
|
||||
impl Drop for Thread {
|
||||
fn drop(&mut self) {
|
||||
// Safety: `ThreadInner` is alive at this point
|
||||
let inner = unsafe { self.p_inner.as_ref() };
|
||||
|
||||
// Detach the thread.
|
||||
match self.inner.lifecycle.swap(LIFECYCLE_DETACHED_OR_JOINED, Ordering::Acquire) {
|
||||
match inner.lifecycle.swap(LIFECYCLE_DETACHED_OR_JOINED, Ordering::Acquire) {
|
||||
LIFECYCLE_INIT => {
|
||||
// [INIT → DETACHED]
|
||||
// When the time comes, the child will figure out that no
|
||||
// one will ever join it.
|
||||
// The ownership of `self.inner` is moved to the child thread.
|
||||
// The ownership of `*p_inner` is moved to the child thread.
|
||||
// However, the release ordering is not necessary because we
|
||||
// made no memory access needing synchronization since the call
|
||||
// to `acre_tsk`.
|
||||
@ -278,10 +291,9 @@ fn drop(&mut self) {
|
||||
// delete by entering the `FINISHED` state.
|
||||
unsafe { terminate_and_delete_task(self.task) };
|
||||
|
||||
// Wwe are responsible for dropping `inner`.
|
||||
// Safety: The contents of `self.inner` will not be accessed
|
||||
// hereafter
|
||||
unsafe { ManuallyDrop::drop(&mut self.inner) };
|
||||
// Wwe are responsible for dropping `*p_inner`.
|
||||
// Safety: The contents of `*p_inner` will not be accessed hereafter
|
||||
let _ = unsafe { Box::from_raw(self.p_inner.as_ptr()) };
|
||||
}
|
||||
_ => unsafe { hint::unreachable_unchecked() },
|
||||
}
|
||||
|
@ -75,3 +75,7 @@ pub fn as_mut_slice(&mut self) -> &mut [u8] {
|
||||
unsafe { slice::from_raw_parts_mut(self.vec.iov_base as *mut u8, self.vec.iov_len) }
|
||||
}
|
||||
}
|
||||
|
||||
pub fn is_terminal<T>(_: &T) -> bool {
|
||||
false
|
||||
}
|
||||
|
@ -1,7 +1,6 @@
|
||||
use super::unsupported;
|
||||
use crate::convert::TryFrom;
|
||||
use crate::error::Error as StdError;
|
||||
use crate::ffi::{CStr, CString, OsStr, OsString};
|
||||
use crate::ffi::{CStr, OsStr, OsString};
|
||||
use crate::fmt;
|
||||
use crate::io;
|
||||
use crate::os::{
|
||||
|
Loading…
Reference in New Issue
Block a user