// 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-gen.h" #include "src/builtins/builtins-utils-gen.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 { using compiler::Node; namespace { class AsyncFromSyncBuiltinsAssembler : public AsyncBuiltinsAssembler { public: explicit AsyncFromSyncBuiltinsAssembler(compiler::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; typedef std::function<Node*(Node*)> SyncIteratorNodeGenerator; void Generate_AsyncFromSyncIteratorMethod( Node* const context, Node* const iterator, Node* const sent_value, const SyncIteratorNodeGenerator& get_method, const UndefinedMethodHandler& if_method_undefined, const char* operation_name, Label::Type reject_label_type = Label::kDeferred, Node* const initial_exception_value = nullptr); void Generate_AsyncFromSyncIteratorMethodOptimized( Node* const context, Node* const iterator, Node* const sent_value, const SyncIteratorNodeGenerator& get_method, const UndefinedMethodHandler& if_method_undefined, const char* operation_name, Label::Type reject_label_type = Label::kDeferred, Node* const initial_exception_value = nullptr); void Generate_AsyncFromSyncIteratorMethod( Node* const context, Node* const iterator, Node* const sent_value, Handle<String> name, const UndefinedMethodHandler& if_method_undefined, const char* operation_name, Label::Type reject_label_type = Label::kDeferred, Node* const initial_exception_value = nullptr) { auto get_method = [=](Node* const sync_iterator) { return GetProperty(context, sync_iterator, name); }; return Generate_AsyncFromSyncIteratorMethod( context, iterator, sent_value, get_method, if_method_undefined, operation_name, reject_label_type, initial_exception_value); } void Generate_AsyncFromSyncIteratorMethodOptimized( Node* const context, Node* const iterator, Node* const sent_value, Handle<String> name, const UndefinedMethodHandler& if_method_undefined, const char* operation_name, Label::Type reject_label_type = Label::kDeferred, Node* const initial_exception_value = nullptr) { auto get_method = [=](Node* const sync_iterator) { return GetProperty(context, sync_iterator, name); }; return Generate_AsyncFromSyncIteratorMethodOptimized( context, iterator, sent_value, get_method, if_method_undefined, operation_name, reject_label_type, initial_exception_value); } // 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); }; 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, StringConstant(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, const SyncIteratorNodeGenerator& get_method, const 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, 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 = get_method(sync_iterator); 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 »). CallBuiltin(Builtins::kResolvePromise, 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). Return(CallBuiltin(Builtins::kPerformPromiseThen, context, wrapper, on_fulfilled, UndefinedConstant(), promise)); BIND(&reject_promise); { Node* const exception = var_exception.value(); CallBuiltin(Builtins::kRejectPromise, context, promise, exception, TrueConstant()); Return(promise); } } void AsyncFromSyncBuiltinsAssembler:: Generate_AsyncFromSyncIteratorMethodOptimized( Node* const context, Node* const iterator, Node* const sent_value, const SyncIteratorNodeGenerator& get_method, const 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, 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 = get_method(sync_iterator); 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 promise_fun = LoadContextElement(native_context, Context::PROMISE_FUNCTION_INDEX); CSA_ASSERT(this, IsConstructor(promise_fun)); // Let valueWrapper be ? PromiseResolve(« value »). Node* const valueWrapper = CallBuiltin(Builtins::kPromiseResolve, native_context, promise_fun, 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(valueWrapper, // onFulfilled, undefined, promiseCapability). Return(CallBuiltin(Builtins::kPerformPromiseThen, context, valueWrapper, on_fulfilled, UndefinedConstant(), promise)); BIND(&reject_promise); { Node* const exception = var_exception.value(); CallBuiltin(Builtins::kRejectPromise, 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, MachineRepresentation::kTagged); VARIABLE(var_done, MachineRepresentation::kTagged); Branch(WordEqual(iter_result_map, fast_iter_result_map), &if_fastpath, &if_slowpath); BIND(&if_fastpath); { var_done.Bind(LoadObjectField(iter_result, JSIteratorResult::kDoneOffset)); var_value.Bind( LoadObjectField(iter_result, JSIteratorResult::kValueOffset)); Goto(&merge); } BIND(&if_slowpath); { // Let nextDone be IteratorComplete(nextResult). // IfAbruptRejectPromise(nextDone, promiseCapability). Node* const done = GetProperty(context, iter_result, factory()->done_string()); GotoIfException(done, if_exception, var_exception); // Let nextValue be IteratorValue(nextResult). // IfAbruptRejectPromise(nextValue, promiseCapability). Node* const value = GetProperty(context, iter_result, factory()->value_string()); GotoIfException(value, 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 = CallBuiltin(Builtins::kToBoolean, context, var_done.value()); var_done.Bind(result); Goto(&done); } BIND(&done); return std::make_pair(var_value.value(), var_done.value()); } } // namespace // https://tc39.github.io/proposal-async-iteration/ // Section #sec-%asyncfromsynciteratorprototype%.next TF_BUILTIN(AsyncFromSyncIteratorPrototypeNext, AsyncFromSyncBuiltinsAssembler) { Node* const iterator = Parameter(Descriptor::kReceiver); Node* const value = Parameter(Descriptor::kValue); Node* const context = Parameter(Descriptor::kContext); auto get_method = [=](Node* const unused) { return LoadObjectField(iterator, JSAsyncFromSyncIterator::kNextOffset); }; Generate_AsyncFromSyncIteratorMethod( context, iterator, value, get_method, UndefinedMethodHandler(), "[Async-from-Sync Iterator].prototype.next"); } TF_BUILTIN(AsyncFromSyncIteratorPrototypeNextOptimized, AsyncFromSyncBuiltinsAssembler) { Node* const iterator = Parameter(Descriptor::kReceiver); Node* const value = Parameter(Descriptor::kValue); Node* const context = Parameter(Descriptor::kContext); auto get_method = [=](Node* const unused) { return LoadObjectField(iterator, JSAsyncFromSyncIterator::kNextOffset); }; Generate_AsyncFromSyncIteratorMethodOptimized( context, iterator, value, get_method, 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(Descriptor::kReceiver); Node* const value = Parameter(Descriptor::kValue); Node* const context = Parameter(Descriptor::kContext); 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 = CallBuiltin(Builtins::kCreateIterResultObject, context, value, TrueConstant()); // Perform ! Call(promiseCapability.[[Resolve]], undefined, « iterResult »). // IfAbruptRejectPromise(nextDone, promiseCapability). // Return promiseCapability.[[Promise]]. CallBuiltin(Builtins::kResolvePromise, context, promise, iter_result); Return(promise); }; Generate_AsyncFromSyncIteratorMethod( context, iterator, value, factory()->return_string(), if_return_undefined, "[Async-from-Sync Iterator].prototype.return"); } TF_BUILTIN(AsyncFromSyncIteratorPrototypeReturnOptimized, AsyncFromSyncBuiltinsAssembler) { Node* const iterator = Parameter(Descriptor::kReceiver); Node* const value = Parameter(Descriptor::kValue); Node* const context = Parameter(Descriptor::kContext); 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 = CallBuiltin(Builtins::kCreateIterResultObject, context, value, TrueConstant()); // Perform ! Call(promiseCapability.[[Resolve]], undefined, « iterResult »). // IfAbruptRejectPromise(nextDone, promiseCapability). // Return promiseCapability.[[Promise]]. CallBuiltin(Builtins::kResolvePromise, context, promise, iter_result); Return(promise); }; Generate_AsyncFromSyncIteratorMethodOptimized( 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(Descriptor::kReceiver); Node* const reason = Parameter(Descriptor::kReason); Node* const context = Parameter(Descriptor::kContext); 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(AsyncFromSyncIteratorPrototypeThrowOptimized, AsyncFromSyncBuiltinsAssembler) { Node* const iterator = Parameter(Descriptor::kReceiver); Node* const reason = Parameter(Descriptor::kReason); Node* const context = Parameter(Descriptor::kContext); auto if_throw_undefined = [=](Node* const native_context, Node* const promise, Label* if_exception) { Goto(if_exception); }; Generate_AsyncFromSyncIteratorMethodOptimized( context, iterator, reason, factory()->throw_string(), if_throw_undefined, "[Async-from-Sync Iterator].prototype.throw", Label::kNonDeferred, reason); } } // namespace internal } // namespace v8