| OLD | NEW |
| 1 // Copyright 2016 the V8 project authors. All rights reserved. | 1 // Copyright 2016 the V8 project authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 #include "src/runtime/runtime-utils.h" | 4 #include "src/runtime/runtime-utils.h" |
| 5 | 5 |
| 6 #include "src/debug/debug.h" | 6 #include "src/debug/debug.h" |
| 7 #include "src/elements.h" | 7 #include "src/elements.h" |
| 8 #include "src/promise-utils.h" | 8 #include "src/promise-utils.h" |
| 9 | 9 |
| 10 namespace v8 { | 10 namespace v8 { |
| (...skipping 51 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 62 Handle<Object> deferred, Handle<Object> status) { | 62 Handle<Object> deferred, Handle<Object> status) { |
| 63 Handle<Object> debug_id = isolate->factory()->undefined_value(); | 63 Handle<Object> debug_id = isolate->factory()->undefined_value(); |
| 64 Handle<Object> debug_name = isolate->factory()->undefined_value(); | 64 Handle<Object> debug_name = isolate->factory()->undefined_value(); |
| 65 if (isolate->debug()->is_active()) { | 65 if (isolate->debug()->is_active()) { |
| 66 MaybeHandle<Object> maybe_result; | 66 MaybeHandle<Object> maybe_result; |
| 67 Handle<Object> deferred_obj(deferred); | 67 Handle<Object> deferred_obj(deferred); |
| 68 | 68 |
| 69 if (deferred->IsFixedArray()) { | 69 if (deferred->IsFixedArray()) { |
| 70 deferred_obj = isolate->factory()->undefined_value(); | 70 deferred_obj = isolate->factory()->undefined_value(); |
| 71 } | 71 } |
| 72 | 72 Handle<Object> argv[] = {deferred_obj, status, |
| 73 Handle<Object> argv[] = {deferred_obj, status}; | 73 isolate->debug()->NextAsyncTaskId(promise)}; |
| 74 maybe_result = Execution::TryCall( | 74 maybe_result = Execution::TryCall( |
| 75 isolate, isolate->promise_debug_get_info(), | 75 isolate, isolate->promise_debug_get_info(), |
| 76 isolate->factory()->undefined_value(), arraysize(argv), argv); | 76 isolate->factory()->undefined_value(), arraysize(argv), argv); |
| 77 | 77 |
| 78 Handle<Object> result; | 78 Handle<Object> result; |
| 79 if ((maybe_result).ToHandle(&result)) { | 79 if ((maybe_result).ToHandle(&result)) { |
| 80 CHECK(result->IsJSArray()); | 80 CHECK(result->IsJSArray()); |
| 81 Handle<JSArray> array = Handle<JSArray>::cast(result); | 81 Handle<JSArray> array = Handle<JSArray>::cast(result); |
| 82 ElementsAccessor* accessor = array->GetElementsAccessor(); | 82 ElementsAccessor* accessor = array->GetElementsAccessor(); |
| 83 DCHECK(accessor->HasElement(array, 0)); | 83 DCHECK(accessor->HasElement(array, 0)); |
| (...skipping 13 matching lines...) Expand all Loading... |
| 97 Handle<Object> result) { | 97 Handle<Object> result) { |
| 98 promise->set_status(status); | 98 promise->set_status(status); |
| 99 promise->set_result(*result); | 99 promise->set_result(*result); |
| 100 promise->set_deferred(isolate->heap()->undefined_value()); | 100 promise->set_deferred(isolate->heap()->undefined_value()); |
| 101 promise->set_fulfill_reactions(isolate->heap()->undefined_value()); | 101 promise->set_fulfill_reactions(isolate->heap()->undefined_value()); |
| 102 promise->set_reject_reactions(isolate->heap()->undefined_value()); | 102 promise->set_reject_reactions(isolate->heap()->undefined_value()); |
| 103 } | 103 } |
| 104 | 104 |
| 105 void PromiseFulfill(Isolate* isolate, Handle<JSPromise> promise, | 105 void PromiseFulfill(Isolate* isolate, Handle<JSPromise> promise, |
| 106 Handle<Smi> status, Handle<Object> value) { | 106 Handle<Smi> status, Handle<Object> value) { |
| 107 if (isolate->debug()->is_active()) { |
| 108 isolate->debug()->OnAsyncTaskEvent( |
| 109 debug::EnqueueRecurring, isolate->debug()->NextAsyncTaskId(promise), |
| 110 status->value() == kPromiseFulfilled |
| 111 ? isolate->factory()->PromiseResolve_string() |
| 112 : isolate->factory()->PromiseReject_string()); |
| 113 } |
| 114 |
| 107 // Check if there are any callbacks. | 115 // Check if there are any callbacks. |
| 108 if (!promise->deferred()->IsUndefined(isolate)) { | 116 if (!promise->deferred()->IsUndefined(isolate)) { |
| 109 Handle<Object> tasks((status->value() == kPromiseFulfilled) | 117 Handle<Object> tasks((status->value() == kPromiseFulfilled) |
| 110 ? promise->fulfill_reactions() | 118 ? promise->fulfill_reactions() |
| 111 : promise->reject_reactions(), | 119 : promise->reject_reactions(), |
| 112 isolate); | 120 isolate); |
| 113 Handle<Object> deferred(promise->deferred(), isolate); | 121 Handle<Object> deferred(promise->deferred(), isolate); |
| 114 EnqueuePromiseReactionJob(isolate, promise, value, tasks, deferred, status); | 122 EnqueuePromiseReactionJob(isolate, promise, value, tasks, deferred, status); |
| 115 } | 123 } |
| 116 | 124 |
| (...skipping 47 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 164 | 172 |
| 165 // TODO(gsathya): Add fast path for native promises with unmodified | 173 // TODO(gsathya): Add fast path for native promises with unmodified |
| 166 // PromiseThen (which don't need these resolving functions, but | 174 // PromiseThen (which don't need these resolving functions, but |
| 167 // instead can just call resolve/reject directly). | 175 // instead can just call resolve/reject directly). |
| 168 Handle<JSFunction> resolve, reject; | 176 Handle<JSFunction> resolve, reject; |
| 169 PromiseUtils::CreateResolvingFunctions( | 177 PromiseUtils::CreateResolvingFunctions( |
| 170 isolate, promise, isolate->factory()->false_value(), &resolve, &reject); | 178 isolate, promise, isolate->factory()->false_value(), &resolve, &reject); |
| 171 | 179 |
| 172 Handle<Object> debug_id, debug_name; | 180 Handle<Object> debug_id, debug_name; |
| 173 if (isolate->debug()->is_active()) { | 181 if (isolate->debug()->is_active()) { |
| 174 debug_id = | 182 debug_id = isolate->debug()->NextAsyncTaskId(promise); |
| 175 handle(Smi::FromInt(isolate->GetNextDebugMicrotaskId()), isolate); | |
| 176 debug_name = isolate->factory()->PromiseResolveThenableJob_string(); | 183 debug_name = isolate->factory()->PromiseResolveThenableJob_string(); |
| 177 isolate->debug()->OnAsyncTaskEvent(isolate->factory()->enqueue_string(), | |
| 178 debug_id, | |
| 179 Handle<String>::cast(debug_name)); | |
| 180 } else { | 184 } else { |
| 181 debug_id = isolate->factory()->undefined_value(); | 185 debug_id = isolate->factory()->undefined_value(); |
| 182 debug_name = isolate->factory()->undefined_value(); | 186 debug_name = isolate->factory()->undefined_value(); |
| 183 } | 187 } |
| 184 | 188 |
| 185 Handle<PromiseResolveThenableJobInfo> info = | 189 Handle<PromiseResolveThenableJobInfo> info = |
| 186 isolate->factory()->NewPromiseResolveThenableJobInfo( | 190 isolate->factory()->NewPromiseResolveThenableJobInfo( |
| 187 resolution, then, resolve, reject, debug_id, debug_name, | 191 resolution, then, resolve, reject, debug_id, debug_name, |
| 188 isolate->native_context()); | 192 isolate->native_context()); |
| 189 isolate->EnqueueMicrotask(info); | 193 isolate->EnqueueMicrotask(info); |
| (...skipping 89 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 279 HandleScope scope(isolate); | 283 HandleScope scope(isolate); |
| 280 DCHECK(args.length() == 1); | 284 DCHECK(args.length() == 1); |
| 281 CONVERT_ARG_HANDLE_CHECKED(JSPromise, promise, 0); | 285 CONVERT_ARG_HANDLE_CHECKED(JSPromise, promise, 0); |
| 282 | 286 |
| 283 promise->set_has_handler(true); | 287 promise->set_has_handler(true); |
| 284 return isolate->heap()->undefined_value(); | 288 return isolate->heap()->undefined_value(); |
| 285 } | 289 } |
| 286 | 290 |
| 287 } // namespace internal | 291 } // namespace internal |
| 288 } // namespace v8 | 292 } // namespace v8 |
| OLD | NEW |