diff options
Diffstat (limited to 'runtime/ops')
-rw-r--r-- | runtime/ops/crypto.rs | 2 | ||||
-rw-r--r-- | runtime/ops/fetch.rs | 10 | ||||
-rw-r--r-- | runtime/ops/file.rs | 12 | ||||
-rw-r--r-- | runtime/ops/fs.rs | 98 | ||||
-rw-r--r-- | runtime/ops/fs_events.rs | 4 | ||||
-rw-r--r-- | runtime/ops/http.rs | 12 | ||||
-rw-r--r-- | runtime/ops/io.rs | 10 | ||||
-rw-r--r-- | runtime/ops/mod.rs | 38 | ||||
-rw-r--r-- | runtime/ops/net.rs | 12 | ||||
-rw-r--r-- | runtime/ops/os.rs | 22 | ||||
-rw-r--r-- | runtime/ops/permissions.rs | 6 | ||||
-rw-r--r-- | runtime/ops/plugin.rs | 2 | ||||
-rw-r--r-- | runtime/ops/process.rs | 6 | ||||
-rw-r--r-- | runtime/ops/runtime.rs | 4 | ||||
-rw-r--r-- | runtime/ops/signal.rs | 6 | ||||
-rw-r--r-- | runtime/ops/timers.rs | 10 | ||||
-rw-r--r-- | runtime/ops/tls.rs | 8 | ||||
-rw-r--r-- | runtime/ops/tty.rs | 6 | ||||
-rw-r--r-- | runtime/ops/url.rs | 10 | ||||
-rw-r--r-- | runtime/ops/web_worker.rs | 20 | ||||
-rw-r--r-- | runtime/ops/webgpu.rs | 160 | ||||
-rw-r--r-- | runtime/ops/websocket.rs | 10 | ||||
-rw-r--r-- | runtime/ops/worker_host.rs | 14 |
23 files changed, 213 insertions, 269 deletions
diff --git a/runtime/ops/crypto.rs b/runtime/ops/crypto.rs index 43a9d1126..432cc0185 100644 --- a/runtime/ops/crypto.rs +++ b/runtime/ops/crypto.rs @@ -10,7 +10,7 @@ pub fn init(rt: &mut deno_core::JsRuntime, maybe_seed: Option<u64>) { let mut state = op_state.borrow_mut(); state.put::<StdRng>(rng); } - super::reg_json_sync( + super::reg_sync( rt, "op_crypto_get_random_values", op_crypto_get_random_values, diff --git a/runtime/ops/fetch.rs b/runtime/ops/fetch.rs index 3cb0c6c78..17656974a 100644 --- a/runtime/ops/fetch.rs +++ b/runtime/ops/fetch.rs @@ -20,19 +20,19 @@ pub fn init( ca_data, }); } - super::reg_json_sync(rt, "op_fetch", deno_fetch::op_fetch::<Permissions>); - super::reg_json_async(rt, "op_fetch_send", deno_fetch::op_fetch_send); - super::reg_json_async( + super::reg_sync(rt, "op_fetch", deno_fetch::op_fetch::<Permissions>); + super::reg_async(rt, "op_fetch_send", deno_fetch::op_fetch_send); + super::reg_async( rt, "op_fetch_request_write", deno_fetch::op_fetch_request_write, ); - super::reg_json_async( + super::reg_async( rt, "op_fetch_response_read", deno_fetch::op_fetch_response_read, ); - super::reg_json_sync( + super::reg_sync( rt, "op_create_http_client", deno_fetch::op_create_http_client::<Permissions>, diff --git a/runtime/ops/file.rs b/runtime/ops/file.rs index e7f68b207..8f471ebbd 100644 --- a/runtime/ops/file.rs +++ b/runtime/ops/file.rs @@ -18,14 +18,6 @@ pub fn init( op_state.put(Location(location)); } } - super::reg_json_sync( - rt, - "op_file_create_object_url", - op_file_create_object_url, - ); - super::reg_json_sync( - rt, - "op_file_revoke_object_url", - op_file_revoke_object_url, - ); + super::reg_sync(rt, "op_file_create_object_url", op_file_create_object_url); + super::reg_sync(rt, "op_file_revoke_object_url", op_file_revoke_object_url); } diff --git a/runtime/ops/fs.rs b/runtime/ops/fs.rs index aa3780624..19933dcb6 100644 --- a/runtime/ops/fs.rs +++ b/runtime/ops/fs.rs @@ -34,79 +34,79 @@ use deno_core::error::generic_error; use deno_core::error::not_supported; pub fn init(rt: &mut deno_core::JsRuntime) { - super::reg_json_sync(rt, "op_open_sync", op_open_sync); - super::reg_json_async(rt, "op_open_async", op_open_async); + super::reg_sync(rt, "op_open_sync", op_open_sync); + super::reg_async(rt, "op_open_async", op_open_async); - super::reg_json_sync(rt, "op_seek_sync", op_seek_sync); - super::reg_json_async(rt, "op_seek_async", op_seek_async); + super::reg_sync(rt, "op_seek_sync", op_seek_sync); + super::reg_async(rt, "op_seek_async", op_seek_async); - super::reg_json_sync(rt, "op_fdatasync_sync", op_fdatasync_sync); - super::reg_json_async(rt, "op_fdatasync_async", op_fdatasync_async); + super::reg_sync(rt, "op_fdatasync_sync", op_fdatasync_sync); + super::reg_async(rt, "op_fdatasync_async", op_fdatasync_async); - super::reg_json_sync(rt, "op_fsync_sync", op_fsync_sync); - super::reg_json_async(rt, "op_fsync_async", op_fsync_async); + super::reg_sync(rt, "op_fsync_sync", op_fsync_sync); + super::reg_async(rt, "op_fsync_async", op_fsync_async); - super::reg_json_sync(rt, "op_fstat_sync", op_fstat_sync); - super::reg_json_async(rt, "op_fstat_async", op_fstat_async); + super::reg_sync(rt, "op_fstat_sync", op_fstat_sync); + super::reg_async(rt, "op_fstat_async", op_fstat_async); - super::reg_json_sync(rt, "op_umask", op_umask); - super::reg_json_sync(rt, "op_chdir", op_chdir); + super::reg_sync(rt, "op_umask", op_umask); + super::reg_sync(rt, "op_chdir", op_chdir); - super::reg_json_sync(rt, "op_mkdir_sync", op_mkdir_sync); - super::reg_json_async(rt, "op_mkdir_async", op_mkdir_async); + super::reg_sync(rt, "op_mkdir_sync", op_mkdir_sync); + super::reg_async(rt, "op_mkdir_async", op_mkdir_async); - super::reg_json_sync(rt, "op_chmod_sync", op_chmod_sync); - super::reg_json_async(rt, "op_chmod_async", op_chmod_async); + super::reg_sync(rt, "op_chmod_sync", op_chmod_sync); + super::reg_async(rt, "op_chmod_async", op_chmod_async); - super::reg_json_sync(rt, "op_chown_sync", op_chown_sync); - super::reg_json_async(rt, "op_chown_async", op_chown_async); + super::reg_sync(rt, "op_chown_sync", op_chown_sync); + super::reg_async(rt, "op_chown_async", op_chown_async); - super::reg_json_sync(rt, "op_remove_sync", op_remove_sync); - super::reg_json_async(rt, "op_remove_async", op_remove_async); + super::reg_sync(rt, "op_remove_sync", op_remove_sync); + super::reg_async(rt, "op_remove_async", op_remove_async); - super::reg_json_sync(rt, "op_copy_file_sync", op_copy_file_sync); - super::reg_json_async(rt, "op_copy_file_async", op_copy_file_async); + super::reg_sync(rt, "op_copy_file_sync", op_copy_file_sync); + super::reg_async(rt, "op_copy_file_async", op_copy_file_async); - super::reg_json_sync(rt, "op_stat_sync", op_stat_sync); - super::reg_json_async(rt, "op_stat_async", op_stat_async); + super::reg_sync(rt, "op_stat_sync", op_stat_sync); + super::reg_async(rt, "op_stat_async", op_stat_async); - super::reg_json_sync(rt, "op_realpath_sync", op_realpath_sync); - super::reg_json_async(rt, "op_realpath_async", op_realpath_async); + super::reg_sync(rt, "op_realpath_sync", op_realpath_sync); + super::reg_async(rt, "op_realpath_async", op_realpath_async); - super::reg_json_sync(rt, "op_read_dir_sync", op_read_dir_sync); - super::reg_json_async(rt, "op_read_dir_async", op_read_dir_async); + super::reg_sync(rt, "op_read_dir_sync", op_read_dir_sync); + super::reg_async(rt, "op_read_dir_async", op_read_dir_async); - super::reg_json_sync(rt, "op_rename_sync", op_rename_sync); - super::reg_json_async(rt, "op_rename_async", op_rename_async); + super::reg_sync(rt, "op_rename_sync", op_rename_sync); + super::reg_async(rt, "op_rename_async", op_rename_async); - super::reg_json_sync(rt, "op_link_sync", op_link_sync); - super::reg_json_async(rt, "op_link_async", op_link_async); + super::reg_sync(rt, "op_link_sync", op_link_sync); + super::reg_async(rt, "op_link_async", op_link_async); - super::reg_json_sync(rt, "op_symlink_sync", op_symlink_sync); - super::reg_json_async(rt, "op_symlink_async", op_symlink_async); + super::reg_sync(rt, "op_symlink_sync", op_symlink_sync); + super::reg_async(rt, "op_symlink_async", op_symlink_async); - super::reg_json_sync(rt, "op_read_link_sync", op_read_link_sync); - super::reg_json_async(rt, "op_read_link_async", op_read_link_async); + super::reg_sync(rt, "op_read_link_sync", op_read_link_sync); + super::reg_async(rt, "op_read_link_async", op_read_link_async); - super::reg_json_sync(rt, "op_ftruncate_sync", op_ftruncate_sync); - super::reg_json_async(rt, "op_ftruncate_async", op_ftruncate_async); + super::reg_sync(rt, "op_ftruncate_sync", op_ftruncate_sync); + super::reg_async(rt, "op_ftruncate_async", op_ftruncate_async); - super::reg_json_sync(rt, "op_truncate_sync", op_truncate_sync); - super::reg_json_async(rt, "op_truncate_async", op_truncate_async); + super::reg_sync(rt, "op_truncate_sync", op_truncate_sync); + super::reg_async(rt, "op_truncate_async", op_truncate_async); - super::reg_json_sync(rt, "op_make_temp_dir_sync", op_make_temp_dir_sync); - super::reg_json_async(rt, "op_make_temp_dir_async", op_make_temp_dir_async); + super::reg_sync(rt, "op_make_temp_dir_sync", op_make_temp_dir_sync); + super::reg_async(rt, "op_make_temp_dir_async", op_make_temp_dir_async); - super::reg_json_sync(rt, "op_make_temp_file_sync", op_make_temp_file_sync); - super::reg_json_async(rt, "op_make_temp_file_async", op_make_temp_file_async); + super::reg_sync(rt, "op_make_temp_file_sync", op_make_temp_file_sync); + super::reg_async(rt, "op_make_temp_file_async", op_make_temp_file_async); - super::reg_json_sync(rt, "op_cwd", op_cwd); + super::reg_sync(rt, "op_cwd", op_cwd); - super::reg_json_sync(rt, "op_futime_sync", op_futime_sync); - super::reg_json_async(rt, "op_futime_async", op_futime_async); + super::reg_sync(rt, "op_futime_sync", op_futime_sync); + super::reg_async(rt, "op_futime_async", op_futime_async); - super::reg_json_sync(rt, "op_utime_sync", op_utime_sync); - super::reg_json_async(rt, "op_utime_async", op_utime_async); + super::reg_sync(rt, "op_utime_sync", op_utime_sync); + super::reg_async(rt, "op_utime_async", op_utime_async); } #[derive(Deserialize)] diff --git a/runtime/ops/fs_events.rs b/runtime/ops/fs_events.rs index 30ab69ba5..8bc9c4c57 100644 --- a/runtime/ops/fs_events.rs +++ b/runtime/ops/fs_events.rs @@ -28,8 +28,8 @@ use std::rc::Rc; use tokio::sync::mpsc; pub fn init(rt: &mut deno_core::JsRuntime) { - super::reg_json_sync(rt, "op_fs_events_open", op_fs_events_open); - super::reg_json_async(rt, "op_fs_events_poll", op_fs_events_poll); + super::reg_sync(rt, "op_fs_events_open", op_fs_events_open); + super::reg_async(rt, "op_fs_events_poll", op_fs_events_poll); } struct FsEventsResource { diff --git a/runtime/ops/http.rs b/runtime/ops/http.rs index 9cf4ff9d5..f209662c4 100644 --- a/runtime/ops/http.rs +++ b/runtime/ops/http.rs @@ -43,14 +43,14 @@ use tokio_rustls::server::TlsStream; use tokio_util::io::StreamReader; pub fn init(rt: &mut deno_core::JsRuntime) { - super::reg_json_sync(rt, "op_http_start", op_http_start); + super::reg_sync(rt, "op_http_start", op_http_start); - super::reg_json_async(rt, "op_http_request_next", op_http_request_next); - super::reg_json_async(rt, "op_http_request_read", op_http_request_read); + super::reg_async(rt, "op_http_request_next", op_http_request_next); + super::reg_async(rt, "op_http_request_read", op_http_request_read); - super::reg_json_sync(rt, "op_http_response", op_http_response); - super::reg_json_async(rt, "op_http_response_write", op_http_response_write); - super::reg_json_async(rt, "op_http_response_close", op_http_response_close); + super::reg_sync(rt, "op_http_response", op_http_response); + super::reg_async(rt, "op_http_response_write", op_http_response_write); + super::reg_async(rt, "op_http_response_close", op_http_response_close); } struct ServiceInner { diff --git a/runtime/ops/io.rs b/runtime/ops/io.rs index f8ab92704..0e4e3f42a 100644 --- a/runtime/ops/io.rs +++ b/runtime/ops/io.rs @@ -96,13 +96,13 @@ lazy_static::lazy_static! { } pub fn init(rt: &mut JsRuntime) { - super::reg_bin_async(rt, "op_read_async", op_read_async); - super::reg_bin_async(rt, "op_write_async", op_write_async); + super::reg_async(rt, "op_read_async", op_read_async); + super::reg_async(rt, "op_write_async", op_write_async); - super::reg_bin_sync(rt, "op_read_sync", op_read_sync); - super::reg_bin_sync(rt, "op_write_sync", op_write_sync); + super::reg_sync(rt, "op_read_sync", op_read_sync); + super::reg_sync(rt, "op_write_sync", op_write_sync); - super::reg_json_async(rt, "op_shutdown", op_shutdown); + super::reg_async(rt, "op_shutdown", op_shutdown); } pub fn get_stdio() -> ( diff --git a/runtime/ops/mod.rs b/runtime/ops/mod.rs index d9bd2ba83..825950d65 100644 --- a/runtime/ops/mod.rs +++ b/runtime/ops/mod.rs @@ -27,59 +27,35 @@ pub mod websocket; pub mod worker_host; use crate::metrics::metrics_op; -use deno_core::bin_op_async; -use deno_core::bin_op_sync; use deno_core::error::AnyError; -use deno_core::json_op_async; -use deno_core::json_op_sync; +use deno_core::op_async; +use deno_core::op_sync; use deno_core::serde::de::DeserializeOwned; use deno_core::serde::Serialize; use deno_core::JsRuntime; use deno_core::OpState; -use deno_core::ValueOrVector; use deno_core::ZeroCopyBuf; use std::cell::RefCell; use std::future::Future; use std::rc::Rc; -pub fn reg_json_async<F, V, R, RV>( - rt: &mut JsRuntime, - name: &'static str, - op_fn: F, -) where +pub fn reg_async<F, V, R, RV>(rt: &mut JsRuntime, name: &'static str, op_fn: F) +where F: Fn(Rc<RefCell<OpState>>, V, Option<ZeroCopyBuf>) -> R + 'static, V: DeserializeOwned, R: Future<Output = Result<RV, AnyError>> + 'static, RV: Serialize + 'static, { - rt.register_op(name, metrics_op(name, json_op_async(op_fn))); + rt.register_op(name, metrics_op(name, op_async(op_fn))); } -pub fn reg_json_sync<F, V, R>(rt: &mut JsRuntime, name: &'static str, op_fn: F) +pub fn reg_sync<F, V, R>(rt: &mut JsRuntime, name: &'static str, op_fn: F) where F: Fn(&mut OpState, V, Option<ZeroCopyBuf>) -> Result<R, AnyError> + 'static, V: DeserializeOwned, R: Serialize + 'static, { - rt.register_op(name, metrics_op(name, json_op_sync(op_fn))); -} - -pub fn reg_bin_async<F, R, RV>(rt: &mut JsRuntime, name: &'static str, op_fn: F) -where - F: Fn(Rc<RefCell<OpState>>, u32, Option<ZeroCopyBuf>) -> R + 'static, - R: Future<Output = Result<RV, AnyError>> + 'static, - RV: ValueOrVector, -{ - rt.register_op(name, metrics_op(name, bin_op_async(op_fn))); -} - -pub fn reg_bin_sync<F, R>(rt: &mut JsRuntime, name: &'static str, op_fn: F) -where - F: - Fn(&mut OpState, u32, Option<ZeroCopyBuf>) -> Result<R, AnyError> + 'static, - R: ValueOrVector, -{ - rt.register_op(name, metrics_op(name, bin_op_sync(op_fn))); + rt.register_op(name, metrics_op(name, op_sync(op_fn))); } /// `UnstableChecker` is a struct so it can be placed inside `GothamState`; diff --git a/runtime/ops/net.rs b/runtime/ops/net.rs index 934ff7926..ee762ed47 100644 --- a/runtime/ops/net.rs +++ b/runtime/ops/net.rs @@ -43,12 +43,12 @@ use crate::ops::io::UnixStreamResource; use std::path::Path; pub fn init(rt: &mut deno_core::JsRuntime) { - super::reg_json_async(rt, "op_accept", op_accept); - super::reg_json_async(rt, "op_connect", op_connect); - super::reg_json_sync(rt, "op_listen", op_listen); - super::reg_json_async(rt, "op_datagram_receive", op_datagram_receive); - super::reg_json_async(rt, "op_datagram_send", op_datagram_send); - super::reg_json_async(rt, "op_dns_resolve", op_dns_resolve); + super::reg_async(rt, "op_accept", op_accept); + super::reg_async(rt, "op_connect", op_connect); + super::reg_sync(rt, "op_listen", op_listen); + super::reg_async(rt, "op_datagram_receive", op_datagram_receive); + super::reg_async(rt, "op_datagram_send", op_datagram_send); + super::reg_async(rt, "op_dns_resolve", op_dns_resolve); } #[derive(Serialize)] diff --git a/runtime/ops/os.rs b/runtime/ops/os.rs index b13b54d22..b9511fcdc 100644 --- a/runtime/ops/os.rs +++ b/runtime/ops/os.rs @@ -12,17 +12,17 @@ use std::collections::HashMap; use std::env; pub fn init(rt: &mut deno_core::JsRuntime) { - super::reg_json_sync(rt, "op_exit", op_exit); - super::reg_json_sync(rt, "op_env", op_env); - super::reg_json_sync(rt, "op_exec_path", op_exec_path); - super::reg_json_sync(rt, "op_set_env", op_set_env); - super::reg_json_sync(rt, "op_get_env", op_get_env); - super::reg_json_sync(rt, "op_delete_env", op_delete_env); - super::reg_json_sync(rt, "op_hostname", op_hostname); - super::reg_json_sync(rt, "op_loadavg", op_loadavg); - super::reg_json_sync(rt, "op_os_release", op_os_release); - super::reg_json_sync(rt, "op_system_memory_info", op_system_memory_info); - super::reg_json_sync(rt, "op_system_cpu_info", op_system_cpu_info); + super::reg_sync(rt, "op_exit", op_exit); + super::reg_sync(rt, "op_env", op_env); + super::reg_sync(rt, "op_exec_path", op_exec_path); + super::reg_sync(rt, "op_set_env", op_set_env); + super::reg_sync(rt, "op_get_env", op_get_env); + super::reg_sync(rt, "op_delete_env", op_delete_env); + super::reg_sync(rt, "op_hostname", op_hostname); + super::reg_sync(rt, "op_loadavg", op_loadavg); + super::reg_sync(rt, "op_os_release", op_os_release); + super::reg_sync(rt, "op_system_memory_info", op_system_memory_info); + super::reg_sync(rt, "op_system_cpu_info", op_system_cpu_info); } fn op_exec_path( diff --git a/runtime/ops/permissions.rs b/runtime/ops/permissions.rs index 77d095d84..ce89def54 100644 --- a/runtime/ops/permissions.rs +++ b/runtime/ops/permissions.rs @@ -11,9 +11,9 @@ use serde::Deserialize; use std::path::Path; pub fn init(rt: &mut deno_core::JsRuntime) { - super::reg_json_sync(rt, "op_query_permission", op_query_permission); - super::reg_json_sync(rt, "op_revoke_permission", op_revoke_permission); - super::reg_json_sync(rt, "op_request_permission", op_request_permission); + super::reg_sync(rt, "op_query_permission", op_query_permission); + super::reg_sync(rt, "op_revoke_permission", op_revoke_permission); + super::reg_sync(rt, "op_request_permission", op_request_permission); } #[derive(Deserialize)] diff --git a/runtime/ops/plugin.rs b/runtime/ops/plugin.rs index d0fc989f4..c265c757f 100644 --- a/runtime/ops/plugin.rs +++ b/runtime/ops/plugin.rs @@ -23,7 +23,7 @@ use std::task::Context; use std::task::Poll; pub fn init(rt: &mut JsRuntime) { - super::reg_json_sync(rt, "op_open_plugin", op_open_plugin); + super::reg_sync(rt, "op_open_plugin", op_open_plugin); } pub fn op_open_plugin( diff --git a/runtime/ops/process.rs b/runtime/ops/process.rs index 4b49e21f3..bf074db2c 100644 --- a/runtime/ops/process.rs +++ b/runtime/ops/process.rs @@ -26,9 +26,9 @@ use tokio::process::Command; use std::os::unix::process::ExitStatusExt; pub fn init(rt: &mut deno_core::JsRuntime) { - super::reg_json_sync(rt, "op_run", op_run); - super::reg_json_async(rt, "op_run_status", op_run_status); - super::reg_json_sync(rt, "op_kill", op_kill); + super::reg_sync(rt, "op_run", op_run); + super::reg_async(rt, "op_run_status", op_run_status); + super::reg_sync(rt, "op_kill", op_kill); } fn clone_file( diff --git a/runtime/ops/runtime.rs b/runtime/ops/runtime.rs index d694cb9c9..d90e92593 100644 --- a/runtime/ops/runtime.rs +++ b/runtime/ops/runtime.rs @@ -17,8 +17,8 @@ pub fn init(rt: &mut deno_core::JsRuntime, main_module: ModuleSpecifier) { let mut state = op_state.borrow_mut(); state.put::<ModuleSpecifier>(main_module); } - super::reg_json_sync(rt, "op_main_module", op_main_module); - super::reg_json_sync(rt, "op_metrics", op_metrics); + super::reg_sync(rt, "op_main_module", op_main_module); + super::reg_sync(rt, "op_metrics", op_metrics); } fn op_main_module( diff --git a/runtime/ops/signal.rs b/runtime/ops/signal.rs index 5235da612..2a19e4e98 100644 --- a/runtime/ops/signal.rs +++ b/runtime/ops/signal.rs @@ -25,9 +25,9 @@ use std::borrow::Cow; use tokio::signal::unix::{signal, Signal, SignalKind}; pub fn init(rt: &mut deno_core::JsRuntime) { - super::reg_json_sync(rt, "op_signal_bind", op_signal_bind); - super::reg_json_sync(rt, "op_signal_unbind", op_signal_unbind); - super::reg_json_async(rt, "op_signal_poll", op_signal_poll); + super::reg_sync(rt, "op_signal_bind", op_signal_bind); + super::reg_sync(rt, "op_signal_unbind", op_signal_unbind); + super::reg_async(rt, "op_signal_poll", op_signal_poll); } #[cfg(unix)] diff --git a/runtime/ops/timers.rs b/runtime/ops/timers.rs index aee38cf8d..8e709440e 100644 --- a/runtime/ops/timers.rs +++ b/runtime/ops/timers.rs @@ -69,11 +69,11 @@ pub fn init(rt: &mut deno_core::JsRuntime) { state.put::<GlobalTimer>(GlobalTimer::default()); state.put::<StartTime>(StartTime::now()); } - super::reg_json_sync(rt, "op_global_timer_stop", op_global_timer_stop); - super::reg_json_sync(rt, "op_global_timer_start", op_global_timer_start); - super::reg_json_async(rt, "op_global_timer", op_global_timer); - super::reg_json_sync(rt, "op_now", op_now); - super::reg_json_sync(rt, "op_sleep_sync", op_sleep_sync); + super::reg_sync(rt, "op_global_timer_stop", op_global_timer_stop); + super::reg_sync(rt, "op_global_timer_start", op_global_timer_start); + super::reg_async(rt, "op_global_timer", op_global_timer); + super::reg_sync(rt, "op_now", op_now); + super::reg_sync(rt, "op_sleep_sync", op_sleep_sync); } #[allow(clippy::unnecessary_wraps)] diff --git a/runtime/ops/tls.rs b/runtime/ops/tls.rs index 36762d66c..10293cf92 100644 --- a/runtime/ops/tls.rs +++ b/runtime/ops/tls.rs @@ -71,10 +71,10 @@ impl StoresClientSessions for ClientSessionMemoryCache { } pub fn init(rt: &mut deno_core::JsRuntime) { - super::reg_json_async(rt, "op_start_tls", op_start_tls); - super::reg_json_async(rt, "op_connect_tls", op_connect_tls); - super::reg_json_sync(rt, "op_listen_tls", op_listen_tls); - super::reg_json_async(rt, "op_accept_tls", op_accept_tls); + super::reg_async(rt, "op_start_tls", op_start_tls); + super::reg_async(rt, "op_connect_tls", op_connect_tls); + super::reg_sync(rt, "op_listen_tls", op_listen_tls); + super::reg_async(rt, "op_accept_tls", op_accept_tls); } #[derive(Deserialize)] diff --git a/runtime/ops/tty.rs b/runtime/ops/tty.rs index 9af72b5cd..a62a9ba02 100644 --- a/runtime/ops/tty.rs +++ b/runtime/ops/tty.rs @@ -44,9 +44,9 @@ fn get_windows_handle( } pub fn init(rt: &mut deno_core::JsRuntime) { - super::reg_json_sync(rt, "op_set_raw", op_set_raw); - super::reg_json_sync(rt, "op_isatty", op_isatty); - super::reg_json_sync(rt, "op_console_size", op_console_size); + super::reg_sync(rt, "op_set_raw", op_set_raw); + super::reg_sync(rt, "op_isatty", op_isatty); + super::reg_sync(rt, "op_console_size", op_console_size); } #[derive(Deserialize)] diff --git a/runtime/ops/url.rs b/runtime/ops/url.rs index 4add9132d..5168a7242 100644 --- a/runtime/ops/url.rs +++ b/runtime/ops/url.rs @@ -4,13 +4,9 @@ use deno_url::op_url_parse_search_params; use deno_url::op_url_stringify_search_params; pub fn init(rt: &mut deno_core::JsRuntime) { - super::reg_json_sync(rt, "op_url_parse", op_url_parse); - super::reg_json_sync( - rt, - "op_url_parse_search_params", - op_url_parse_search_params, - ); - super::reg_json_sync( + super::reg_sync(rt, "op_url_parse", op_url_parse); + super::reg_sync(rt, "op_url_parse_search_params", op_url_parse_search_params); + super::reg_sync( rt, "op_url_stringify_search_params", op_url_stringify_search_params, diff --git a/runtime/ops/web_worker.rs b/runtime/ops/web_worker.rs index 5f63a03b7..68cef110c 100644 --- a/runtime/ops/web_worker.rs +++ b/runtime/ops/web_worker.rs @@ -12,7 +12,7 @@ pub fn init( ) { // Post message to host as guest worker. let sender_ = sender.clone(); - super::reg_json_sync( + super::reg_sync( rt, "op_worker_post_message", move |_state, _args: (), buf| { @@ -27,15 +27,11 @@ pub fn init( ); // Notify host that guest worker closes. - super::reg_json_sync( - rt, - "op_worker_close", - move |_state, _args: (), _bufs| { - // Notify parent that we're finished - sender.clone().close_channel(); - // Terminate execution of current worker - handle.terminate(); - Ok(()) - }, - ); + super::reg_sync(rt, "op_worker_close", move |_state, _args: (), _bufs| { + // Notify parent that we're finished + sender.clone().close_channel(); + // Terminate execution of current worker + handle.terminate(); + Ok(()) + }); } diff --git a/runtime/ops/webgpu.rs b/runtime/ops/webgpu.rs index d48913ce8..55c6d1817 100644 --- a/runtime/ops/webgpu.rs +++ b/runtime/ops/webgpu.rs @@ -10,40 +10,28 @@ pub fn init(rt: &mut deno_core::JsRuntime) { state.put(Unstable(unstable)); } - super::reg_json_async( - rt, - "op_webgpu_request_adapter", - op_webgpu_request_adapter, - ); - super::reg_json_async( - rt, - "op_webgpu_request_device", - op_webgpu_request_device, - ); - super::reg_json_sync( - rt, - "op_webgpu_create_query_set", - op_webgpu_create_query_set, - ); + super::reg_async(rt, "op_webgpu_request_adapter", op_webgpu_request_adapter); + super::reg_async(rt, "op_webgpu_request_device", op_webgpu_request_device); + super::reg_sync(rt, "op_webgpu_create_query_set", op_webgpu_create_query_set); { // buffer - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_create_buffer", buffer::op_webgpu_create_buffer, ); - super::reg_json_async( + super::reg_async( rt, "op_webgpu_buffer_get_map_async", buffer::op_webgpu_buffer_get_map_async, ); - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_buffer_get_mapped_range", buffer::op_webgpu_buffer_get_mapped_range, ); - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_buffer_unmap", buffer::op_webgpu_buffer_unmap, @@ -51,12 +39,12 @@ pub fn init(rt: &mut deno_core::JsRuntime) { } { // texture - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_create_texture", texture::op_webgpu_create_texture, ); - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_create_texture_view", texture::op_webgpu_create_texture_view, @@ -64,7 +52,7 @@ pub fn init(rt: &mut deno_core::JsRuntime) { } { // sampler - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_create_sampler", sampler::op_webgpu_create_sampler, @@ -72,17 +60,17 @@ pub fn init(rt: &mut deno_core::JsRuntime) { } { // binding - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_create_bind_group_layout", binding::op_webgpu_create_bind_group_layout, ); - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_create_pipeline_layout", binding::op_webgpu_create_pipeline_layout, ); - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_create_bind_group", binding::op_webgpu_create_bind_group, @@ -90,22 +78,22 @@ pub fn init(rt: &mut deno_core::JsRuntime) { } { // pipeline - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_create_compute_pipeline", pipeline::op_webgpu_create_compute_pipeline, ); - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_compute_pipeline_get_bind_group_layout", pipeline::op_webgpu_compute_pipeline_get_bind_group_layout, ); - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_create_render_pipeline", pipeline::op_webgpu_create_render_pipeline, ); - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_render_pipeline_get_bind_group_layout", pipeline::op_webgpu_render_pipeline_get_bind_group_layout, @@ -113,67 +101,67 @@ pub fn init(rt: &mut deno_core::JsRuntime) { } { // command_encoder - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_create_command_encoder", command_encoder::op_webgpu_create_command_encoder, ); - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_command_encoder_begin_render_pass", command_encoder::op_webgpu_command_encoder_begin_render_pass, ); - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_command_encoder_begin_compute_pass", command_encoder::op_webgpu_command_encoder_begin_compute_pass, ); - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_command_encoder_copy_buffer_to_buffer", command_encoder::op_webgpu_command_encoder_copy_buffer_to_buffer, ); - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_command_encoder_copy_buffer_to_texture", command_encoder::op_webgpu_command_encoder_copy_buffer_to_texture, ); - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_command_encoder_copy_texture_to_buffer", command_encoder::op_webgpu_command_encoder_copy_texture_to_buffer, ); - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_command_encoder_copy_texture_to_texture", command_encoder::op_webgpu_command_encoder_copy_texture_to_texture, ); - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_command_encoder_push_debug_group", command_encoder::op_webgpu_command_encoder_push_debug_group, ); - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_command_encoder_pop_debug_group", command_encoder::op_webgpu_command_encoder_pop_debug_group, ); - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_command_encoder_insert_debug_marker", command_encoder::op_webgpu_command_encoder_insert_debug_marker, ); - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_command_encoder_write_timestamp", command_encoder::op_webgpu_command_encoder_write_timestamp, ); - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_command_encoder_resolve_query_set", command_encoder::op_webgpu_command_encoder_resolve_query_set, ); - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_command_encoder_finish", command_encoder::op_webgpu_command_encoder_finish, @@ -181,102 +169,102 @@ pub fn init(rt: &mut deno_core::JsRuntime) { } { // render_pass - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_render_pass_set_viewport", render_pass::op_webgpu_render_pass_set_viewport, ); - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_render_pass_set_scissor_rect", render_pass::op_webgpu_render_pass_set_scissor_rect, ); - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_render_pass_set_blend_color", render_pass::op_webgpu_render_pass_set_blend_color, ); - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_render_pass_set_stencil_reference", render_pass::op_webgpu_render_pass_set_stencil_reference, ); - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_render_pass_begin_pipeline_statistics_query", render_pass::op_webgpu_render_pass_begin_pipeline_statistics_query, ); - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_render_pass_end_pipeline_statistics_query", render_pass::op_webgpu_render_pass_end_pipeline_statistics_query, ); - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_render_pass_write_timestamp", render_pass::op_webgpu_render_pass_write_timestamp, ); - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_render_pass_execute_bundles", render_pass::op_webgpu_render_pass_execute_bundles, ); - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_render_pass_end_pass", render_pass::op_webgpu_render_pass_end_pass, ); - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_render_pass_set_bind_group", render_pass::op_webgpu_render_pass_set_bind_group, ); - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_render_pass_push_debug_group", render_pass::op_webgpu_render_pass_push_debug_group, ); - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_render_pass_pop_debug_group", render_pass::op_webgpu_render_pass_pop_debug_group, ); - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_render_pass_insert_debug_marker", render_pass::op_webgpu_render_pass_insert_debug_marker, ); - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_render_pass_set_pipeline", render_pass::op_webgpu_render_pass_set_pipeline, ); - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_render_pass_set_index_buffer", render_pass::op_webgpu_render_pass_set_index_buffer, ); - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_render_pass_set_vertex_buffer", render_pass::op_webgpu_render_pass_set_vertex_buffer, ); - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_render_pass_draw", render_pass::op_webgpu_render_pass_draw, ); - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_render_pass_draw_indexed", render_pass::op_webgpu_render_pass_draw_indexed, ); - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_render_pass_draw_indirect", render_pass::op_webgpu_render_pass_draw_indirect, ); - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_render_pass_draw_indexed_indirect", render_pass::op_webgpu_render_pass_draw_indexed_indirect, @@ -284,42 +272,42 @@ pub fn init(rt: &mut deno_core::JsRuntime) { } { // compute_pass - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_compute_pass_set_pipeline", compute_pass::op_webgpu_compute_pass_set_pipeline, ); - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_compute_pass_dispatch", compute_pass::op_webgpu_compute_pass_dispatch, ); - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_compute_pass_dispatch_indirect", compute_pass::op_webgpu_compute_pass_dispatch_indirect, ); - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_compute_pass_end_pass", compute_pass::op_webgpu_compute_pass_end_pass, ); - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_compute_pass_set_bind_group", compute_pass::op_webgpu_compute_pass_set_bind_group, ); - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_compute_pass_push_debug_group", compute_pass::op_webgpu_compute_pass_push_debug_group, ); - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_compute_pass_pop_debug_group", compute_pass::op_webgpu_compute_pass_pop_debug_group, ); - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_compute_pass_insert_debug_marker", compute_pass::op_webgpu_compute_pass_insert_debug_marker, @@ -327,62 +315,62 @@ pub fn init(rt: &mut deno_core::JsRuntime) { } { // bundle - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_create_render_bundle_encoder", bundle::op_webgpu_create_render_bundle_encoder, ); - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_render_bundle_encoder_finish", bundle::op_webgpu_render_bundle_encoder_finish, ); - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_render_bundle_encoder_set_bind_group", bundle::op_webgpu_render_bundle_encoder_set_bind_group, ); - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_render_bundle_encoder_push_debug_group", bundle::op_webgpu_render_bundle_encoder_push_debug_group, ); - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_render_bundle_encoder_pop_debug_group", bundle::op_webgpu_render_bundle_encoder_pop_debug_group, ); - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_render_bundle_encoder_insert_debug_marker", bundle::op_webgpu_render_bundle_encoder_insert_debug_marker, ); - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_render_bundle_encoder_set_pipeline", bundle::op_webgpu_render_bundle_encoder_set_pipeline, ); - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_render_bundle_encoder_set_index_buffer", bundle::op_webgpu_render_bundle_encoder_set_index_buffer, ); - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_render_bundle_encoder_set_vertex_buffer", bundle::op_webgpu_render_bundle_encoder_set_vertex_buffer, ); - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_render_bundle_encoder_draw", bundle::op_webgpu_render_bundle_encoder_draw, ); - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_render_bundle_encoder_draw_indexed", bundle::op_webgpu_render_bundle_encoder_draw_indexed, ); - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_render_bundle_encoder_draw_indirect", bundle::op_webgpu_render_bundle_encoder_draw_indirect, @@ -390,17 +378,17 @@ pub fn init(rt: &mut deno_core::JsRuntime) { } { // queue - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_queue_submit", queue::op_webgpu_queue_submit, ); - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_write_buffer", queue::op_webgpu_write_buffer, ); - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_write_texture", queue::op_webgpu_write_texture, @@ -408,7 +396,7 @@ pub fn init(rt: &mut deno_core::JsRuntime) { } { // shader - super::reg_json_sync( + super::reg_sync( rt, "op_webgpu_create_shader_module", shader::op_webgpu_create_shader_module, diff --git a/runtime/ops/websocket.rs b/runtime/ops/websocket.rs index 1563961d7..1c44f8b80 100644 --- a/runtime/ops/websocket.rs +++ b/runtime/ops/websocket.rs @@ -21,13 +21,13 @@ pub fn init( state.put::<WsCaData>(WsCaData(ca_data)); } } - super::reg_json_sync( + super::reg_sync( rt, "op_ws_check_permission", op_ws_check_permission::<Permissions>, ); - super::reg_json_async(rt, "op_ws_create", op_ws_create::<Permissions>); - super::reg_json_async(rt, "op_ws_send", op_ws_send); - super::reg_json_async(rt, "op_ws_close", op_ws_close); - super::reg_json_async(rt, "op_ws_next_event", op_ws_next_event); + super::reg_async(rt, "op_ws_create", op_ws_create::<Permissions>); + super::reg_async(rt, "op_ws_send", op_ws_send); + super::reg_async(rt, "op_ws_close", op_ws_close); + super::reg_async(rt, "op_ws_next_event", op_ws_next_event); } diff --git a/runtime/ops/worker_host.rs b/runtime/ops/worker_host.rs index 2f297fb08..92de420e3 100644 --- a/runtime/ops/worker_host.rs +++ b/runtime/ops/worker_host.rs @@ -80,15 +80,11 @@ pub fn init( let create_module_loader = CreateWebWorkerCbHolder(create_web_worker_cb); state.put::<CreateWebWorkerCbHolder>(create_module_loader); } - super::reg_json_sync(rt, "op_create_worker", op_create_worker); - super::reg_json_sync( - rt, - "op_host_terminate_worker", - op_host_terminate_worker, - ); - super::reg_json_sync(rt, "op_host_post_message", op_host_post_message); - super::reg_json_async(rt, "op_host_get_message", op_host_get_message); - super::reg_json_sync( + super::reg_sync(rt, "op_create_worker", op_create_worker); + super::reg_sync(rt, "op_host_terminate_worker", op_host_terminate_worker); + super::reg_sync(rt, "op_host_post_message", op_host_post_message); + super::reg_async(rt, "op_host_get_message", op_host_get_message); + super::reg_sync( rt, "op_host_unhandled_error", move |_state, message: String, _zero_copy| { |