Skip to content

Commit

Permalink
queueMicrotask added
Browse files Browse the repository at this point in the history
  • Loading branch information
pshaughn committed Jan 13, 2020
1 parent 968b45f commit b01b2d3
Show file tree
Hide file tree
Showing 11 changed files with 42 additions and 75 deletions.
10 changes: 9 additions & 1 deletion components/script/dom/globalscope.rs
Expand Up @@ -4,6 +4,7 @@

use crate::dom::bindings::cell::DomRefCell;
use crate::dom::bindings::codegen::Bindings::EventSourceBinding::EventSourceBinding::EventSourceMethods;
use crate::dom::bindings::codegen::Bindings::VoidFunctionBinding::VoidFunction;
use crate::dom::bindings::codegen::Bindings::WindowBinding::WindowMethods;
use crate::dom::bindings::codegen::Bindings::WorkerGlobalScopeBinding::WorkerGlobalScopeMethods;
use crate::dom::bindings::conversions::{root_from_object, root_from_object_static};
Expand Down Expand Up @@ -32,7 +33,7 @@ use crate::dom::performance::Performance;
use crate::dom::window::Window;
use crate::dom::workerglobalscope::WorkerGlobalScope;
use crate::dom::workletglobalscope::WorkletGlobalScope;
use crate::microtask::{Microtask, MicrotaskQueue};
use crate::microtask::{Microtask, MicrotaskQueue, UserMicrotask};
use crate::script_module::ModuleTree;
use crate::script_runtime::{CommonScriptMsg, JSContext as SafeJSContext, ScriptChan, ScriptPort};
use crate::script_thread::{MainThreadScriptChan, ScriptThread};
Expand Down Expand Up @@ -1772,6 +1773,13 @@ impl GlobalScope {
self.timers.clear_timeout_or_interval(self, handle);
}

pub fn queue_function_as_microtask(&self, callback: Rc<VoidFunction>) {
self.enqueue_microtask(Microtask::User(UserMicrotask {
callback: callback,
pipeline: self.pipeline_id(),
}))
}

