Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(627)

Unified Diff: third_party/WebKit/Source/core/workers/WorkletPendingTasks.cpp

Issue 2839123003: Worklet: Introduce "pending tasks struct" concept defined in the Worklet spec (Closed)
Patch Set: address review comments Created 3 years, 8 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
Index: third_party/WebKit/Source/core/workers/WorkletPendingTasks.cpp
diff --git a/third_party/WebKit/Source/core/workers/WorkletPendingTasks.cpp b/third_party/WebKit/Source/core/workers/WorkletPendingTasks.cpp
new file mode 100644
index 0000000000000000000000000000000000000000..211e1ed2327591b06b35a8e0f07dba76a3e52fea
--- /dev/null
+++ b/third_party/WebKit/Source/core/workers/WorkletPendingTasks.cpp
@@ -0,0 +1,47 @@
+// Copyright 2017 The Chromium Authors. All rights reserved.
+// Use of this source code is governed by a BSD-style license that can be
+// found in the LICENSE file.
+
+#include "core/workers/WorkletPendingTasks.h"
+
+#include "core/dom/DOMException.h"
+#include "core/dom/ExceptionCode.h"
+#include "platform/wtf/WTF.h"
+
+namespace blink {
+
+WorkletPendingTasks::WorkletPendingTasks(int counter,
+ ScriptPromiseResolver* resolver)
+ : counter_(counter), resolver_(resolver) {
+ DCHECK(IsMainThread());
+}
+
+void WorkletPendingTasks::Abort() {
+ DCHECK(IsMainThread());
+ // Step 3: "If script is null, then queue a task on outsideSettings's
+ // responsible event loop to run these steps:"
+ // 1: "If pendingTaskStruct's counter is not -1, then run these steps:"
+ // 1: "Set pendingTaskStruct's counter to -1."
+ // 2: "Reject promise with an "AbortError" DOMException."
+ if (counter_ != -1) {
+ counter_ = -1;
+ // TODO(nhiroki): This should be kAbortError.
+ resolver_->Reject(DOMException::Create(kNetworkError));
+ }
+}
+
+void WorkletPendingTasks::DecrementCounter() {
+ DCHECK(IsMainThread());
+ // Step 5: "Queue a task on outsideSettings's responsible event loop to run
+ // these steps:"
+ // 1: "If pendingTaskStruct's counter is not -1, then run these steps:"
+ // 1: "Decrement pendingTaskStruct's counter by 1."
+ // 2: "If pendingTaskStruct's counter is 0, then resolve promise."
+ if (counter_ != -1) {
+ --counter_;
+ if (counter_ == 0)
+ resolver_->Resolve();
+ }
+}
+
+} // namespace blink

Powered by Google App Engine
This is Rietveld 408576698