OLD | NEW |
1 // Copyright 2012 the V8 project authors. All rights reserved. | 1 // Copyright 2012 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 | 4 |
5 #include "src/isolate.h" | 5 #include "src/isolate.h" |
6 | 6 |
7 #include <stdlib.h> | 7 #include <stdlib.h> |
8 | 8 |
9 #include <fstream> // NOLINT(readability/streams) | 9 #include <fstream> // NOLINT(readability/streams) |
10 #include <sstream> | 10 #include <sstream> |
(...skipping 3118 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
3129 } | 3129 } |
3130 } | 3130 } |
3131 } else { | 3131 } else { |
3132 Handle<Object> deferred(info->deferred(), this); | 3132 Handle<Object> deferred(info->deferred(), this); |
3133 Handle<Object> argv[] = {value, tasks, deferred}; | 3133 Handle<Object> argv[] = {value, tasks, deferred}; |
3134 *result = Execution::TryCall(this, promise_handle_fn, undefined, | 3134 *result = Execution::TryCall(this, promise_handle_fn, undefined, |
3135 arraysize(argv), argv, maybe_exception); | 3135 arraysize(argv), argv, maybe_exception); |
3136 } | 3136 } |
3137 } | 3137 } |
3138 | 3138 |
3139 void Isolate::PromiseResolveThenableJob(Handle<PromiseContainer> container, | 3139 void Isolate::PromiseResolveThenableJob( |
3140 MaybeHandle<Object>* result, | 3140 Handle<PromiseResolveThenableJobInfo> info, MaybeHandle<Object>* result, |
3141 MaybeHandle<Object>* maybe_exception) { | 3141 MaybeHandle<Object>* maybe_exception) { |
3142 PromiseDebugEventScope helper(this, container->before_debug_event(), | 3142 PromiseDebugEventScope helper(this, info->before_debug_event(), |
3143 container->after_debug_event()); | 3143 info->after_debug_event()); |
3144 | 3144 |
3145 Handle<JSReceiver> thenable(container->thenable(), this); | 3145 Handle<JSReceiver> thenable(info->thenable(), this); |
3146 Handle<JSFunction> resolve(container->resolve(), this); | 3146 Handle<JSFunction> resolve(info->resolve(), this); |
3147 Handle<JSFunction> reject(container->reject(), this); | 3147 Handle<JSFunction> reject(info->reject(), this); |
3148 Handle<JSReceiver> then(container->then(), this); | 3148 Handle<JSReceiver> then(info->then(), this); |
3149 Handle<Object> argv[] = {resolve, reject}; | 3149 Handle<Object> argv[] = {resolve, reject}; |
3150 *result = Execution::TryCall(this, then, thenable, arraysize(argv), argv, | 3150 *result = Execution::TryCall(this, then, thenable, arraysize(argv), argv, |
3151 maybe_exception); | 3151 maybe_exception); |
3152 | 3152 |
3153 Handle<Object> reason; | 3153 Handle<Object> reason; |
3154 if (maybe_exception->ToHandle(&reason)) { | 3154 if (maybe_exception->ToHandle(&reason)) { |
3155 DCHECK(result->is_null()); | 3155 DCHECK(result->is_null()); |
3156 Handle<Object> reason_arg[] = {reason}; | 3156 Handle<Object> reason_arg[] = {reason}; |
3157 *result = | 3157 *result = |
3158 Execution::TryCall(this, reject, factory()->undefined_value(), | 3158 Execution::TryCall(this, reject, factory()->undefined_value(), |
3159 arraysize(reason_arg), reason_arg, maybe_exception); | 3159 arraysize(reason_arg), reason_arg, maybe_exception); |
3160 } | 3160 } |
3161 } | 3161 } |
3162 | 3162 |
3163 void Isolate::EnqueueMicrotask(Handle<Object> microtask) { | 3163 void Isolate::EnqueueMicrotask(Handle<Object> microtask) { |
3164 DCHECK(microtask->IsJSFunction() || microtask->IsCallHandlerInfo() || | 3164 DCHECK(microtask->IsJSFunction() || microtask->IsCallHandlerInfo() || |
3165 microtask->IsPromiseContainer() || | 3165 microtask->IsPromiseResolveThenableJobInfo() || |
3166 microtask->IsPromiseReactionJobInfo()); | 3166 microtask->IsPromiseReactionJobInfo()); |
3167 Handle<FixedArray> queue(heap()->microtask_queue(), this); | 3167 Handle<FixedArray> queue(heap()->microtask_queue(), this); |
3168 int num_tasks = pending_microtask_count(); | 3168 int num_tasks = pending_microtask_count(); |
3169 DCHECK(num_tasks <= queue->length()); | 3169 DCHECK(num_tasks <= queue->length()); |
3170 if (num_tasks == 0) { | 3170 if (num_tasks == 0) { |
3171 queue = factory()->NewFixedArray(8); | 3171 queue = factory()->NewFixedArray(8); |
3172 heap()->set_microtask_queue(*queue); | 3172 heap()->set_microtask_queue(*queue); |
3173 } else if (num_tasks == queue->length()) { | 3173 } else if (num_tasks == queue->length()) { |
3174 queue = factory()->CopyFixedArrayAndGrow(queue, num_tasks); | 3174 queue = factory()->CopyFixedArrayAndGrow(queue, num_tasks); |
3175 heap()->set_microtask_queue(*queue); | 3175 heap()->set_microtask_queue(*queue); |
(...skipping 35 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
3211 Handle<CallHandlerInfo>::cast(microtask); | 3211 Handle<CallHandlerInfo>::cast(microtask); |
3212 v8::MicrotaskCallback callback = | 3212 v8::MicrotaskCallback callback = |
3213 v8::ToCData<v8::MicrotaskCallback>(callback_info->callback()); | 3213 v8::ToCData<v8::MicrotaskCallback>(callback_info->callback()); |
3214 void* data = v8::ToCData<void*>(callback_info->data()); | 3214 void* data = v8::ToCData<void*>(callback_info->data()); |
3215 callback(data); | 3215 callback(data); |
3216 } else { | 3216 } else { |
3217 SaveContext save(this); | 3217 SaveContext save(this); |
3218 Context* context; | 3218 Context* context; |
3219 if (microtask->IsJSFunction()) { | 3219 if (microtask->IsJSFunction()) { |
3220 context = Handle<JSFunction>::cast(microtask)->context(); | 3220 context = Handle<JSFunction>::cast(microtask)->context(); |
3221 } else if (microtask->IsPromiseContainer()) { | 3221 } else if (microtask->IsPromiseResolveThenableJobInfo()) { |
3222 context = | 3222 context = Handle<PromiseResolveThenableJobInfo>::cast(microtask) |
3223 Handle<PromiseContainer>::cast(microtask)->resolve()->context(); | 3223 ->resolve() |
| 3224 ->context(); |
3224 } else { | 3225 } else { |
3225 context = Handle<PromiseReactionJobInfo>::cast(microtask)->context(); | 3226 context = Handle<PromiseReactionJobInfo>::cast(microtask)->context(); |
3226 } | 3227 } |
3227 | 3228 |
3228 set_context(context->native_context()); | 3229 set_context(context->native_context()); |
3229 handle_scope_implementer_->EnterMicrotaskContext( | 3230 handle_scope_implementer_->EnterMicrotaskContext( |
3230 Handle<Context>(context, this)); | 3231 Handle<Context>(context, this)); |
3231 | 3232 |
3232 MaybeHandle<Object> result; | 3233 MaybeHandle<Object> result; |
3233 MaybeHandle<Object> maybe_exception; | 3234 MaybeHandle<Object> maybe_exception; |
3234 | 3235 |
3235 if (microtask->IsJSFunction()) { | 3236 if (microtask->IsJSFunction()) { |
3236 Handle<JSFunction> microtask_function = | 3237 Handle<JSFunction> microtask_function = |
3237 Handle<JSFunction>::cast(microtask); | 3238 Handle<JSFunction>::cast(microtask); |
3238 result = Execution::TryCall(this, microtask_function, | 3239 result = Execution::TryCall(this, microtask_function, |
3239 factory()->undefined_value(), 0, NULL, | 3240 factory()->undefined_value(), 0, NULL, |
3240 &maybe_exception); | 3241 &maybe_exception); |
3241 } else if (microtask->IsPromiseContainer()) { | 3242 } else if (microtask->IsPromiseResolveThenableJobInfo()) { |
3242 PromiseResolveThenableJob(Handle<PromiseContainer>::cast(microtask), | 3243 PromiseResolveThenableJob( |
3243 &result, &maybe_exception); | 3244 Handle<PromiseResolveThenableJobInfo>::cast(microtask), &result, |
| 3245 &maybe_exception); |
3244 } else { | 3246 } else { |
3245 PromiseReactionJob(Handle<PromiseReactionJobInfo>::cast(microtask), | 3247 PromiseReactionJob(Handle<PromiseReactionJobInfo>::cast(microtask), |
3246 &result, &maybe_exception); | 3248 &result, &maybe_exception); |
3247 } | 3249 } |
3248 | 3250 |
3249 handle_scope_implementer_->LeaveMicrotaskContext(); | 3251 handle_scope_implementer_->LeaveMicrotaskContext(); |
3250 | 3252 |
3251 // If execution is terminating, just bail out. | 3253 // If execution is terminating, just bail out. |
3252 if (result.is_null() && maybe_exception.is_null()) { | 3254 if (result.is_null() && maybe_exception.is_null()) { |
3253 // Clear out any remaining callbacks in the queue. | 3255 // Clear out any remaining callbacks in the queue. |
(...skipping 195 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
3449 // Then check whether this scope intercepts. | 3451 // Then check whether this scope intercepts. |
3450 if ((flag & intercept_mask_)) { | 3452 if ((flag & intercept_mask_)) { |
3451 intercepted_flags_ |= flag; | 3453 intercepted_flags_ |= flag; |
3452 return true; | 3454 return true; |
3453 } | 3455 } |
3454 return false; | 3456 return false; |
3455 } | 3457 } |
3456 | 3458 |
3457 } // namespace internal | 3459 } // namespace internal |
3458 } // namespace v8 | 3460 } // namespace v8 |
OLD | NEW |