pub fn fire_timer(&self, handle: TimerEventId) {
self.timers.fire_timer(handle, self);
}
Expand Down
Expand Up @@ -20,6 +20,9 @@ interface mixin WindowOrWorkerGlobalScope {
long setInterval(TimerHandler handler, optional long timeout = 0, any... arguments);
void clearInterval(optional long handle = 0);

// microtask queuing
void queueMicrotask(VoidFunction callback);

// ImageBitmap
// Promise<ImageBitmap> createImageBitmap(ImageBitmapSource image, optional ImageBitmapOptions options);
// Promise<ImageBitmap> createImageBitmap(
Expand Down
7 changes: 7 additions & 0 deletions components/script/dom/window.rs
Expand Up @@ -11,6 +11,7 @@ use crate::dom::bindings::codegen::Bindings::HistoryBinding::HistoryBinding::His
use crate::dom::bindings::codegen::Bindings::MediaQueryListBinding::MediaQueryListBinding::MediaQueryListMethods;
use crate::dom::bindings::codegen::Bindings::PermissionStatusBinding::PermissionState;
use crate::dom::bindings::codegen::Bindings::RequestBinding::RequestInit;
use crate::dom::bindings::codegen::Bindings::VoidFunctionBinding::VoidFunction;
use crate::dom::bindings::codegen::Bindings::WindowBinding::{
self, FrameRequestCallback, WindowMethods, WindowPostMessageOptions,
};
Expand Down Expand Up @@ -871,6 +872,12 @@ impl WindowMethods for Window {
self.ClearTimeout(handle);
}

// https://html.spec.whatwg.org/multipage/#dom-queuemicrotask
fn QueueMicrotask(&self, callback: Rc<VoidFunction>) {
self.upcast::<GlobalScope>()
.queue_function_as_microtask(callback);
}

// https://html.spec.whatwg.org/multipage/#dom-window
fn Window(&self) -> DomRoot<WindowProxy> {
self.window_proxy()
Expand Down
7 changes: 7 additions & 0 deletions components/script/dom/workerglobalscope.rs
Expand Up @@ -5,6 +5,7 @@
use crate::compartments::InCompartment;
use crate::dom::bindings::cell::{DomRefCell, Ref};
use crate::dom::bindings::codegen::Bindings::RequestBinding::RequestInit;
use crate::dom::bindings::codegen::Bindings::VoidFunctionBinding::VoidFunction;
use crate::dom::bindings::codegen::Bindings::WorkerBinding::WorkerType;
use crate::dom::bindings::codegen::Bindings::WorkerGlobalScopeBinding::WorkerGlobalScopeMethods;
use crate::dom::bindings::codegen::UnionTypes::{RequestOrUSVString, StringOrFunction};
Expand Down Expand Up @@ -341,6 +342,12 @@ impl WorkerGlobalScopeMethods for WorkerGlobalScope {
self.ClearTimeout(handle);
}

// https://html.spec.whatwg.org/multipage/#dom-queuemicrotask
fn QueueMicrotask(&self, callback: Rc<VoidFunction>) {
self.upcast::<GlobalScope>()
.queue_function_as_microtask(callback);
}

#[allow(unrooted_must_root)]
// https://fetch.spec.whatwg.org/#fetch-method
fn Fetch(
Expand Down
16 changes: 16 additions & 0 deletions components/script/microtask.rs
Expand Up @@ -9,6 +9,7 @@
use crate::dom::bindings::callback::ExceptionHandling;
use crate::dom::bindings::cell::DomRefCell;
use crate::dom::bindings::codegen::Bindings::PromiseBinding::PromiseJobCallback;
use crate::dom::bindings::codegen::Bindings::VoidFunctionBinding::VoidFunction;
use crate::dom::bindings::root::DomRoot;
use crate::dom::globalscope::GlobalScope;
use crate::dom::htmlimageelement::ImageElementMicrotask;
Expand All @@ -34,6 +35,7 @@ pub struct MicrotaskQueue {
#[derive(JSTraceable, MallocSizeOf)]
pub enum Microtask {
Promise(EnqueuedPromiseCallback),
User(UserMicrotask),
MediaElement(MediaElementMicrotask),
ImageElement(ImageElementMicrotask),
CustomElementReaction,
Expand All @@ -52,6 +54,15 @@ pub struct EnqueuedPromiseCallback {
pub pipeline: PipelineId,
}

/// A microtask that comes from a queueMicrotask() Javascript call,
/// identical to EnqueuedPromiseCallback once it's on the queue
#[derive(JSTraceable, MallocSizeOf)]
pub struct UserMicrotask {
#[ignore_malloc_size_of = "Rc has unclear ownership"]
pub callback: Rc<VoidFunction>,
pub pipeline: PipelineId,
}

impl MicrotaskQueue {
/// Add a new microtask to this queue. It will be invoked as part of the next
/// microtask checkpoint.
Expand Down Expand Up @@ -95,6 +106,11 @@ impl MicrotaskQueue {
let _ = job.callback.Call_(&*target, ExceptionHandling::Report);
}
},
Microtask::User(ref job) => {
if let Some(target) = target_provider(job.pipeline) {
let _ = job.callback.Call_(&*target, ExceptionHandling::Report);
}
},
Microtask::MediaElement(ref task) => {
task.handler();
},
Expand Down
Expand Up @@ -53,6 +53,3 @@
[Window method: createImageBitmap]
expected: FAIL

[Window method: queueMicrotask]
expected: FAIL

9 changes: 0 additions & 9 deletions tests/wpt/metadata/html/dom/idlharness.https.html.ini
Expand Up @@ -1501,9 +1501,6 @@
[Document interface: attribute all]
expected: FAIL

[Window interface: window must inherit property "queueMicrotask(VoidFunction)" with the proper type]
expected: FAIL

[Document interface: calling execCommand(DOMString, boolean, DOMString) on new Document() with too few arguments must throw TypeError]
expected: FAIL

Expand Down Expand Up @@ -1570,9 +1567,6 @@
[Window interface: window must inherit property "scrollbars" with the proper type]
expected: FAIL

[Window interface: calling queueMicrotask(VoidFunction) on window with too few arguments must throw TypeError]
expected: FAIL

[Window interface: attribute personalbar]
expected: FAIL

Expand Down Expand Up @@ -1711,9 +1705,6 @@
[Document interface: iframe.contentDocument must inherit property "queryCommandState(DOMString)" with the proper type]
expected: FAIL

[Window interface: operation queueMicrotask(VoidFunction)]
expected: FAIL

[Window interface: internal [[SetPrototypeOf\]\] method of interface prototype object - setting to a new value via Object.setPrototypeOf should throw a TypeError]
expected: FAIL

Expand Down
9 changes: 0 additions & 9 deletions tests/wpt/metadata/html/dom/idlharness.worker.js.ini
Expand Up @@ -98,9 +98,6 @@
[OffscreenCanvasRenderingContext2D interface: attribute shadowColor]
expected: FAIL
[WorkerGlobalScope interface: self must inherit property "queueMicrotask(VoidFunction)" with the proper type]
expected: FAIL
[DedicatedWorkerGlobalScope interface: attribute name]
expected: FAIL
Expand All @@ -125,9 +122,6 @@
[OffscreenCanvasRenderingContext2D interface: operation translate(unrestricted double, unrestricted double)]
expected: FAIL

[WorkerGlobalScope interface: operation queueMicrotask(VoidFunction)]
expected: FAIL

[Path2D interface: operation moveTo(unrestricted double, unrestricted double)]
expected: FAIL

Expand Down Expand Up @@ -158,9 +152,6 @@
[WorkerGlobalScope interface: self must inherit property "createImageBitmap(ImageBitmapSource, ImageBitmapOptions)" with the proper type]
expected: FAIL

[WorkerGlobalScope interface: calling queueMicrotask(VoidFunction) on self with too few arguments must throw TypeError]
expected: FAIL

[DedicatedWorkerGlobalScope interface: self must inherit property "cancelAnimationFrame(unsigned long)" with the proper type]
expected: FAIL

Expand Down
@@ -1,8 +1,3 @@
[queue-microtask-exceptions.any.html]
[It rethrows exceptions]
expected: FAIL


[queue-microtask-exceptions.any.serviceworker.html]
expected: ERROR
[queue-microtask-exceptions]
Expand All @@ -18,9 +13,3 @@
expected: ERROR
[queue-microtask-exceptions]
expected: FAIL


[queue-microtask-exceptions.any.worker.html]
[It rethrows exceptions]
expected: FAIL

@@ -1,20 +1,3 @@
[queue-microtask.any.html]
[It exists and is a function]
expected: FAIL

[It does not pass any arguments]
expected: FAIL

[It calls the callback asynchronously]
expected: FAIL

[It throws when given non-functions]
expected: FAIL

[It interleaves with promises as expected]
expected: FAIL


[queue-microtask.any.serviceworker.html]
expected: ERROR
[queue-microtask]
Expand All @@ -31,21 +14,3 @@
expected: TIMEOUT
[queue-microtask]
expected: FAIL


[queue-microtask.any.worker.html]
[It exists and is a function]
expected: FAIL

[It does not pass any arguments]
expected: FAIL

[It calls the callback asynchronously]
expected: FAIL

[It throws when given non-functions]
expected: FAIL

[It interleaves with promises as expected]
expected: FAIL

This file was deleted.

0 comments on commit b01b2d3

Please sign in to comment.