| Index: src/builtins/builtins-async-iterator.cc
|
| diff --git a/src/builtins/builtins-async-iterator.cc b/src/builtins/builtins-async-iterator.cc
|
| deleted file mode 100644
|
| index 13d15ef2c6047e5c6f543bc2b33c21f93920549d..0000000000000000000000000000000000000000
|
| --- a/src/builtins/builtins-async-iterator.cc
|
| +++ /dev/null
|
| @@ -1,326 +0,0 @@
|
| -// Copyright 2017 the V8 project 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 "src/builtins/builtins-async.h"
|
| -#include "src/builtins/builtins-utils.h"
|
| -#include "src/builtins/builtins.h"
|
| -#include "src/code-factory.h"
|
| -#include "src/code-stub-assembler.h"
|
| -#include "src/frames-inl.h"
|
| -
|
| -namespace v8 {
|
| -namespace internal {
|
| -
|
| -namespace {
|
| -
|
| -// Describe fields of Context associated with the AsyncIterator unwrap closure.
|
| -class ValueUnwrapContext {
|
| - public:
|
| - enum Fields { kDoneSlot = Context::MIN_CONTEXT_SLOTS, kLength };
|
| -};
|
| -
|
| -class AsyncFromSyncBuiltinsAssembler : public AsyncBuiltinsAssembler {
|
| - public:
|
| - explicit AsyncFromSyncBuiltinsAssembler(CodeAssemblerState* state)
|
| - : AsyncBuiltinsAssembler(state) {}
|
| -
|
| - void ThrowIfNotAsyncFromSyncIterator(Node* const context, Node* const object,
|
| - Label* if_exception,
|
| - Variable* var_exception,
|
| - const char* method_name);
|
| -
|
| - typedef std::function<void(Node* const context, Node* const promise,
|
| - Label* if_exception)>
|
| - UndefinedMethodHandler;
|
| - void Generate_AsyncFromSyncIteratorMethod(
|
| - Node* const context, Node* const iterator, Node* const sent_value,
|
| - Handle<Name> method_name, UndefinedMethodHandler&& if_method_undefined,
|
| - const char* operation_name,
|
| - Label::Type reject_label_type = Label::kDeferred,
|
| - Node* const initial_exception_value = nullptr);
|
| -
|
| - Node* AllocateAsyncIteratorValueUnwrapContext(Node* native_context,
|
| - Node* done);
|
| -
|
| - // Load "value" and "done" from an iterator result object. If an exception
|
| - // is thrown at any point, jumps to te `if_exception` label with exception
|
| - // stored in `var_exception`.
|
| - //
|
| - // Returns a Pair of Nodes, whose first element is the value of the "value"
|
| - // property, and whose second element is the value of the "done" property,
|
| - // converted to a Boolean if needed.
|
| - std::pair<Node*, Node*> LoadIteratorResult(Node* const context,
|
| - Node* const native_context,
|
| - Node* const iter_result,
|
| - Label* if_exception,
|
| - Variable* var_exception);
|
| -
|
| - Node* CreateUnwrapClosure(Node* const native_context, Node* const done);
|
| -};
|
| -
|
| -void AsyncFromSyncBuiltinsAssembler::ThrowIfNotAsyncFromSyncIterator(
|
| - Node* const context, Node* const object, Label* if_exception,
|
| - Variable* var_exception, const char* method_name) {
|
| - Label if_receiverisincompatible(this, Label::kDeferred), done(this);
|
| -
|
| - GotoIf(TaggedIsSmi(object), &if_receiverisincompatible);
|
| - Branch(HasInstanceType(object, JS_ASYNC_FROM_SYNC_ITERATOR_TYPE), &done,
|
| - &if_receiverisincompatible);
|
| -
|
| - Bind(&if_receiverisincompatible);
|
| - {
|
| - // If Type(O) is not Object, or if O does not have a [[SyncIterator]]
|
| - // internal slot, then
|
| -
|
| - // Let badIteratorError be a new TypeError exception.
|
| - Node* const error =
|
| - MakeTypeError(MessageTemplate::kIncompatibleMethodReceiver, context,
|
| - CStringConstant(method_name), object);
|
| -
|
| - // Perform ! Call(promiseCapability.[[Reject]], undefined,
|
| - // « badIteratorError »).
|
| - var_exception->Bind(error);
|
| - Goto(if_exception);
|
| - }
|
| -
|
| - Bind(&done);
|
| -}
|
| -
|
| -void AsyncFromSyncBuiltinsAssembler::Generate_AsyncFromSyncIteratorMethod(
|
| - Node* const context, Node* const iterator, Node* const sent_value,
|
| - Handle<Name> method_name, UndefinedMethodHandler&& if_method_undefined,
|
| - const char* operation_name, Label::Type reject_label_type,
|
| - Node* const initial_exception_value) {
|
| - Node* const native_context = LoadNativeContext(context);
|
| - Node* const promise = AllocateAndInitJSPromise(context);
|
| -
|
| - Variable var_exception(this, MachineRepresentation::kTagged,
|
| - initial_exception_value == nullptr
|
| - ? UndefinedConstant()
|
| - : initial_exception_value);
|
| - Label reject_promise(this, reject_label_type);
|
| -
|
| - ThrowIfNotAsyncFromSyncIterator(context, iterator, &reject_promise,
|
| - &var_exception, operation_name);
|
| -
|
| - Node* const sync_iterator =
|
| - LoadObjectField(iterator, JSAsyncFromSyncIterator::kSyncIteratorOffset);
|
| -
|
| - Node* const method = GetProperty(context, sync_iterator, method_name);
|
| -
|
| - if (if_method_undefined) {
|
| - Label if_isnotundefined(this);
|
| -
|
| - GotoIfNot(IsUndefined(method), &if_isnotundefined);
|
| - if_method_undefined(native_context, promise, &reject_promise);
|
| -
|
| - Bind(&if_isnotundefined);
|
| - }
|
| -
|
| - Node* const iter_result = CallJS(CodeFactory::Call(isolate()), context,
|
| - method, sync_iterator, sent_value);
|
| - GotoIfException(iter_result, &reject_promise, &var_exception);
|
| -
|
| - Node* value;
|
| - Node* done;
|
| - std::tie(value, done) = LoadIteratorResult(
|
| - context, native_context, iter_result, &reject_promise, &var_exception);
|
| - Node* const wrapper = AllocateAndInitJSPromise(context);
|
| -
|
| - // Perform ! Call(valueWrapperCapability.[[Resolve]], undefined, «
|
| - // throwValue »).
|
| - InternalResolvePromise(context, wrapper, value);
|
| -
|
| - // Let onFulfilled be a new built-in function object as defined in
|
| - // Async Iterator Value Unwrap Functions.
|
| - // Set onFulfilled.[[Done]] to throwDone.
|
| - Node* const on_fulfilled = CreateUnwrapClosure(native_context, done);
|
| -
|
| - // Perform ! PerformPromiseThen(valueWrapperCapability.[[Promise]],
|
| - // onFulfilled, undefined, promiseCapability).
|
| - Node* const undefined = UndefinedConstant();
|
| - InternalPerformPromiseThen(context, wrapper, on_fulfilled, undefined, promise,
|
| - undefined, undefined);
|
| - Return(promise);
|
| -
|
| - Bind(&reject_promise);
|
| - {
|
| - Node* const exception = var_exception.value();
|
| - InternalPromiseReject(context, promise, exception, TrueConstant());
|
| -
|
| - Return(promise);
|
| - }
|
| -}
|
| -
|
| -std::pair<Node*, Node*> AsyncFromSyncBuiltinsAssembler::LoadIteratorResult(
|
| - Node* const context, Node* const native_context, Node* const iter_result,
|
| - Label* if_exception, Variable* var_exception) {
|
| - Label if_fastpath(this), if_slowpath(this), merge(this), to_boolean(this),
|
| - done(this), if_notanobject(this, Label::kDeferred);
|
| - GotoIf(TaggedIsSmi(iter_result), &if_notanobject);
|
| -
|
| - Node* const iter_result_map = LoadMap(iter_result);
|
| - GotoIfNot(IsJSReceiverMap(iter_result_map), &if_notanobject);
|
| -
|
| - Node* const fast_iter_result_map =
|
| - LoadContextElement(native_context, Context::ITERATOR_RESULT_MAP_INDEX);
|
| -
|
| - Variable var_value(this, MachineRepresentation::kTagged);
|
| - Variable var_done(this, MachineRepresentation::kTagged);
|
| - Branch(WordEqual(iter_result_map, fast_iter_result_map), &if_fastpath,
|
| - &if_slowpath);
|
| -
|
| - Bind(&if_fastpath);
|
| - {
|
| - var_value.Bind(
|
| - LoadObjectField(iter_result, JSIteratorResult::kValueOffset));
|
| - var_done.Bind(LoadObjectField(iter_result, JSIteratorResult::kDoneOffset));
|
| - Goto(&merge);
|
| - }
|
| -
|
| - Bind(&if_slowpath);
|
| - {
|
| - // Let nextValue be IteratorValue(nextResult).
|
| - // IfAbruptRejectPromise(nextValue, promiseCapability).
|
| - Node* const value =
|
| - GetProperty(context, iter_result, factory()->value_string());
|
| - GotoIfException(value, if_exception, var_exception);
|
| -
|
| - // Let nextDone be IteratorComplete(nextResult).
|
| - // IfAbruptRejectPromise(nextDone, promiseCapability).
|
| - Node* const done =
|
| - GetProperty(context, iter_result, factory()->done_string());
|
| - GotoIfException(done, if_exception, var_exception);
|
| -
|
| - var_value.Bind(value);
|
| - var_done.Bind(done);
|
| - Goto(&merge);
|
| - }
|
| -
|
| - Bind(&if_notanobject);
|
| - {
|
| - // Sync iterator result is not an object --- Produce a TypeError and jump
|
| - // to the `if_exception` path.
|
| - Node* const error = MakeTypeError(
|
| - MessageTemplate::kIteratorResultNotAnObject, context, iter_result);
|
| - var_exception->Bind(error);
|
| - Goto(if_exception);
|
| - }
|
| -
|
| - Bind(&merge);
|
| - // Ensure `iterResult.done` is a Boolean.
|
| - GotoIf(TaggedIsSmi(var_done.value()), &to_boolean);
|
| - Branch(IsBoolean(var_done.value()), &done, &to_boolean);
|
| -
|
| - Bind(&to_boolean);
|
| - {
|
| - Node* const result =
|
| - CallStub(CodeFactory::ToBoolean(isolate()), context, var_done.value());
|
| - var_done.Bind(result);
|
| - Goto(&done);
|
| - }
|
| -
|
| - Bind(&done);
|
| - return std::make_pair(var_value.value(), var_done.value());
|
| -}
|
| -
|
| -Node* AsyncFromSyncBuiltinsAssembler::CreateUnwrapClosure(Node* native_context,
|
| - Node* done) {
|
| - Node* const map = LoadContextElement(
|
| - native_context, Context::STRICT_FUNCTION_WITHOUT_PROTOTYPE_MAP_INDEX);
|
| - Node* const on_fulfilled_shared = LoadContextElement(
|
| - native_context, Context::ASYNC_ITERATOR_VALUE_UNWRAP_SHARED_FUN);
|
| - CSA_ASSERT(this,
|
| - HasInstanceType(on_fulfilled_shared, SHARED_FUNCTION_INFO_TYPE));
|
| - Node* const closure_context =
|
| - AllocateAsyncIteratorValueUnwrapContext(native_context, done);
|
| - return AllocateFunctionWithMapAndContext(map, on_fulfilled_shared,
|
| - closure_context);
|
| -}
|
| -
|
| -Node* AsyncFromSyncBuiltinsAssembler::AllocateAsyncIteratorValueUnwrapContext(
|
| - Node* native_context, Node* done) {
|
| - CSA_ASSERT(this, IsNativeContext(native_context));
|
| - CSA_ASSERT(this, IsBoolean(done));
|
| -
|
| - Node* const context =
|
| - CreatePromiseContext(native_context, ValueUnwrapContext::kLength);
|
| - StoreContextElementNoWriteBarrier(context, ValueUnwrapContext::kDoneSlot,
|
| - done);
|
| - return context;
|
| -}
|
| -} // namespace
|
| -
|
| -// https://tc39.github.io/proposal-async-iteration/
|
| -// Section #sec-%asyncfromsynciteratorprototype%.next
|
| -TF_BUILTIN(AsyncFromSyncIteratorPrototypeNext, AsyncFromSyncBuiltinsAssembler) {
|
| - Node* const iterator = Parameter(0);
|
| - Node* const value = Parameter(1);
|
| - Node* const context = Parameter(4);
|
| -
|
| - Generate_AsyncFromSyncIteratorMethod(
|
| - context, iterator, value, factory()->next_string(),
|
| - UndefinedMethodHandler(), "[Async-from-Sync Iterator].prototype.next");
|
| -}
|
| -
|
| -// https://tc39.github.io/proposal-async-iteration/
|
| -// Section #sec-%asyncfromsynciteratorprototype%.return
|
| -TF_BUILTIN(AsyncFromSyncIteratorPrototypeReturn,
|
| - AsyncFromSyncBuiltinsAssembler) {
|
| - Node* const iterator = Parameter(0);
|
| - Node* const value = Parameter(1);
|
| - Node* const context = Parameter(4);
|
| -
|
| - auto if_return_undefined = [=](Node* const native_context,
|
| - Node* const promise, Label* if_exception) {
|
| - // If return is undefined, then
|
| - // Let iterResult be ! CreateIterResultObject(value, true)
|
| - Node* const iter_result =
|
| - CallStub(CodeFactory::CreateIterResultObject(isolate()), context, value,
|
| - TrueConstant());
|
| -
|
| - // Perform ! Call(promiseCapability.[[Resolve]], undefined, « iterResult »).
|
| - // IfAbruptRejectPromise(nextDone, promiseCapability).
|
| - // Return promiseCapability.[[Promise]].
|
| - PromiseFulfill(context, promise, iter_result, v8::Promise::kFulfilled);
|
| - Return(promise);
|
| - };
|
| -
|
| - Generate_AsyncFromSyncIteratorMethod(
|
| - context, iterator, value, factory()->return_string(), if_return_undefined,
|
| - "[Async-from-Sync Iterator].prototype.return");
|
| -}
|
| -
|
| -// https://tc39.github.io/proposal-async-iteration/
|
| -// Section #sec-%asyncfromsynciteratorprototype%.throw
|
| -TF_BUILTIN(AsyncFromSyncIteratorPrototypeThrow,
|
| - AsyncFromSyncBuiltinsAssembler) {
|
| - Node* const iterator = Parameter(0);
|
| - Node* const reason = Parameter(1);
|
| - Node* const context = Parameter(4);
|
| -
|
| - auto if_throw_undefined = [=](Node* const native_context, Node* const promise,
|
| - Label* if_exception) { Goto(if_exception); };
|
| -
|
| - Generate_AsyncFromSyncIteratorMethod(
|
| - context, iterator, reason, factory()->throw_string(), if_throw_undefined,
|
| - "[Async-from-Sync Iterator].prototype.throw", Label::kNonDeferred,
|
| - reason);
|
| -}
|
| -
|
| -TF_BUILTIN(AsyncIteratorValueUnwrap, AsyncFromSyncBuiltinsAssembler) {
|
| - Node* const value = Parameter(1);
|
| - Node* const context = Parameter(4);
|
| -
|
| - Node* const done = LoadContextElement(context, ValueUnwrapContext::kDoneSlot);
|
| - CSA_ASSERT(this, IsBoolean(done));
|
| -
|
| - Node* const unwrapped_value = CallStub(
|
| - CodeFactory::CreateIterResultObject(isolate()), context, value, done);
|
| -
|
| - Return(unwrapped_value);
|
| -}
|
| -
|
| -} // namespace internal
|
| -} // namespace v8
|
|
|