mod task;
use std::{
ptr,
sync::{Arc, atomic, atomic::AtomicI64},
};
use dart_sys::{
_Dart_CObject__bindgen_ty_1, Dart_CObject,
Dart_CObject_Type_Dart_CObject_kInt64, Dart_Port,
};
pub use self::task::Task;
use crate::{api::propagate_panic, platform::utils::dart_api};
pub fn spawn(fut: impl Future<Output = ()> + 'static) {
Task::spawn(Box::pin(fut));
}
type AtomicDartPort = AtomicI64;
static WAKE_PORT: AtomicDartPort = AtomicI64::new(0);
#[unsafe(no_mangle)]
pub unsafe extern "C" fn rust_executor_init(wake_port: Dart_Port) {
WAKE_PORT.store(wake_port, atomic::Ordering::Release);
}
#[unsafe(no_mangle)]
pub unsafe extern "C" fn rust_executor_poll_task(task: ptr::NonNull<Task>) {
propagate_panic(move || unsafe { Arc::from_raw(task.as_ptr()).poll() });
}
fn task_wake(task: Arc<Task>) {
let wake_port = WAKE_PORT.load(atomic::Ordering::Acquire);
assert!(wake_port > 0, "`WAKE_PORT` address must be initialized");
let task = Arc::into_raw(task);
let mut task_addr = Dart_CObject {
type_: Dart_CObject_Type_Dart_CObject_kInt64,
value: _Dart_CObject__bindgen_ty_1 { as_int64: task as i64 },
};
let enqueued =
unsafe { dart_api::post_c_object(wake_port, &mut task_addr) };
if !enqueued {
log::warn!("Could not send message to Dart's native port");
unsafe {
drop(Arc::from_raw(task));
}
}
}