diff options
| author | Divy Srivastava <dj.srivastava23@gmail.com> | 2022-08-21 17:37:53 +0530 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-08-21 17:37:53 +0530 |
| commit | 906aa78af33c8405a47d5446d2a6fb3348c275bb (patch) | |
| tree | c444e42b6bdfe4bad35634925829a1b1d190fa75 /ext | |
| parent | e39d4e3e7fb9815bf094e7321d1d73d00275831a (diff) | |
feat(ops): V8 Fast Calls (#15291)
Diffstat (limited to 'ext')
| -rw-r--r-- | ext/flash/lib.rs | 8 | ||||
| -rw-r--r-- | ext/net/lib.rs | 4 |
2 files changed, 7 insertions, 5 deletions
diff --git a/ext/flash/lib.rs b/ext/flash/lib.rs index abd8502d0..92350db58 100644 --- a/ext/flash/lib.rs +++ b/ext/flash/lib.rs @@ -1344,8 +1344,8 @@ async fn op_flash_next_async( // the ContextScope creation is optimized away and the op is as simple as: // f(info: *const v8::FunctionCallbackInfo) { let rv = ...; rv.set_uint32(op_flash_next()); } #[op] -fn op_flash_next(op_state: &mut OpState) -> u32 { - let flash_ctx = op_state.borrow_mut::<FlashContext>(); +fn op_flash_next(state: &mut OpState) -> u32 { + let flash_ctx = state.borrow_mut::<FlashContext>(); let ctx = flash_ctx.servers.get_mut(&0).unwrap(); next_request_sync(ctx) } @@ -1353,8 +1353,8 @@ fn op_flash_next(op_state: &mut OpState) -> u32 { // Syncrhonous version of op_flash_next_async. Under heavy load, // this can collect buffered requests from rx channel and return tokens in a single batch. #[op] -fn op_flash_next_server(op_state: &mut OpState, server_id: u32) -> u32 { - let flash_ctx = op_state.borrow_mut::<FlashContext>(); +fn op_flash_next_server(state: &mut OpState, server_id: u32) -> u32 { + let flash_ctx = state.borrow_mut::<FlashContext>(); let ctx = flash_ctx.servers.get_mut(&server_id).unwrap(); next_request_sync(ctx) } diff --git a/ext/net/lib.rs b/ext/net/lib.rs index c95348020..249170060 100644 --- a/ext/net/lib.rs +++ b/ext/net/lib.rs @@ -81,6 +81,8 @@ pub fn init<P: NetPermissions + 'static>( unstable: bool, unsafely_ignore_certificate_errors: Option<Vec<String>>, ) -> Extension { + let mut ops = ops::init::<P>(); + ops.extend(ops_tls::init::<P>()); Extension::builder() .js(include_js_files!( prefix "deno:ext/net", @@ -88,7 +90,7 @@ pub fn init<P: NetPermissions + 'static>( "02_tls.js", "04_net_unstable.js", )) - .ops([&ops::init::<P>()[..], &ops_tls::init::<P>()[..]].concat()) + .ops(ops) .state(move |state| { state.put(DefaultTlsOptions { root_cert_store: root_cert_store.clone(), |