diff options
| author | Divy Srivastava <dj.srivastava23@gmail.com> | 2022-11-11 05:44:53 -0800 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-11-11 19:14:53 +0530 |
| commit | 5b9620df7ac655449abd2cce5292bd4669b1f211 (patch) | |
| tree | 5fd028c3bc3f2963172aada45c3e56174863d2f1 /core | |
| parent | ff92febb385c166744b49219ca7b3059c41ad34a (diff) | |
feat(ops): implement fast lazy async ops (#16579)
Implements fast scheduling of deferred op futures.
```rs
#[op(fast)]
async fn op_read(
state: Rc<RefCell<OpState>>,
rid: ResourceId,
buf: &mut [u8],
) -> Result<u32, Error> {
// ...
}
```
The future is scheduled via a fast API call and polled by the event loop
after being woken up by its waker.
Diffstat (limited to 'core')
| -rw-r--r-- | core/lib.rs | 2 | ||||
| -rw-r--r-- | core/runtime.rs | 16 |
2 files changed, 18 insertions, 0 deletions
diff --git a/core/lib.rs b/core/lib.rs index adda98046..607d90f0b 100644 --- a/core/lib.rs +++ b/core/lib.rs @@ -121,7 +121,9 @@ pub mod _ops { pub use super::error_codes::get_error_code; pub use super::ops::to_op_result; pub use super::ops::OpCtx; + pub use super::ops::OpResult; pub use super::runtime::queue_async_op; + pub use super::runtime::queue_fast_async_op; pub use super::runtime::V8_WRAPPER_OBJECT_INDEX; pub use super::runtime::V8_WRAPPER_TYPE_INDEX; } diff --git a/core/runtime.rs b/core/runtime.rs index 21e6e7570..376e0beb4 100644 --- a/core/runtime.rs +++ b/core/runtime.rs @@ -2203,6 +2203,22 @@ impl JsRealm { } #[inline] +pub fn queue_fast_async_op( + ctx: &OpCtx, + op: impl Future<Output = (PromiseId, OpId, OpResult)> + 'static, +) { + let runtime_state = match ctx.runtime_state.upgrade() { + Some(rc_state) => rc_state, + // atleast 1 Rc is held by the JsRuntime. + None => unreachable!(), + }; + + let mut state = runtime_state.borrow_mut(); + state.pending_ops.push(OpCall::lazy(op)); + state.have_unpolled_ops = true; +} + +#[inline] pub fn queue_async_op( ctx: &OpCtx, scope: &mut v8::HandleScope, |