summaryrefslogtreecommitdiff
path: root/cli/napi/mod.rs
diff options
context:
space:
mode:
Diffstat (limited to 'cli/napi/mod.rs')
-rw-r--r--cli/napi/mod.rs66
1 files changed, 0 insertions, 66 deletions
diff --git a/cli/napi/mod.rs b/cli/napi/mod.rs
index f6ee01c2b..ec49b2c72 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<deno_runtime::deno_napi::PendingNapiAsyncWork>,
- >,
- ref_sender: Option<
- mpsc::UnboundedSender<deno_runtime::deno_napi::ThreadSafeFunctionStatus>,
- >,
-}
-
-#[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,
- }
-}