diff --git a/cli/napi/env.rs b/cli/napi/env.rs index 841b6cd961..558b9b0127 100644 --- a/cli/napi/env.rs +++ b/cli/napi/env.rs @@ -141,8 +141,7 @@ fn napi_module_register(module: *const NapiModule) -> Result { #[napi_sym::napi_sym] fn napi_get_uv_event_loop(_env: *mut Env, uv_loop: *mut *mut ()) -> Result { - // Don't error out because addons may pass this to - // our libuv _polyfills_. + // There is no uv_loop in Deno *uv_loop = std::ptr::null_mut(); Ok(()) } diff --git a/cli/napi/mod.rs b/cli/napi/mod.rs index f6ee01c2bb..ec49b2c72a 100644 --- a/cli/napi/mod.rs +++ b/cli/napi/mod.rs @@ -20,69 +20,3 @@ pub mod env; pub mod js_native_api; pub mod threadsafe_functions; pub mod util; - -use std::os::raw::c_int; -use std::os::raw::c_void; - -pub type uv_async_t = *mut uv_async; -pub type uv_loop_t = *mut c_void; -pub type uv_async_cb = extern "C" fn(handle: uv_async_t); - -use deno_core::futures::channel::mpsc; -#[repr(C)] -pub struct uv_async { - pub data: Option<*mut c_void>, - callback: uv_async_cb, - sender: Option< - mpsc::UnboundedSender, - >, - ref_sender: Option< - mpsc::UnboundedSender, - >, -} - -#[no_mangle] -pub extern "C" fn uv_default_loop() -> uv_loop_t { - std::ptr::null_mut() -} - -/// # Safety -/// libuv APIs -#[no_mangle] -pub unsafe extern "C" fn uv_async_init( - _loop: uv_loop_t, - async_: uv_async_t, - cb: uv_async_cb, -) -> c_int { - (*async_).callback = cb; - deno_runtime::deno_napi::ASYNC_WORK_SENDER.with(|sender| { - (*async_).sender = Some(sender.borrow().clone().unwrap()); - }); - - deno_runtime::deno_napi::THREAD_SAFE_FN_SENDER.with(|sender| { - sender - .borrow() - .clone() - .unwrap() - .unbounded_send(deno_runtime::deno_napi::ThreadSafeFunctionStatus::Alive) - .unwrap(); - (*async_).ref_sender = Some(sender.borrow().clone().unwrap()); - }); - - 0 -} - -/// # Safety -/// libuv APIs -#[no_mangle] -pub unsafe extern "C" fn uv_async_send(async_: uv_async_t) -> c_int { - let sender = (*async_).sender.as_ref().unwrap(); - let fut = Box::new(move || { - ((*async_).callback)(async_); - }); - - match sender.unbounded_send(fut) { - Ok(_) => 0, - Err(_) => 1, - } -}