| 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 (function(global, utils, extrasUtils) { | 5 (function(global, utils, extrasUtils) { |
| 6 | 6 |
| 7 "use strict"; | 7 "use strict"; |
| 8 | 8 |
| 9 %CheckIsBootstrapping(); | 9 %CheckIsBootstrapping(); |
| 10 | 10 |
| (...skipping 31 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 42 }); | 42 }); |
| 43 | 43 |
| 44 // ------------------------------------------------------------------- | 44 // ------------------------------------------------------------------- |
| 45 | 45 |
| 46 // [[PromiseState]] values: | 46 // [[PromiseState]] values: |
| 47 // These values should be kept in sync with PromiseStatus in globals.h | 47 // These values should be kept in sync with PromiseStatus in globals.h |
| 48 const kPending = 0; | 48 const kPending = 0; |
| 49 const kFulfilled = +1; | 49 const kFulfilled = +1; |
| 50 const kRejected = +2; | 50 const kRejected = +2; |
| 51 | 51 |
| 52 // ES#sec-createresolvingfunctions | 52 const kResolveCallback = 0; |
| 53 // CreateResolvingFunctions ( promise ) | 53 const kRejectCallback = 1; |
| 54 function CreateResolvingFunctions(promise, debugEvent) { | |
| 55 var alreadyResolved = false; | |
| 56 | |
| 57 // ES#sec-promise-resolve-functions | |
| 58 // Promise Resolve Functions | |
| 59 var resolve = value => { | |
| 60 if (alreadyResolved === true) return; | |
| 61 alreadyResolved = true; | |
| 62 ResolvePromise(promise, value); | |
| 63 }; | |
| 64 | |
| 65 // ES#sec-promise-reject-functions | |
| 66 // Promise Reject Functions | |
| 67 var reject = reason => { | |
| 68 if (alreadyResolved === true) return; | |
| 69 alreadyResolved = true; | |
| 70 %PromiseReject(promise, reason, debugEvent); | |
| 71 PromiseSet(promise, kRejected, reason); | |
| 72 }; | |
| 73 | |
| 74 return { | |
| 75 __proto__: null, | |
| 76 resolve: resolve, | |
| 77 reject: reject | |
| 78 }; | |
| 79 } | |
| 80 | |
| 81 | 54 |
| 82 // ES#sec-promise-executor | 55 // ES#sec-promise-executor |
| 83 // Promise ( executor ) | 56 // Promise ( executor ) |
| 84 var GlobalPromise = function Promise(executor) { | 57 var GlobalPromise = function Promise(executor) { |
| 85 if (executor === promiseRawSymbol) { | 58 if (executor === promiseRawSymbol) { |
| 86 return %_NewObject(GlobalPromise, new.target); | 59 return %_NewObject(GlobalPromise, new.target); |
| 87 } | 60 } |
| 88 if (IS_UNDEFINED(new.target)) throw %make_type_error(kNotAPromise, this); | 61 if (IS_UNDEFINED(new.target)) throw %make_type_error(kNotAPromise, this); |
| 89 if (!IS_CALLABLE(executor)) { | 62 if (!IS_CALLABLE(executor)) { |
| 90 throw %make_type_error(kResolverNotAFunction, executor); | 63 throw %make_type_error(kResolverNotAFunction, executor); |
| 91 } | 64 } |
| 92 | 65 |
| 93 var promise = PromiseInit(%_NewObject(GlobalPromise, new.target)); | 66 var promise = PromiseInit(%_NewObject(GlobalPromise, new.target)); |
| 94 // Calling the reject function would be a new exception, so debugEvent = true | 67 // Calling the reject function would be a new exception, so debugEvent = true |
| 95 var callbacks = CreateResolvingFunctions(promise, true); | 68 // TODO(gsathya): Remove container for callbacks when this is moved |
| 69 // to CPP/TF. |
| 70 var callbacks = %create_resolving_functions(promise, true); |
| 96 var debug_is_active = DEBUG_IS_ACTIVE; | 71 var debug_is_active = DEBUG_IS_ACTIVE; |
| 97 try { | 72 try { |
| 98 if (debug_is_active) %DebugPushPromise(promise); | 73 if (debug_is_active) %DebugPushPromise(promise); |
| 99 executor(callbacks.resolve, callbacks.reject); | 74 executor(callbacks[kResolveCallback], callbacks[kRejectCallback]); |
| 100 } %catch (e) { // Natives syntax to mark this catch block. | 75 } %catch (e) { // Natives syntax to mark this catch block. |
| 101 %_Call(callbacks.reject, UNDEFINED, e); | 76 %_Call(callbacks[kRejectCallback], UNDEFINED, e); |
| 102 } finally { | 77 } finally { |
| 103 if (debug_is_active) %DebugPopPromise(); | 78 if (debug_is_active) %DebugPopPromise(); |
| 104 } | 79 } |
| 105 | 80 |
| 106 return promise; | 81 return promise; |
| 107 } | 82 } |
| 108 | 83 |
| 109 // Core functionality. | 84 // Core functionality. |
| 110 | 85 |
| 111 function PromiseSet(promise, status, value) { | 86 function PromiseSet(promise, status, value) { |
| (...skipping 172 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 284 } | 259 } |
| 285 // Don't cause a debug event as this case is forwarding a rejection | 260 // Don't cause a debug event as this case is forwarding a rejection |
| 286 %PromiseReject(promise, thenableValue, false); | 261 %PromiseReject(promise, thenableValue, false); |
| 287 PromiseSet(promise, kRejected, thenableValue); | 262 PromiseSet(promise, kRejected, thenableValue); |
| 288 SET_PRIVATE(resolution, promiseHasHandlerSymbol, true); | 263 SET_PRIVATE(resolution, promiseHasHandlerSymbol, true); |
| 289 return; | 264 return; |
| 290 } | 265 } |
| 291 } | 266 } |
| 292 | 267 |
| 293 if (IS_CALLABLE(then)) { | 268 if (IS_CALLABLE(then)) { |
| 294 var callbacks = CreateResolvingFunctions(promise, false); | 269 // TODO(gsathya): Remove container for callbacks when this is |
| 270 // moved to CPP/TF. |
| 271 var callbacks = %create_resolving_functions(promise, false); |
| 295 if (DEBUG_IS_ACTIVE && IsPromise(resolution)) { | 272 if (DEBUG_IS_ACTIVE && IsPromise(resolution)) { |
| 296 // Mark the dependency of the new promise on the resolution | 273 // Mark the dependency of the new promise on the resolution |
| 297 SET_PRIVATE(resolution, promiseHandledBySymbol, promise); | 274 SET_PRIVATE(resolution, promiseHandledBySymbol, promise); |
| 298 } | 275 } |
| 299 %EnqueuePromiseResolveThenableJob( | 276 %EnqueuePromiseResolveThenableJob( |
| 300 resolution, then, callbacks.resolve, callbacks.reject); | 277 resolution, then, callbacks[kResolveCallback], |
| 278 callbacks[kRejectCallback]); |
| 301 return; | 279 return; |
| 302 } | 280 } |
| 303 } | 281 } |
| 304 %PromiseFulfill(promise, kFulfilled, resolution, | 282 %PromiseFulfill(promise, kFulfilled, resolution, |
| 305 promiseFulfillReactionsSymbol); | 283 promiseFulfillReactionsSymbol); |
| 306 PromiseSet(promise, kFulfilled, resolution); | 284 PromiseSet(promise, kFulfilled, resolution); |
| 307 } | 285 } |
| 308 | 286 |
| 309 // Only used by async-await.js | 287 // Only used by async-await.js |
| 310 function RejectPromise(promise, reason) { | 288 function RejectPromise(promise, reason, debugEvent) { |
| 311 %PromiseReject(promise, reason, false); | 289 %PromiseReject(promise, reason, debugEvent); |
| 312 PromiseSet(promise, kRejected, reason); | 290 PromiseSet(promise, kRejected, reason); |
| 313 } | 291 } |
| 314 | 292 |
| 315 // Export to bindings | 293 // Export to bindings |
| 316 function DoRejectPromise(promise, reason) { | 294 function DoRejectPromise(promise, reason) { |
| 317 %PromiseReject(promise, reason, true); | 295 %PromiseReject(promise, reason, true); |
| 318 PromiseSet(promise, kRejected, reason); | 296 PromiseSet(promise, kRejected, reason); |
| 319 } | 297 } |
| 320 | 298 |
| 321 // ES#sec-newpromisecapability | 299 // ES#sec-newpromisecapability |
| 322 // NewPromiseCapability ( C ) | 300 // NewPromiseCapability ( C ) |
| 323 function NewPromiseCapability(C, debugEvent) { | 301 function NewPromiseCapability(C, debugEvent) { |
| 324 if (C === GlobalPromise) { | 302 if (C === GlobalPromise) { |
| 325 // Optimized case, avoid extra closure. | 303 // Optimized case, avoid extra closure. |
| 326 var promise = PromiseCreate(); | 304 var promise = PromiseCreate(); |
| 327 var callbacks = CreateResolvingFunctions(promise, debugEvent); | 305 // TODO(gsathya): Remove container for callbacks when this is |
| 306 // moved to CPP/TF. |
| 307 var callbacks = %create_resolving_functions(promise, debugEvent); |
| 328 return { | 308 return { |
| 329 promise: promise, | 309 promise: promise, |
| 330 resolve: callbacks.resolve, | 310 resolve: callbacks[kResolveCallback], |
| 331 reject: callbacks.reject | 311 reject: callbacks[kRejectCallback] |
| 332 }; | 312 }; |
| 333 } | 313 } |
| 334 | 314 |
| 335 var result = {promise: UNDEFINED, resolve: UNDEFINED, reject: UNDEFINED }; | 315 var result = {promise: UNDEFINED, resolve: UNDEFINED, reject: UNDEFINED }; |
| 336 result.promise = new C((resolve, reject) => { | 316 result.promise = new C((resolve, reject) => { |
| 337 if (!IS_UNDEFINED(result.resolve) || !IS_UNDEFINED(result.reject)) | 317 if (!IS_UNDEFINED(result.resolve) || !IS_UNDEFINED(result.reject)) |
| 338 throw %make_type_error(kPromiseExecutorAlreadyInvoked); | 318 throw %make_type_error(kPromiseExecutorAlreadyInvoked); |
| 339 result.resolve = resolve; | 319 result.resolve = resolve; |
| 340 result.reject = reject; | 320 result.reject = reject; |
| 341 }); | 321 }); |
| (...skipping 294 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 636 utils.InstallFunctions(GlobalPromise.prototype, DONT_ENUM, [ | 616 utils.InstallFunctions(GlobalPromise.prototype, DONT_ENUM, [ |
| 637 "then", PromiseThen, | 617 "then", PromiseThen, |
| 638 "catch", PromiseCatch | 618 "catch", PromiseCatch |
| 639 ]); | 619 ]); |
| 640 | 620 |
| 641 %InstallToContext([ | 621 %InstallToContext([ |
| 642 "promise_catch", PromiseCatch, | 622 "promise_catch", PromiseCatch, |
| 643 "promise_create", PromiseCreate, | 623 "promise_create", PromiseCreate, |
| 644 "promise_has_user_defined_reject_handler", PromiseHasUserDefinedRejectHandler, | 624 "promise_has_user_defined_reject_handler", PromiseHasUserDefinedRejectHandler, |
| 645 "promise_reject", DoRejectPromise, | 625 "promise_reject", DoRejectPromise, |
| 626 // TODO(gsathya): Remove this once we update the promise builtin. |
| 627 "promise_internal_reject", RejectPromise, |
| 646 "promise_resolve", ResolvePromise, | 628 "promise_resolve", ResolvePromise, |
| 647 "promise_then", PromiseThen, | 629 "promise_then", PromiseThen, |
| 648 "promise_handle", PromiseHandle, | 630 "promise_handle", PromiseHandle, |
| 649 "promise_debug_get_info", PromiseDebugGetInfo | 631 "promise_debug_get_info", PromiseDebugGetInfo |
| 650 ]); | 632 ]); |
| 651 | 633 |
| 652 // This allows extras to create promises quickly without building extra | 634 // This allows extras to create promises quickly without building extra |
| 653 // resolve/reject closures, and allows them to later resolve and reject any | 635 // resolve/reject closures, and allows them to later resolve and reject any |
| 654 // promise without having to hold on to those closures forever. | 636 // promise without having to hold on to those closures forever. |
| 655 utils.InstallFunctions(extrasUtils, 0, [ | 637 utils.InstallFunctions(extrasUtils, 0, [ |
| 656 "createPromise", PromiseCreate, | 638 "createPromise", PromiseCreate, |
| 657 "resolvePromise", ResolvePromise, | 639 "resolvePromise", ResolvePromise, |
| 658 "rejectPromise", DoRejectPromise | 640 "rejectPromise", DoRejectPromise |
| 659 ]); | 641 ]); |
| 660 | 642 |
| 661 utils.Export(function(to) { | 643 utils.Export(function(to) { |
| 662 to.IsPromise = IsPromise; | 644 to.IsPromise = IsPromise; |
| 663 to.PromiseCreate = PromiseCreate; | 645 to.PromiseCreate = PromiseCreate; |
| 664 to.PromiseThen = PromiseThen; | 646 to.PromiseThen = PromiseThen; |
| 665 | 647 |
| 666 to.GlobalPromise = GlobalPromise; | 648 to.GlobalPromise = GlobalPromise; |
| 667 to.NewPromiseCapability = NewPromiseCapability; | 649 to.NewPromiseCapability = NewPromiseCapability; |
| 668 to.PerformPromiseThen = PerformPromiseThen; | 650 to.PerformPromiseThen = PerformPromiseThen; |
| 669 to.ResolvePromise = ResolvePromise; | 651 to.ResolvePromise = ResolvePromise; |
| 670 to.RejectPromise = RejectPromise; | 652 to.RejectPromise = RejectPromise; |
| 671 }); | 653 }); |
| 672 | 654 |
| 673 }) | 655 }) |
| OLD | NEW |