tokio-rs/tokio
1
0
Fork 0
mirror of https://github.com/tokio-rs/tokio.git synced 2026-08-28 00:00:11 +02:00
Code Issues Packages Projects Releases Wiki Activity

try lloyd's fix

Browse Source
This commit is contained in:
Noah Kennedy
2025-05-02 15:34:41 -05:00
parent ef9fcf999d
commit 855be676da
1 changed files with 4 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
tokio/src/runtime/task/raw.rs
+4 -7
View File
@@ -215,8 +215,8 @@ impl RawTask {
/// Safety: mutual exclusion is required to call this function. /// Safety: mutual exclusion is required to call this function.
pub(crate) fn poll(self) { pub(crate) fn poll(self) {
#[cfg(tokio_unstable)] #[cfg(tokio_unstable)]
self.trailer().hooks.with_mut(|ptr| unsafe { let _guard = self.trailer().hooks.with_mut(|ptr| unsafe {
let _guard = ptr.as_mut().and_then(|x| { ptr.as_mut().and_then(|x| {
x.as_mut().map(|x| { x.as_mut().map(|x| {
let _ = panic::catch_unwind(panic::AssertUnwindSafe(|| { let _ = panic::catch_unwind(panic::AssertUnwindSafe(|| {
x.before_poll(&mut BeforeTaskPollContext { x.before_poll(&mut BeforeTaskPollContext {
@@ -228,12 +228,9 @@ impl RawTask {
(&mut **x) as *mut (dyn TaskHookHarness + Send + Sync + 'static), (&mut **x) as *mut (dyn TaskHookHarness + Send + Sync + 'static),
)) ))
}) })
}); })
let vtable = self.header().vtable;
(vtable.poll)(self.ptr);
}); });
#[cfg(not(tokio_unstable))]
unsafe { unsafe {
let vtable = self.header().vtable; let vtable = self.header().vtable;
(vtable.poll)(self.ptr); (vtable.poll)(self.ptr);