| 12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090209120922093209420952096209720982099210021012102210321042105210621072108210921102111211221132114211521162117211821192120212121222123212421252126212721282129213021312132213321342135213621372138213921402141214221432144214521462147214821492150215121522153215421552156215721582159216021612162216321642165216621672168216921702171217221732174217521762177217821792180218121822183218421852186218721882189219021912192219321942195219621972198219922002201220222032204220522062207220822092210221122122213221422152216221722182219222022212222222322242225222622272228222922302231223222332234223522362237223822392240224122422243224422452246224722482249225022512252225322542255225622572258225922602261226222632264226522662267226822692270227122722273227422752276227722782279228022812282228322842285228622872288228922902291229222932294229522962297229822992300230123022303230423052306230723082309231023112312231323142315231623172318231923202321232223232324232523262327232823292330233123322333233423352336233723382339234023412342234323442345234623472348234923502351235223532354235523562357235823592360 |
- //-------------------------------------------------------------------------------------------------------
- // Copyright (C) Microsoft. All rights reserved.
- // Licensed under the MIT license. See LICENSE.txt file in the project root for full license information.
- //-------------------------------------------------------------------------------------------------------
- #include "RuntimeLibraryPch.h"
- namespace Js
- {
- JavascriptPromise::JavascriptPromise(DynamicType * type)
- : DynamicObject(type)
- {
- Assert(type->GetTypeId() == TypeIds_Promise);
- this->status = PromiseStatusCode_Undefined;
- this->isHandled = false;
- this->result = nullptr;
- this->resolveReactions = nullptr;
- this->rejectReactions = nullptr;
- }
- // Promise() as defined by ES 2016 Sections 25.4.3.1
- Var JavascriptPromise::NewInstance(RecyclableObject* function, CallInfo callInfo, ...)
- {
- PROBE_STACK(function->GetScriptContext(), Js::Constants::MinStackDefault);
- ARGUMENTS(args, callInfo);
- AssertMsg(args.Info.Count > 0, "Should always have implicit 'this'");
- ScriptContext* scriptContext = function->GetScriptContext();
- JavascriptLibrary* library = scriptContext->GetLibrary();
- CHAKRATEL_LANGSTATS_INC_LANGFEATURECOUNT(ES6, Promise, scriptContext);
- // SkipDefaultNewObject function flag should have prevented the default object from
- // being created, except when call true a host dispatch
- Var newTarget = args.GetNewTarget();
- bool isCtorSuperCall = JavascriptOperators::GetAndAssertIsConstructorSuperCall(args);
- AUTO_TAG_NATIVE_LIBRARY_ENTRY(function, callInfo, _u("Promise"));
- // 1. If NewTarget is undefined, throw a TypeError exception.
- if ((callInfo.Flags & CallFlags_New) != CallFlags_New || (newTarget != nullptr && JavascriptOperators::IsUndefined(newTarget)))
- {
- JavascriptError::ThrowTypeError(scriptContext, JSERR_ClassConstructorCannotBeCalledWithoutNew, _u("Promise"));
- }
- // 2. If IsCallable(executor) is false, throw a TypeError exception.
- if (args.Info.Count < 2 || !JavascriptConversion::IsCallable(args[1]))
- {
- JavascriptError::ThrowTypeError(scriptContext, JSERR_FunctionArgument_NeedFunction, _u("Promise"));
- }
- RecyclableObject* executor = RecyclableObject::FromVar(args[1]);
- // 3. Let promise be ? OrdinaryCreateFromConstructor(NewTarget, "%PromisePrototype%", <<[[PromiseState]], [[PromiseResult]], [[PromiseFulfillReactions]], [[PromiseRejectReactions]], [[PromiseIsHandled]] >>).
- JavascriptPromise* promise = library->CreatePromise();
- if (isCtorSuperCall)
- {
- JavascriptOperators::OrdinaryCreateFromConstructor(RecyclableObject::FromVar(newTarget), promise, library->GetPromisePrototype(), scriptContext);
- }
- JavascriptPromiseResolveOrRejectFunction* resolve;
- JavascriptPromiseResolveOrRejectFunction* reject;
- // 4. Set promise's [[PromiseState]] internal slot to "pending".
- // 5. Set promise's [[PromiseFulfillReactions]] internal slot to a new empty List.
- // 6. Set promise's [[PromiseRejectReactions]] internal slot to a new empty List.
- // 7. Set promise's [[PromiseIsHandled]] internal slot to false.
- // 8. Let resolvingFunctions be CreateResolvingFunctions(promise).
- InitializePromise(promise, &resolve, &reject, scriptContext);
- JavascriptExceptionObject* exception = nullptr;
- // 9. Let completion be Call(executor, undefined, << resolvingFunctions.[[Resolve]], resolvingFunctions.[[Reject]] >>).
- try
- {
- BEGIN_SAFE_REENTRANT_CALL(scriptContext->GetThreadContext())
- {
- CALL_FUNCTION(scriptContext->GetThreadContext(),
- executor, CallInfo(CallFlags_Value, 3),
- library->GetUndefined(),
- resolve,
- reject);
- }
- END_SAFE_REENTRANT_CALL
- }
- catch (const JavascriptException& err)
- {
- exception = err.GetAndClear();
- }
- if (exception != nullptr)
- {
- // 10. If completion is an abrupt completion, then
- // a. Perform ? Call(resolvingFunctions.[[Reject]], undefined, << completion.[[Value]] >>).
- TryRejectWithExceptionObject(exception, reject, scriptContext);
- }
- // 11. Return promise.
- return promise;
- }
- void JavascriptPromise::InitializePromise(JavascriptPromise* promise, JavascriptPromiseResolveOrRejectFunction** resolve, JavascriptPromiseResolveOrRejectFunction** reject, ScriptContext* scriptContext)
- {
- Assert(promise->status == PromiseStatusCode_Undefined);
- Assert(resolve);
- Assert(reject);
- Recycler* recycler = scriptContext->GetRecycler();
- JavascriptLibrary* library = scriptContext->GetLibrary();
- promise->status = PromiseStatusCode_Unresolved;
- promise->resolveReactions = RecyclerNew(recycler, JavascriptPromiseReactionList, recycler);
- promise->rejectReactions = RecyclerNew(recycler, JavascriptPromiseReactionList, recycler);
- JavascriptPromiseResolveOrRejectFunctionAlreadyResolvedWrapper* alreadyResolvedRecord = RecyclerNewStructZ(scriptContext->GetRecycler(), JavascriptPromiseResolveOrRejectFunctionAlreadyResolvedWrapper);
- alreadyResolvedRecord->alreadyResolved = false;
- *resolve = library->CreatePromiseResolveOrRejectFunction(EntryResolveOrRejectFunction, promise, false, alreadyResolvedRecord);
- *reject = library->CreatePromiseResolveOrRejectFunction(EntryResolveOrRejectFunction, promise, true, alreadyResolvedRecord);
- }
- bool JavascriptPromise::Is(Var aValue)
- {
- return Js::JavascriptOperators::GetTypeId(aValue) == TypeIds_Promise;
- }
- JavascriptPromise* JavascriptPromise::FromVar(Js::Var aValue)
- {
- AssertOrFailFastMsg(Is(aValue), "Ensure var is actually a 'JavascriptPromise'");
- return static_cast<JavascriptPromise *>(aValue);
- }
- JavascriptPromise* JavascriptPromise::UnsafeFromVar(Js::Var aValue)
- {
- AssertMsg(Is(aValue), "Ensure var is actually a 'JavascriptPromise'");
- return static_cast<JavascriptPromise *>(aValue);
- }
- BOOL JavascriptPromise::GetDiagValueString(StringBuilder<ArenaAllocator>* stringBuilder, ScriptContext* requestContext)
- {
- stringBuilder->AppendCppLiteral(_u("[...]"));
- return TRUE;
- }
- BOOL JavascriptPromise::GetDiagTypeString(StringBuilder<ArenaAllocator>* stringBuilder, ScriptContext* requestContext)
- {
- stringBuilder->AppendCppLiteral(_u("Promise"));
- return TRUE;
- }
- JavascriptPromiseReactionList* JavascriptPromise::GetResolveReactions()
- {
- return this->resolveReactions;
- }
- JavascriptPromiseReactionList* JavascriptPromise::GetRejectReactions()
- {
- return this->rejectReactions;
- }
- // Promise.all as described in ES 2015 Section 25.4.4.1
- Var JavascriptPromise::EntryAll(RecyclableObject* function, CallInfo callInfo, ...)
- {
- PROBE_STACK(function->GetScriptContext(), Js::Constants::MinStackDefault);
- ARGUMENTS(args, callInfo);
- Assert(!(callInfo.Flags & CallFlags_New));
- ScriptContext* scriptContext = function->GetScriptContext();
- AUTO_TAG_NATIVE_LIBRARY_ENTRY(function, callInfo, _u("Promise.all"));
- // 1. Let C be the this value.
- Var constructor = args[0];
- // 2. If Type(C) is not Object, throw a TypeError exception.
- if (!JavascriptOperators::IsObject(constructor))
- {
- JavascriptError::ThrowTypeError(scriptContext, JSERR_This_NeedObject, _u("Promise.all"));
- }
- JavascriptLibrary* library = scriptContext->GetLibrary();
- Var iterable;
- if (args.Info.Count > 1)
- {
- iterable = args[1];
- }
- else
- {
- iterable = library->GetUndefined();
- }
- // 3. Let promiseCapability be NewPromiseCapability(C).
- JavascriptPromiseCapability* promiseCapability = NewPromiseCapability(constructor, scriptContext);
- // We know that constructor is an object at this point - further, we even know that it is a constructor - because NewPromiseCapability
- // would throw otherwise. That means we can safely cast constructor into a RecyclableObject* now and avoid having to perform ToObject
- // as part of the Invoke operation performed inside the loop below.
- RecyclableObject* constructorObject = RecyclableObject::FromVar(constructor);
- uint32 index = 0;
- JavascriptArray* values = nullptr;
- // We can't use a simple counter for the remaining element count since each Promise.all Resolve Element Function needs to know how many
- // elements are remaining when it runs and needs to update that counter for all other functions created by this call to Promise.all.
- // We can't just use a static variable, either, since this element count is only used for the Promise.all Resolve Element Functions created
- // by this call to Promise.all.
- JavascriptPromiseAllResolveElementFunctionRemainingElementsWrapper* remainingElementsWrapper = RecyclerNewStructZ(scriptContext->GetRecycler(), JavascriptPromiseAllResolveElementFunctionRemainingElementsWrapper);
- remainingElementsWrapper->remainingElements = 1;
- JavascriptExceptionObject* exception = nullptr;
- try
- {
- // 4. Let iterator be GetIterator(iterable).
- RecyclableObject* iterator = JavascriptOperators::GetIterator(iterable, scriptContext);
- values = library->CreateArray(0);
- JavascriptOperators::DoIteratorStepAndValue(iterator, scriptContext, [&](Var next)
- {
- Var resolveVar = JavascriptOperators::GetProperty(constructorObject, Js::PropertyIds::resolve, scriptContext);
- if (!JavascriptConversion::IsCallable(resolveVar))
- {
- JavascriptError::ThrowTypeError(scriptContext, JSERR_NeedFunction);
- }
- RecyclableObject* resolveFunc = RecyclableObject::FromVar(resolveVar);
- ThreadContext * threadContext = scriptContext->GetThreadContext();
- Var nextPromise = nullptr;
- BEGIN_SAFE_REENTRANT_CALL(threadContext)
- {
- nextPromise = CALL_FUNCTION(threadContext,
- resolveFunc, Js::CallInfo(CallFlags_Value, 2),
- constructorObject,
- next);
- }
- END_SAFE_REENTRANT_CALL
- JavascriptPromiseAllResolveElementFunction* resolveElement = library->CreatePromiseAllResolveElementFunction(EntryAllResolveElementFunction, index, values, promiseCapability, remainingElementsWrapper);
- remainingElementsWrapper->remainingElements++;
- RecyclableObject* nextPromiseObject;
- if (!JavascriptConversion::ToObject(nextPromise, scriptContext, &nextPromiseObject))
- {
- JavascriptError::ThrowTypeError(scriptContext, JSERR_NeedObject);
- }
- Var thenVar = JavascriptOperators::GetProperty(nextPromiseObject, Js::PropertyIds::then, scriptContext);
- if (!JavascriptConversion::IsCallable(thenVar))
- {
- JavascriptError::ThrowTypeError(scriptContext, JSERR_NeedFunction);
- }
- RecyclableObject* thenFunc = RecyclableObject::FromVar(thenVar);
- BEGIN_SAFE_REENTRANT_CALL(threadContext)
- {
- CALL_FUNCTION(scriptContext->GetThreadContext(),
- thenFunc, Js::CallInfo(CallFlags_Value, 3),
- nextPromiseObject,
- resolveElement,
- promiseCapability->GetReject());
- }
- END_SAFE_REENTRANT_CALL
- index++;
- });
- }
- catch (const JavascriptException& err)
- {
- exception = err.GetAndClear();
- }
- if (exception != nullptr)
- {
- TryRejectWithExceptionObject(exception, promiseCapability->GetReject(), scriptContext);
- // We need to explicitly return here to make sure we don't resolve in case index == 0 here.
- // That would happen if GetIterator or IteratorValue throws an exception in the first iteration.
- return promiseCapability->GetPromise();
- }
- remainingElementsWrapper->remainingElements--;
- // We want this call to happen outside the try statement because if it throws, we aren't supposed to reject the promise.
- if (remainingElementsWrapper->remainingElements == 0)
- {
- Assert(values != nullptr);
- TryCallResolveOrRejectHandler(promiseCapability->GetResolve(), values, scriptContext);
- }
- return promiseCapability->GetPromise();
- }
- // Promise.prototype.catch as defined in ES 2015 Section 25.4.5.1
- Var JavascriptPromise::EntryCatch(RecyclableObject* function, CallInfo callInfo, ...)
- {
- PROBE_STACK(function->GetScriptContext(), Js::Constants::MinStackDefault);
- ARGUMENTS(args, callInfo);
- Assert(!(callInfo.Flags & CallFlags_New));
- ScriptContext* scriptContext = function->GetScriptContext();
- AUTO_TAG_NATIVE_LIBRARY_ENTRY(function, callInfo, _u("Promise.prototype.catch"));
- RecyclableObject* promise;
- if (!JavascriptConversion::ToObject(args[0], scriptContext, &promise))
- {
- JavascriptError::ThrowTypeError(scriptContext, JSERR_This_NeedObject, _u("Promise.prototype.catch"));
- }
- Var funcVar = JavascriptOperators::GetProperty(promise, Js::PropertyIds::then, scriptContext);
- if (!JavascriptConversion::IsCallable(funcVar))
- {
- JavascriptError::ThrowTypeError(scriptContext, JSERR_FunctionArgument_NeedFunction, _u("Promise.prototype.catch"));
- }
- Var onRejected;
- RecyclableObject* undefinedVar = scriptContext->GetLibrary()->GetUndefined();
- if (args.Info.Count > 1)
- {
- onRejected = args[1];
- }
- else
- {
- onRejected = undefinedVar;
- }
- RecyclableObject* func = RecyclableObject::FromVar(funcVar);
- BEGIN_SAFE_REENTRANT_CALL(scriptContext->GetThreadContext())
- {
- return CALL_FUNCTION(scriptContext->GetThreadContext(),
- func, Js::CallInfo(CallFlags_Value, 3),
- promise,
- undefinedVar,
- onRejected);
- }
- END_SAFE_REENTRANT_CALL
- }
- // Promise.race as described in ES 2015 Section 25.4.4.3
- Var JavascriptPromise::EntryRace(RecyclableObject* function, CallInfo callInfo, ...)
- {
- PROBE_STACK(function->GetScriptContext(), Js::Constants::MinStackDefault);
- ARGUMENTS(args, callInfo);
- Assert(!(callInfo.Flags & CallFlags_New));
- ScriptContext* scriptContext = function->GetScriptContext();
- AUTO_TAG_NATIVE_LIBRARY_ENTRY(function, callInfo, _u("Promise.race"));
- // 1. Let C be the this value.
- Var constructor = args[0];
- // 2. If Type(C) is not Object, throw a TypeError exception.
- if (!JavascriptOperators::IsObject(constructor))
- {
- JavascriptError::ThrowTypeError(scriptContext, JSERR_This_NeedObject, _u("Promise.race"));
- }
- Var undefinedVar = scriptContext->GetLibrary()->GetUndefined();
- Var iterable;
- if (args.Info.Count > 1)
- {
- iterable = args[1];
- }
- else
- {
- iterable = undefinedVar;
- }
- // 3. Let promiseCapability be NewPromiseCapability(C).
- JavascriptPromiseCapability* promiseCapability = NewPromiseCapability(constructor, scriptContext);
- // We know that constructor is an object at this point - further, we even know that it is a constructor - because NewPromiseCapability
- // would throw otherwise. That means we can safely cast constructor into a RecyclableObject* now and avoid having to perform ToObject
- // as part of the Invoke operation performed inside the loop below.
- RecyclableObject* constructorObject = RecyclableObject::FromVar(constructor);
- JavascriptExceptionObject* exception = nullptr;
- try
- {
- // 4. Let iterator be GetIterator(iterable).
- RecyclableObject* iterator = JavascriptOperators::GetIterator(iterable, scriptContext);
- JavascriptOperators::DoIteratorStepAndValue(iterator, scriptContext, [&](Var next)
- {
- Var resolveVar = JavascriptOperators::GetProperty(constructorObject, Js::PropertyIds::resolve, scriptContext);
- if (!JavascriptConversion::IsCallable(resolveVar))
- {
- JavascriptError::ThrowTypeError(scriptContext, JSERR_NeedFunction);
- }
- RecyclableObject* resolveFunc = RecyclableObject::FromVar(resolveVar);
- ThreadContext * threadContext = scriptContext->GetThreadContext();
- Var nextPromise = nullptr;
- BEGIN_SAFE_REENTRANT_CALL(threadContext)
- {
- nextPromise = CALL_FUNCTION(threadContext,
- resolveFunc, Js::CallInfo(CallFlags_Value, 2),
- constructorObject,
- next);
- }
- END_SAFE_REENTRANT_CALL
- RecyclableObject* nextPromiseObject;
- if (!JavascriptConversion::ToObject(nextPromise, scriptContext, &nextPromiseObject))
- {
- JavascriptError::ThrowTypeError(scriptContext, JSERR_NeedObject);
- }
- Var thenVar = JavascriptOperators::GetProperty(nextPromiseObject, Js::PropertyIds::then, scriptContext);
- if (!JavascriptConversion::IsCallable(thenVar))
- {
- JavascriptError::ThrowTypeError(scriptContext, JSERR_NeedFunction);
- }
- RecyclableObject* thenFunc = RecyclableObject::FromVar(thenVar);
- BEGIN_SAFE_REENTRANT_CALL(threadContext)
- {
- CALL_FUNCTION(threadContext,
- thenFunc, Js::CallInfo(CallFlags_Value, 3),
- nextPromiseObject,
- promiseCapability->GetResolve(),
- promiseCapability->GetReject());
- }
- END_SAFE_REENTRANT_CALL
- });
- }
- catch (const JavascriptException& err)
- {
- exception = err.GetAndClear();
- }
- if (exception != nullptr)
- {
- TryRejectWithExceptionObject(exception, promiseCapability->GetReject(), scriptContext);
- }
- return promiseCapability->GetPromise();
- }
- // Promise.reject as described in ES 2015 Section 25.4.4.4
- Var JavascriptPromise::EntryReject(RecyclableObject* function, CallInfo callInfo, ...)
- {
- PROBE_STACK(function->GetScriptContext(), Js::Constants::MinStackDefault);
- ARGUMENTS(args, callInfo);
- Assert(!(callInfo.Flags & CallFlags_New));
- ScriptContext* scriptContext = function->GetScriptContext();
- AUTO_TAG_NATIVE_LIBRARY_ENTRY(function, callInfo, _u("Promise.reject"));
- // 1. Let C be the this value.
- Var constructor = args[0];
- // 2. If Type(C) is not Object, throw a TypeError exception.
- if (!JavascriptOperators::IsObject(constructor))
- {
- JavascriptError::ThrowTypeError(scriptContext, JSERR_This_NeedObject, _u("Promise.reject"));
- }
- Var r;
- if (args.Info.Count > 1)
- {
- r = args[1];
- }
- else
- {
- r = scriptContext->GetLibrary()->GetUndefined();
- }
- // 3. Let promiseCapability be NewPromiseCapability(C).
- // 4. Perform ? Call(promiseCapability.[[Reject]], undefined, << r >>).
- // 5. Return promiseCapability.[[Promise]].
- return CreateRejectedPromise(r, scriptContext, constructor);
- }
- // Promise.resolve as described in ES 2015 Section 25.4.4.5
- Var JavascriptPromise::EntryResolve(RecyclableObject* function, CallInfo callInfo, ...)
- {
- PROBE_STACK(function->GetScriptContext(), Js::Constants::MinStackDefault);
- ARGUMENTS(args, callInfo);
- Assert(!(callInfo.Flags & CallFlags_New));
- ScriptContext* scriptContext = function->GetScriptContext();
- AUTO_TAG_NATIVE_LIBRARY_ENTRY(function, callInfo, _u("Promise.resolve"));
- Var x;
- // 1. Let C be the this value.
- Var constructor = args[0];
- // 2. If Type(C) is not Object, throw a TypeError exception.
- if (!JavascriptOperators::IsObject(constructor))
- {
- JavascriptError::ThrowTypeError(scriptContext, JSERR_This_NeedObject, _u("Promise.resolve"));
- }
- if (args.Info.Count > 1)
- {
- x = args[1];
- }
- else
- {
- x = scriptContext->GetLibrary()->GetUndefined();
- }
- // 3. If IsPromise(x) is true,
- if (JavascriptPromise::Is(x))
- {
- // a. Let xConstructor be Get(x, "constructor").
- Var xConstructor = JavascriptOperators::GetProperty((RecyclableObject*)x, PropertyIds::constructor, scriptContext);
- // b. If SameValue(xConstructor, C) is true, return x.
- if (JavascriptConversion::SameValue(xConstructor, constructor))
- {
- return x;
- }
- }
- // 4. Let promiseCapability be NewPromiseCapability(C).
- // 5. Perform ? Call(promiseCapability.[[Resolve]], undefined, << x >>).
- // 6. Return promiseCapability.[[Promise]].
- return CreateResolvedPromise(x, scriptContext, constructor);
- }
- // Promise.prototype.then as described in ES 2015 Section 25.4.5.3
- Var JavascriptPromise::EntryThen(RecyclableObject* function, CallInfo callInfo, ...)
- {
- PROBE_STACK(function->GetScriptContext(), Js::Constants::MinStackDefault);
- ARGUMENTS(args, callInfo);
- Assert(!(callInfo.Flags & CallFlags_New));
- ScriptContext* scriptContext = function->GetScriptContext();
- AUTO_TAG_NATIVE_LIBRARY_ENTRY(function, callInfo, _u("Promise.prototype.then"));
- if (args.Info.Count < 1 || !JavascriptPromise::Is(args[0]))
- {
- JavascriptError::ThrowTypeError(scriptContext, JSERR_This_NeedPromise, _u("Promise.prototype.then"));
- }
- JavascriptLibrary* library = scriptContext->GetLibrary();
- JavascriptPromise* promise = JavascriptPromise::FromVar(args[0]);
- RecyclableObject* rejectionHandler;
- RecyclableObject* fulfillmentHandler;
- if (args.Info.Count > 1 && JavascriptConversion::IsCallable(args[1]))
- {
- fulfillmentHandler = RecyclableObject::FromVar(args[1]);
- }
- else
- {
- fulfillmentHandler = library->GetIdentityFunction();
- }
- if (args.Info.Count > 2 && JavascriptConversion::IsCallable(args[2]))
- {
- rejectionHandler = RecyclableObject::FromVar(args[2]);
- }
- else
- {
- rejectionHandler = library->GetThrowerFunction();
- }
- return CreateThenPromise(promise, fulfillmentHandler, rejectionHandler, scriptContext);
- }
- // Promise.prototype.finally as described in the draft ES 2018 #sec-promise.prototype.finally
- Var JavascriptPromise::EntryFinally(RecyclableObject* function, CallInfo callInfo, ...)
- {
- PROBE_STACK(function->GetScriptContext(), Js::Constants::MinStackDefault);
- ARGUMENTS(args, callInfo);
- Assert(!(callInfo.Flags & CallFlags_New));
- ScriptContext* scriptContext = function->GetScriptContext();
- AUTO_TAG_NATIVE_LIBRARY_ENTRY(function, callInfo, _u("Promise.prototype.finally"));
- // 1. Let promise be the this value
- // 2. If Type(promise) is not Object, throw a TypeError exception
- if (args.Info.Count < 1 || !JavascriptOperators::IsObject(args[0]))
- {
- JavascriptError::ThrowTypeError(scriptContext, JSERR_This_NeedObject, _u("Promise.prototype.finally"));
- }
- JavascriptLibrary* library = scriptContext->GetLibrary();
- RecyclableObject* promise = RecyclableObject::UnsafeFromVar(args[0]);
- // 3. Let C be ? SpeciesConstructor(promise, %Promise%).
- RecyclableObject* constructor = JavascriptOperators::SpeciesConstructor(promise, scriptContext->GetLibrary()->GetPromiseConstructor(), scriptContext);
- // 4. Assert IsConstructor(C)
- Assert(JavascriptOperators::IsConstructor(constructor));
- // 5. If IsCallable(onFinally) is false
- // a. Let thenFinally be onFinally
- // b. Let catchFinally be onFinally
- // 6. Else,
- // a. Let thenFinally be a new built-in function object as defined in ThenFinally Function.
- // b. Let catchFinally be a new built-in function object as defined in CatchFinally Function.
- // c. Set thenFinally and catchFinally's [[Constructor]] internal slots to C.
- // d. Set thenFinally and catchFinally's [[OnFinally]] internal slots to onFinally.
- Var thenFinally = nullptr;
- Var catchFinally = nullptr;
- if (args.Info.Count > 1)
- {
- if (JavascriptConversion::IsCallable(args[1]))
- {
- //note to avoid duplicating code the ThenFinallyFunction works as both thenFinally and catchFinally using a flag
- thenFinally = library->CreatePromiseThenFinallyFunction(EntryThenFinallyFunction, RecyclableObject::FromVar(args[1]), constructor, false);
- catchFinally = library->CreatePromiseThenFinallyFunction(EntryThenFinallyFunction, RecyclableObject::FromVar(args[1]), constructor, true);
- }
- else
- {
- thenFinally = args[1];
- catchFinally = args[1];
- }
- }
- else
- {
- thenFinally = library->GetUndefined();
- catchFinally = library->GetUndefined();
- }
- Assert(thenFinally != nullptr && catchFinally != nullptr);
- // 7. Return ? Invoke(promise, "then", << thenFinally, catchFinally >>).
- Var funcVar = JavascriptOperators::GetProperty(promise, Js::PropertyIds::then, scriptContext);
- if (!JavascriptConversion::IsCallable(funcVar))
- {
- JavascriptError::ThrowTypeError(scriptContext, JSERR_FunctionArgument_NeedFunction, _u("Promise.prototype.finally"));
- }
- RecyclableObject* func = RecyclableObject::UnsafeFromVar(funcVar);
- BEGIN_SAFE_REENTRANT_CALL(scriptContext->GetThreadContext())
- {
- return CALL_FUNCTION(scriptContext->GetThreadContext(),
- func, Js::CallInfo(CallFlags_Value, 3),
- promise,
- thenFinally,
- catchFinally);
- }
- END_SAFE_REENTRANT_CALL
- }
- // ThenFinallyFunction as described in draft ES2018 #sec-thenfinallyfunctions
- // AND CatchFinallyFunction as described in draft ES2018 #sec-catchfinallyfunctions
- Var JavascriptPromise::EntryThenFinallyFunction(RecyclableObject* function, CallInfo callInfo, ...)
- {
- PROBE_STACK(function->GetScriptContext(), Js::Constants::MinStackDefault);
- ARGUMENTS(args, callInfo);
- Assert(!(callInfo.Flags & CallFlags_New));
- ScriptContext* scriptContext = function->GetScriptContext();
-
- JavascriptLibrary* library = scriptContext->GetLibrary();
- JavascriptPromiseThenFinallyFunction* thenFinallyFunction = JavascriptPromiseThenFinallyFunction::FromVar(function);
- // 1. Let onFinally be F.[[OnFinally]]
- // 2. Assert: IsCallable(onFinally)=true
- Assert(JavascriptConversion::IsCallable(thenFinallyFunction->GetOnFinally()));
- // 3. Let result be ? Call(onFinally, undefined)
- Var result = nullptr;
- BEGIN_SAFE_REENTRANT_CALL(scriptContext->GetThreadContext())
- {
- result = CALL_FUNCTION(scriptContext->GetThreadContext(), thenFinallyFunction->GetOnFinally(), CallInfo(CallFlags_Value, 1), library->GetUndefined());
- }
- END_SAFE_REENTRANT_CALL
- Assert(result);
- // 4. Let C be F.[[Constructor]]
- // 5. Assert IsConstructor(C)
- Assert(JavascriptOperators::IsConstructor(thenFinallyFunction->GetConstructor()));
- // 6. Let promise be ? PromiseResolve(c, result)
- Var promiseVar = CreateResolvedPromise(result, scriptContext, thenFinallyFunction->GetConstructor());
- // 7. Let valueThunk be equivalent to a function that returns value
- // OR 7. Let thrower be equivalent to a function that throws reason
- Var valueOrReason = nullptr;
- if (args.Info.Count > 1)
- {
- valueOrReason = args[1];
- }
- else
- {
- valueOrReason = scriptContext->GetLibrary()->GetUndefined();
- }
- JavascriptPromiseThunkFinallyFunction* thunkFinallyFunction = library->CreatePromiseThunkFinallyFunction(EntryThunkFinallyFunction, valueOrReason, thenFinallyFunction->GetShouldThrow());
- // 8. Return ? Invoke(promise, "then", <<valueThunk>>)
- RecyclableObject* promise = JavascriptOperators::ToObject(promiseVar, scriptContext);
- Var funcVar = JavascriptOperators::GetProperty(promise, Js::PropertyIds::then, scriptContext);
- if (!JavascriptConversion::IsCallable(funcVar))
- {
- JavascriptError::ThrowTypeError(scriptContext, JSERR_FunctionArgument_NeedFunction, _u("Promise.prototype.finally"));
- }
- RecyclableObject* func = RecyclableObject::FromVar(funcVar);
- BEGIN_SAFE_REENTRANT_CALL(scriptContext->GetThreadContext())
- {
- return CALL_FUNCTION(scriptContext->GetThreadContext(),
- func, Js::CallInfo(CallFlags_Value, 2),
- promiseVar,
- thunkFinallyFunction);
- }
- END_SAFE_REENTRANT_CALL
- }
- // valueThunk Function as referenced within draft ES2018 #sec-thenfinallyfunctions
- // and thrower as referenced within draft ES2018 #sec-catchfinallyfunctions
- Var JavascriptPromise::EntryThunkFinallyFunction(RecyclableObject* function, CallInfo callInfo, ...)
- {
- PROBE_STACK(function->GetScriptContext(), Js::Constants::MinStackDefault);
- ARGUMENTS(args, callInfo);
- Assert(!(callInfo.Flags & CallFlags_New));
- JavascriptPromiseThunkFinallyFunction* thunkFinallyFunction = JavascriptPromiseThunkFinallyFunction::FromVar(function);
- if (!thunkFinallyFunction->GetShouldThrow())
- {
- return thunkFinallyFunction->GetValue();
- }
- else
- {
- JavascriptExceptionOperators::Throw(thunkFinallyFunction->GetValue(), function->GetScriptContext());
- }
- }
- // Promise Reject and Resolve Functions as described in ES 2015 Section 25.4.1.4.1 and 25.4.1.4.2
- Var JavascriptPromise::EntryResolveOrRejectFunction(RecyclableObject* function, CallInfo callInfo, ...)
- {
- PROBE_STACK(function->GetScriptContext(), Js::Constants::MinStackDefault);
- ARGUMENTS(args, callInfo);
- Assert(!(callInfo.Flags & CallFlags_New));
- ScriptContext* scriptContext = function->GetScriptContext();
- JavascriptLibrary* library = scriptContext->GetLibrary();
- Var undefinedVar = library->GetUndefined();
- Var resolution;
- if (args.Info.Count > 1)
- {
- resolution = args[1];
- }
- else
- {
- resolution = undefinedVar;
- }
- JavascriptPromiseResolveOrRejectFunction* resolveOrRejectFunction = JavascriptPromiseResolveOrRejectFunction::FromVar(function);
- if (resolveOrRejectFunction->IsAlreadyResolved())
- {
- return undefinedVar;
- }
- resolveOrRejectFunction->SetAlreadyResolved(true);
- bool rejecting = resolveOrRejectFunction->IsRejectFunction();
- JavascriptPromise* promise = resolveOrRejectFunction->GetPromise();
- return promise->ResolveHelper(resolution, rejecting, scriptContext);
- }
- Var JavascriptPromise::Resolve(Var resolution, ScriptContext* scriptContext)
- {
- return this->ResolveHelper(resolution, false, scriptContext);
- }
- Var JavascriptPromise::Reject(Var resolution, ScriptContext* scriptContext)
- {
- return this->ResolveHelper(resolution, true, scriptContext);
- }
- Var JavascriptPromise::ResolveHelper(Var resolution, bool isRejecting, ScriptContext* scriptContext)
- {
- JavascriptLibrary* library = scriptContext->GetLibrary();
- Var undefinedVar = library->GetUndefined();
- // We only need to check SameValue and check for thenable resolution in the Resolve function case (not Reject)
- if (!isRejecting)
- {
- if (JavascriptConversion::SameValue(resolution, this))
- {
- JavascriptError* selfResolutionError = scriptContext->GetLibrary()->CreateTypeError();
- JavascriptError::SetErrorMessage(selfResolutionError, JSERR_PromiseSelfResolution, _u(""), scriptContext);
- resolution = selfResolutionError;
- isRejecting = true;
- }
- else if (RecyclableObject::Is(resolution))
- {
- try
- {
- RecyclableObject* thenable = RecyclableObject::FromVar(resolution);
- Var then = JavascriptOperators::GetPropertyNoCache(thenable, Js::PropertyIds::then, scriptContext);
- if (JavascriptConversion::IsCallable(then))
- {
- JavascriptPromiseResolveThenableTaskFunction* resolveThenableTaskFunction = library->CreatePromiseResolveThenableTaskFunction(EntryResolveThenableTaskFunction, this, thenable, RecyclableObject::FromVar(then));
- library->EnqueueTask(resolveThenableTaskFunction);
- return undefinedVar;
- }
- }
- catch (const JavascriptException& err)
- {
- resolution = err.GetAndClear()->GetThrownObject(scriptContext);
- if (resolution == nullptr)
- {
- resolution = undefinedVar;
- }
- isRejecting = true;
- }
- }
- }
- JavascriptPromiseReactionList* reactions;
- PromiseStatus newStatus;
- // Need to check rejecting state again as it might have changed due to failures
- if (isRejecting)
- {
- reactions = this->GetRejectReactions();
- newStatus = PromiseStatusCode_HasRejection;
- if (!GetIsHandled())
- {
- scriptContext->GetLibrary()->CallNativeHostPromiseRejectionTracker(this, resolution, false);
- }
- }
- else
- {
- reactions = this->GetResolveReactions();
- newStatus = PromiseStatusCode_HasResolution;
- }
- Assert(resolution != nullptr);
- this->result = resolution;
- this->resolveReactions = nullptr;
- this->rejectReactions = nullptr;
- this->status = newStatus;
- return TriggerPromiseReactions(reactions, resolution, scriptContext);
- }
- // Promise Capabilities Executor Function as described in ES 2015 Section 25.4.1.6.2
- Var JavascriptPromise::EntryCapabilitiesExecutorFunction(RecyclableObject* function, CallInfo callInfo, ...)
- {
- PROBE_STACK(function->GetScriptContext(), Js::Constants::MinStackDefault);
- ARGUMENTS(args, callInfo);
- Assert(!(callInfo.Flags & CallFlags_New));
- ScriptContext* scriptContext = function->GetScriptContext();
- Var undefinedVar = scriptContext->GetLibrary()->GetUndefined();
- Var resolve = undefinedVar;
- Var reject = undefinedVar;
- if (args.Info.Count > 1)
- {
- resolve = args[1];
- if (args.Info.Count > 2)
- {
- reject = args[2];
- }
- }
- JavascriptPromiseCapabilitiesExecutorFunction* capabilitiesExecutorFunction = JavascriptPromiseCapabilitiesExecutorFunction::FromVar(function);
- JavascriptPromiseCapability* promiseCapability = capabilitiesExecutorFunction->GetCapability();
- if (!JavascriptOperators::IsUndefined(promiseCapability->GetResolve()) || !JavascriptOperators::IsUndefined(promiseCapability->GetReject()))
- {
- JavascriptError::ThrowTypeErrorVar(scriptContext, JSERR_UnexpectedMetadataFailure, _u("Promise"));
- }
- promiseCapability->SetResolve(resolve);
- promiseCapability->SetReject(reject);
- return undefinedVar;
- }
- // Promise Reaction Task Function as described in ES 2015 Section 25.4.2.1
- Var JavascriptPromise::EntryReactionTaskFunction(RecyclableObject* function, CallInfo callInfo, ...)
- {
- PROBE_STACK(function->GetScriptContext(), Js::Constants::MinStackDefault);
- ARGUMENTS(args, callInfo);
- Assert(!(callInfo.Flags & CallFlags_New));
- ScriptContext* scriptContext = function->GetScriptContext();
- Var undefinedVar = scriptContext->GetLibrary()->GetUndefined();
- JavascriptPromiseReactionTaskFunction* reactionTaskFunction = JavascriptPromiseReactionTaskFunction::FromVar(function);
- JavascriptPromiseReaction* reaction = reactionTaskFunction->GetReaction();
- Var argument = reactionTaskFunction->GetArgument();
- JavascriptPromiseCapability* promiseCapability = reaction->GetCapabilities();
- RecyclableObject* handler = reaction->GetHandler();
- Var handlerResult = nullptr;
- JavascriptExceptionObject* exception = nullptr;
- {
- bool isPromiseRejectionHandled = true;
- if (scriptContext->IsScriptContextInDebugMode())
- {
- // only necessary to determine if false if debugger is attached. This way we'll
- // correctly break on exceptions raised in promises that result in uhandled rejection
- // notifications
- Var promiseVar = promiseCapability->GetPromise();
- if (JavascriptPromise::Is(promiseVar))
- {
- JavascriptPromise* promise = JavascriptPromise::FromVar(promiseVar);
- isPromiseRejectionHandled = !promise->WillRejectionBeUnhandled();
- }
- }
- Js::JavascriptExceptionOperators::AutoCatchHandlerExists autoCatchHandlerExists(scriptContext, isPromiseRejectionHandled);
- try
- {
- BEGIN_SAFE_REENTRANT_CALL(scriptContext->GetThreadContext())
- {
- handlerResult = CALL_FUNCTION(scriptContext->GetThreadContext(),
- handler, Js::CallInfo(Js::CallFlags::CallFlags_Value, 2),
- undefinedVar,
- argument);
- }
- END_SAFE_REENTRANT_CALL
- }
- catch (const JavascriptException& err)
- {
- exception = err.GetAndClear();
- }
- }
- if (exception != nullptr)
- {
- return TryRejectWithExceptionObject(exception, promiseCapability->GetReject(), scriptContext);
- }
- Assert(handlerResult != nullptr);
- return TryCallResolveOrRejectHandler(promiseCapability->GetResolve(), handlerResult, scriptContext);
- }
- /**
- * Determine if at the current point in time, the given promise has a path of reactions that result
- * in an unhandled rejection. This doesn't account for potential of a rejection handler added later
- * in time.
- */
- bool JavascriptPromise::WillRejectionBeUnhandled()
- {
- bool willBeUnhandled = !this->GetIsHandled();
- if (!willBeUnhandled)
- {
- // if this promise is handled, then we need to do a depth-first search over this promise's reject
- // reactions. If we find a reaction that
- // - associated promise is "unhandled" (ie, it's never been "then'd")
- // - AND its rejection handler is our default "thrower function"
- // then this promise results in an unhandled rejection path.
- JsUtil::Stack<JavascriptPromise*, HeapAllocator> stack(&HeapAllocator::Instance);
- SimpleHashTable<JavascriptPromise*, int, HeapAllocator> visited(&HeapAllocator::Instance);
- stack.Push(this);
- visited.Add(this, 1);
- while (!willBeUnhandled && !stack.Empty())
- {
- JavascriptPromise * curr = stack.Pop();
- {
- JavascriptPromiseReactionList* reactions = curr->GetRejectReactions();
- for (int i = 0; i < reactions->Count(); i++)
- {
- JavascriptPromiseReaction* reaction = reactions->Item(i);
- Var promiseVar = reaction->GetCapabilities()->GetPromise();
- if (JavascriptPromise::Is(promiseVar))
- {
- JavascriptPromise* p = JavascriptPromise::FromVar(promiseVar);
- if (!p->GetIsHandled())
- {
- RecyclableObject* handler = reaction->GetHandler();
- if (JavascriptFunction::Is(handler))
- {
- JavascriptFunction* func = JavascriptFunction::FromVar(handler);
- FunctionInfo* functionInfo = func->GetFunctionInfo();
- #ifdef DEBUG
- if (!func->IsCrossSiteObject())
- {
- // assert that Thrower function's FunctionInfo hasn't changed
- AssertMsg(func->GetScriptContext()->GetLibrary()->GetThrowerFunction()->GetFunctionInfo() == &JavascriptPromise::EntryInfo::Thrower, "unexpected FunctionInfo for thrower function!");
- }
- #endif
- // If the function info is the default thrower function's function info, then assume that this is unhandled
- // this will work across script contexts
- if (functionInfo == &JavascriptPromise::EntryInfo::Thrower)
- {
- willBeUnhandled = true;
- break;
- }
- }
- }
- AssertMsg(visited.HasEntry(p) == false, "Unexpected cycle in promise reaction tree!");
- if (!visited.HasEntry(p))
- {
- stack.Push(p);
- visited.Add(p, 1);
- }
- }
- }
- }
- }
- }
- return willBeUnhandled;
- }
- Var JavascriptPromise::TryCallResolveOrRejectHandler(Var handler, Var value, ScriptContext* scriptContext)
- {
- Var undefinedVar = scriptContext->GetLibrary()->GetUndefined();
- if (!JavascriptConversion::IsCallable(handler))
- {
- JavascriptError::ThrowTypeError(scriptContext, JSERR_NeedFunction);
- }
- RecyclableObject* handlerFunc = RecyclableObject::FromVar(handler);
- BEGIN_SAFE_REENTRANT_CALL(scriptContext->GetThreadContext())
- {
- return CALL_FUNCTION(scriptContext->GetThreadContext(),
- handlerFunc, CallInfo(CallFlags_Value, 2),
- undefinedVar,
- value);
- }
- END_SAFE_REENTRANT_CALL
- }
- Var JavascriptPromise::TryRejectWithExceptionObject(JavascriptExceptionObject* exceptionObject, Var handler, ScriptContext* scriptContext)
- {
- Var thrownObject = exceptionObject->GetThrownObject(scriptContext);
- if (thrownObject == nullptr)
- {
- thrownObject = scriptContext->GetLibrary()->GetUndefined();
- }
- return TryCallResolveOrRejectHandler(handler, thrownObject, scriptContext);
- }
- Var JavascriptPromise::CreateRejectedPromise(Var resolution, ScriptContext* scriptContext, Var promiseConstructor)
- {
- if (promiseConstructor == nullptr)
- {
- promiseConstructor = scriptContext->GetLibrary()->GetPromiseConstructor();
- }
- JavascriptPromiseCapability* promiseCapability = NewPromiseCapability(promiseConstructor, scriptContext);
- TryCallResolveOrRejectHandler(promiseCapability->GetReject(), resolution, scriptContext);
- return promiseCapability->GetPromise();
- }
- Var JavascriptPromise::CreateResolvedPromise(Var resolution, ScriptContext* scriptContext, Var promiseConstructor)
- {
- if (promiseConstructor == nullptr)
- {
- promiseConstructor = scriptContext->GetLibrary()->GetPromiseConstructor();
- }
- JavascriptPromiseCapability* promiseCapability = NewPromiseCapability(promiseConstructor, scriptContext);
- TryCallResolveOrRejectHandler(promiseCapability->GetResolve(), resolution, scriptContext);
- return promiseCapability->GetPromise();
- }
- Var JavascriptPromise::CreatePassThroughPromise(JavascriptPromise* sourcePromise, ScriptContext* scriptContext)
- {
- JavascriptLibrary* library = scriptContext->GetLibrary();
- return CreateThenPromise(sourcePromise, library->GetIdentityFunction(), library->GetThrowerFunction(), scriptContext);
- }
- Var JavascriptPromise::CreateThenPromise(JavascriptPromise* sourcePromise, RecyclableObject* fulfillmentHandler, RecyclableObject* rejectionHandler, ScriptContext* scriptContext)
- {
- JavascriptFunction* defaultConstructor = scriptContext->GetLibrary()->GetPromiseConstructor();
- RecyclableObject* constructor = JavascriptOperators::SpeciesConstructor(sourcePromise, defaultConstructor, scriptContext);
- AssertOrFailFast(JavascriptOperators::IsConstructor(constructor));
- bool isDefaultConstructor = constructor == defaultConstructor;
- JavascriptPromiseCapability* promiseCapability = (JavascriptPromiseCapability*)JavascriptOperators::NewObjectCreationHelper_ReentrancySafe(constructor, isDefaultConstructor, scriptContext->GetThreadContext(), [=]()->JavascriptPromiseCapability*
- {
- return NewPromiseCapability(constructor, scriptContext);
- });
- JavascriptPromiseReaction* resolveReaction = JavascriptPromiseReaction::New(promiseCapability, fulfillmentHandler, scriptContext);
- JavascriptPromiseReaction* rejectReaction = JavascriptPromiseReaction::New(promiseCapability, rejectionHandler, scriptContext);
- switch (sourcePromise->status)
- {
- case PromiseStatusCode_Unresolved:
- sourcePromise->resolveReactions->Add(resolveReaction);
- sourcePromise->rejectReactions->Add(rejectReaction);
- break;
- case PromiseStatusCode_HasResolution:
- EnqueuePromiseReactionTask(resolveReaction, sourcePromise->result, scriptContext);
- break;
- case PromiseStatusCode_HasRejection:
- if (!sourcePromise->GetIsHandled())
- {
- scriptContext->GetLibrary()->CallNativeHostPromiseRejectionTracker(sourcePromise, sourcePromise->result, true);
- }
- EnqueuePromiseReactionTask(rejectReaction, sourcePromise->result, scriptContext);
- break;
- default:
- AssertMsg(false, "Promise status is in an invalid state");
- break;
- }
- sourcePromise->SetIsHandled();
- return promiseCapability->GetPromise();
- }
- // Promise Resolve Thenable Job as described in ES 2015 Section 25.4.2.2
- Var JavascriptPromise::EntryResolveThenableTaskFunction(RecyclableObject* function, CallInfo callInfo, ...)
- {
- PROBE_STACK(function->GetScriptContext(), Js::Constants::MinStackDefault);
- ARGUMENTS(args, callInfo);
- Assert(!(callInfo.Flags & CallFlags_New));
- ScriptContext* scriptContext = function->GetScriptContext();
- JavascriptLibrary* library = scriptContext->GetLibrary();
- JavascriptPromiseResolveThenableTaskFunction* resolveThenableTaskFunction = JavascriptPromiseResolveThenableTaskFunction::FromVar(function);
- JavascriptPromise* promise = resolveThenableTaskFunction->GetPromise();
- RecyclableObject* thenable = resolveThenableTaskFunction->GetThenable();
- RecyclableObject* thenFunction = resolveThenableTaskFunction->GetThenFunction();
- JavascriptPromiseResolveOrRejectFunctionAlreadyResolvedWrapper* alreadyResolvedRecord = RecyclerNewStructZ(scriptContext->GetRecycler(), JavascriptPromiseResolveOrRejectFunctionAlreadyResolvedWrapper);
- alreadyResolvedRecord->alreadyResolved = false;
- JavascriptPromiseResolveOrRejectFunction* resolve = library->CreatePromiseResolveOrRejectFunction(EntryResolveOrRejectFunction, promise, false, alreadyResolvedRecord);
- JavascriptPromiseResolveOrRejectFunction* reject = library->CreatePromiseResolveOrRejectFunction(EntryResolveOrRejectFunction, promise, true, alreadyResolvedRecord);
- JavascriptExceptionObject* exception = nullptr;
- {
- bool isPromiseRejectionHandled = true;
- if (scriptContext->IsScriptContextInDebugMode())
- {
- // only necessary to determine if false if debugger is attached. This way we'll
- // correctly break on exceptions raised in promises that result in uhandled rejections
- isPromiseRejectionHandled = !promise->WillRejectionBeUnhandled();
- }
- Js::JavascriptExceptionOperators::AutoCatchHandlerExists autoCatchHandlerExists(scriptContext, isPromiseRejectionHandled);
- try
- {
- BEGIN_SAFE_REENTRANT_CALL(scriptContext->GetThreadContext())
- {
- return CALL_FUNCTION(scriptContext->GetThreadContext(),
- thenFunction, Js::CallInfo(Js::CallFlags::CallFlags_Value, 3),
- thenable,
- resolve,
- reject);
- }
- END_SAFE_REENTRANT_CALL
- }
- catch (const JavascriptException& err)
- {
- exception = err.GetAndClear();
- }
- }
- Assert(exception != nullptr);
- return TryRejectWithExceptionObject(exception, reject, scriptContext);
- }
- // Promise Identity Function as described in ES 2015Section 25.4.5.3.1
- Var JavascriptPromise::EntryIdentityFunction(RecyclableObject* function, CallInfo callInfo, ...)
- {
- PROBE_STACK(function->GetScriptContext(), Js::Constants::MinStackDefault);
- ARGUMENTS(args, callInfo);
- Assert(!(callInfo.Flags & CallFlags_New));
- if (args.Info.Count > 1)
- {
- Assert(args[1] != nullptr);
- return args[1];
- }
- else
- {
- return function->GetScriptContext()->GetLibrary()->GetUndefined();
- }
- }
- // Promise Thrower Function as described in ES 2015Section 25.4.5.3.3
- Var JavascriptPromise::EntryThrowerFunction(RecyclableObject* function, CallInfo callInfo, ...)
- {
- PROBE_STACK(function->GetScriptContext(), Js::Constants::MinStackDefault);
- ARGUMENTS(args, callInfo);
- Assert(!(callInfo.Flags & CallFlags_New));
- ScriptContext* scriptContext = function->GetScriptContext();
- Var arg;
- if (args.Info.Count > 1)
- {
- Assert(args[1] != nullptr);
- arg = args[1];
- }
- else
- {
- arg = scriptContext->GetLibrary()->GetUndefined();
- }
- JavascriptExceptionOperators::Throw(arg, scriptContext);
- }
- // Promise.all Resolve Element Function as described in ES6.0 (Release Candidate 3) Section 25.4.4.1.2
- Var JavascriptPromise::EntryAllResolveElementFunction(RecyclableObject* function, CallInfo callInfo, ...)
- {
- PROBE_STACK(function->GetScriptContext(), Js::Constants::MinStackDefault);
- ARGUMENTS(args, callInfo);
- Assert(!(callInfo.Flags & CallFlags_New));
- ScriptContext* scriptContext = function->GetScriptContext();
- Var undefinedVar = scriptContext->GetLibrary()->GetUndefined();
- Var x;
- if (args.Info.Count > 1)
- {
- x = args[1];
- }
- else
- {
- x = undefinedVar;
- }
- JavascriptPromiseAllResolveElementFunction* allResolveElementFunction = JavascriptPromiseAllResolveElementFunction::FromVar(function);
- if (allResolveElementFunction->IsAlreadyCalled())
- {
- return undefinedVar;
- }
- allResolveElementFunction->SetAlreadyCalled(true);
- uint32 index = allResolveElementFunction->GetIndex();
- JavascriptArray* values = allResolveElementFunction->GetValues();
- JavascriptPromiseCapability* promiseCapability = allResolveElementFunction->GetCapabilities();
- JavascriptExceptionObject* exception = nullptr;
- try
- {
- values->SetItem(index, x, PropertyOperation_None);
- }
- catch (const JavascriptException& err)
- {
- exception = err.GetAndClear();
- }
- if (exception != nullptr)
- {
- return TryRejectWithExceptionObject(exception, promiseCapability->GetReject(), scriptContext);
- }
- if (allResolveElementFunction->DecrementRemainingElements() == 0)
- {
- return TryCallResolveOrRejectHandler(promiseCapability->GetResolve(), values, scriptContext);
- }
- return undefinedVar;
- }
- Var JavascriptPromise::EntryJavascriptPromiseAsyncSpawnExecutorFunction(RecyclableObject* function, CallInfo callInfo, ...)
- {
- PROBE_STACK(function->GetScriptContext(), Js::Constants::MinStackDefault);
- ARGUMENTS(args, callInfo);
- ScriptContext* scriptContext = function->GetScriptContext();
- JavascriptLibrary* library = scriptContext->GetLibrary();
- Var undefinedVar = library->GetUndefined();
- Var resolve = undefinedVar;
- Var reject = undefinedVar;
- Assert(args.Info.Count == 3);
- resolve = args[1];
- reject = args[2];
- Assert(JavascriptPromiseAsyncSpawnExecutorFunction::Is(function));
- JavascriptPromiseAsyncSpawnExecutorFunction* asyncSpawnExecutorFunction = JavascriptPromiseAsyncSpawnExecutorFunction::FromVar(function);
- Var self = asyncSpawnExecutorFunction->GetTarget();
- Var varCallArgs[] = { undefinedVar, self };
- JavascriptGenerator* gen = asyncSpawnExecutorFunction->GetGenerator();
- JavascriptPromiseAsyncSpawnStepArgumentExecutorFunction* nextFunction = library->CreatePromiseAsyncSpawnStepArgumentExecutorFunction(EntryJavascriptPromiseAsyncSpawnStepNextExecutorFunction, gen, varCallArgs);
- Assert(JavascriptConversion::IsCallable(resolve) && JavascriptConversion::IsCallable(reject));
- AsyncSpawnStep(nextFunction, gen, resolve, reject);
- return undefinedVar;
- }
- Var JavascriptPromise::EntryJavascriptPromiseAsyncSpawnStepNextExecutorFunction(RecyclableObject* function, CallInfo callInfo, ...)
- {
- PROBE_STACK(function->GetScriptContext(), Js::Constants::MinStackDefault);
- JavascriptPromiseAsyncSpawnStepArgumentExecutorFunction* asyncSpawnStepArgumentExecutorFunction = JavascriptPromiseAsyncSpawnStepArgumentExecutorFunction::FromVar(function);
- Var argument = asyncSpawnStepArgumentExecutorFunction->GetArgument();
- JavascriptFunction* next = function->GetScriptContext()->GetLibrary()->EnsureGeneratorNextFunction();
- BEGIN_SAFE_REENTRANT_CALL(function->GetScriptContext()->GetThreadContext())
- {
- return CALL_FUNCTION(function->GetScriptContext()->GetThreadContext(), next, CallInfo(CallFlags_Value, 2), asyncSpawnStepArgumentExecutorFunction->GetGenerator(), argument);
- }
- END_SAFE_REENTRANT_CALL
- }
- Var JavascriptPromise::EntryJavascriptPromiseAsyncSpawnStepThrowExecutorFunction(RecyclableObject* function, CallInfo callInfo, ...)
- {
- PROBE_STACK(function->GetScriptContext(), Js::Constants::MinStackDefault);
- JavascriptPromiseAsyncSpawnStepArgumentExecutorFunction* asyncSpawnStepArgumentExecutorFunction = JavascriptPromiseAsyncSpawnStepArgumentExecutorFunction::FromVar(function);
- JavascriptFunction* throw_ = function->GetScriptContext()->GetLibrary()->EnsureGeneratorThrowFunction();
- BEGIN_SAFE_REENTRANT_CALL(function->GetScriptContext()->GetThreadContext())
- {
- return CALL_FUNCTION(function->GetScriptContext()->GetThreadContext(), throw_, CallInfo(CallFlags_Value, 2), asyncSpawnStepArgumentExecutorFunction->GetGenerator(), asyncSpawnStepArgumentExecutorFunction->GetArgument());
- }
- END_SAFE_REENTRANT_CALL
- }
- Var JavascriptPromise::EntryJavascriptPromiseAsyncSpawnCallStepExecutorFunction(RecyclableObject* function, CallInfo callInfo, ...)
- {
- PROBE_STACK(function->GetScriptContext(), Js::Constants::MinStackDefault);
- ARGUMENTS(args, callInfo);
- ScriptContext* scriptContext = function->GetScriptContext();
- JavascriptLibrary* library = scriptContext->GetLibrary();
- Var undefinedVar = library->GetUndefined();
- Var argument = undefinedVar;
- if (args.Info.Count > 1)
- {
- argument = args[1];
- }
- JavascriptPromiseAsyncSpawnStepArgumentExecutorFunction* asyncSpawnStepExecutorFunction = JavascriptPromiseAsyncSpawnStepArgumentExecutorFunction::FromVar(function);
- JavascriptPromiseAsyncSpawnStepArgumentExecutorFunction* functionArg;
- JavascriptGenerator* gen = asyncSpawnStepExecutorFunction->GetGenerator();
- Var reject = asyncSpawnStepExecutorFunction->GetReject();
- Var resolve = asyncSpawnStepExecutorFunction->GetResolve();
- if (asyncSpawnStepExecutorFunction->GetIsReject())
- {
- functionArg = library->CreatePromiseAsyncSpawnStepArgumentExecutorFunction(EntryJavascriptPromiseAsyncSpawnStepThrowExecutorFunction, gen, argument, NULL, NULL, false);
- }
- else
- {
- functionArg = library->CreatePromiseAsyncSpawnStepArgumentExecutorFunction(EntryJavascriptPromiseAsyncSpawnStepNextExecutorFunction, gen, argument, NULL, NULL, false);
- }
- AsyncSpawnStep(functionArg, gen, resolve, reject);
- return undefinedVar;
- }
- void JavascriptPromise::AsyncSpawnStep(JavascriptPromiseAsyncSpawnStepArgumentExecutorFunction* nextFunction, JavascriptGenerator* gen, Var resolve, Var reject)
- {
- ScriptContext* scriptContext = gen->GetScriptContext();
- BEGIN_SAFE_REENTRANT_REGION(scriptContext->GetThreadContext())
- JavascriptLibrary* library = scriptContext->GetLibrary();
- Var undefinedVar = library->GetUndefined();
- JavascriptExceptionObject* exception = nullptr;
- Var value = nullptr;
- RecyclableObject* next = nullptr;
- bool done;
- try
- {
- Var nextVar = CALL_FUNCTION(scriptContext->GetThreadContext(), nextFunction, CallInfo(CallFlags_Value, 1), undefinedVar);
- next = RecyclableObject::FromVar(nextVar);
- }
- catch (const JavascriptException& err)
- {
- exception = err.GetAndClear();
- }
- if (exception != nullptr)
- {
- // finished with failure, reject the promise
- TryRejectWithExceptionObject(exception, reject, scriptContext);
- return;
- }
- Assert(next != nullptr);
- done = JavascriptConversion::ToBool(JavascriptOperators::GetProperty(next, PropertyIds::done, scriptContext), scriptContext);
- if (done)
- {
- // finished with success, resolve the promise
- value = JavascriptOperators::GetProperty(next, PropertyIds::value, scriptContext);
- if (!JavascriptConversion::IsCallable(resolve))
- {
- JavascriptError::ThrowTypeError(scriptContext, JSERR_NeedFunction);
- }
- CALL_FUNCTION(scriptContext->GetThreadContext(), RecyclableObject::FromVar(resolve), CallInfo(CallFlags_Value, 2), undefinedVar, value);
- return;
- }
- // not finished, chain off the yielded promise and `step` again
- JavascriptPromiseAsyncSpawnStepArgumentExecutorFunction* successFunction = library->CreatePromiseAsyncSpawnStepArgumentExecutorFunction(EntryJavascriptPromiseAsyncSpawnCallStepExecutorFunction, gen, undefinedVar, resolve, reject);
- JavascriptPromiseAsyncSpawnStepArgumentExecutorFunction* failFunction = library->CreatePromiseAsyncSpawnStepArgumentExecutorFunction(EntryJavascriptPromiseAsyncSpawnCallStepExecutorFunction, gen, undefinedVar, resolve, reject, true);
- JavascriptFunction* promiseResolve = library->EnsurePromiseResolveFunction();
- value = JavascriptOperators::GetProperty(next, PropertyIds::value, scriptContext);
- Var promiseVar = CALL_FUNCTION(scriptContext->GetThreadContext(), promiseResolve, CallInfo(CallFlags_Value, 2), library->GetPromiseConstructor(), value);
- JavascriptPromise* promise = FromVar(promiseVar);
- Var promiseThen = JavascriptOperators::GetProperty(promise, PropertyIds::then, scriptContext);
- if (!JavascriptConversion::IsCallable(promiseThen))
- {
- JavascriptError::ThrowTypeError(scriptContext, JSERR_NeedFunction);
- }
- CALL_FUNCTION(scriptContext->GetThreadContext(), RecyclableObject::FromVar(promiseThen), CallInfo(CallFlags_Value, 3), promise, successFunction, failFunction);
- END_SAFE_REENTRANT_REGION
- }
- #if ENABLE_TTD
- void JavascriptPromise::MarkVisitKindSpecificPtrs(TTD::SnapshotExtractor* extractor)
- {
- if(this->result != nullptr)
- {
- extractor->MarkVisitVar(this->result);
- }
- if(this->resolveReactions != nullptr)
- {
- for(int32 i = 0; i < this->resolveReactions->Count(); ++i)
- {
- this->resolveReactions->Item(i)->MarkVisitPtrs(extractor);
- }
- }
- if(this->rejectReactions != nullptr)
- {
- for(int32 i = 0; i < this->rejectReactions->Count(); ++i)
- {
- this->rejectReactions->Item(i)->MarkVisitPtrs(extractor);
- }
- }
- }
- TTD::NSSnapObjects::SnapObjectType JavascriptPromise::GetSnapTag_TTD() const
- {
- return TTD::NSSnapObjects::SnapObjectType::SnapPromiseObject;
- }
- void JavascriptPromise::ExtractSnapObjectDataInto(TTD::NSSnapObjects::SnapObject* objData, TTD::SlabAllocator& alloc)
- {
- JsUtil::List<TTD_PTR_ID, HeapAllocator> depOnList(&HeapAllocator::Instance);
- TTD::NSSnapObjects::SnapPromiseInfo* spi = alloc.SlabAllocateStruct<TTD::NSSnapObjects::SnapPromiseInfo>();
- spi->Result = this->result;
- //Primitive kinds always inflated first so we only need to deal with complex kinds as depends on
- if(this->result != nullptr && TTD::JsSupport::IsVarComplexKind(this->result))
- {
- depOnList.Add(TTD_CONVERT_VAR_TO_PTR_ID(this->result));
- }
- spi->Status = this->status;
- spi->ResolveReactionCount = (this->resolveReactions != nullptr) ? this->resolveReactions->Count() : 0;
- spi->ResolveReactions = nullptr;
- if(spi->ResolveReactionCount != 0)
- {
- spi->ResolveReactions = alloc.SlabAllocateArray<TTD::NSSnapValues::SnapPromiseReactionInfo>(spi->ResolveReactionCount);
- for(uint32 i = 0; i < spi->ResolveReactionCount; ++i)
- {
- this->resolveReactions->Item(i)->ExtractSnapPromiseReactionInto(spi->ResolveReactions + i, depOnList, alloc);
- }
- }
- spi->RejectReactionCount = (this->rejectReactions != nullptr) ? this->rejectReactions->Count() : 0;
- spi->RejectReactions = nullptr;
- if(spi->RejectReactionCount != 0)
- {
- spi->RejectReactions = alloc.SlabAllocateArray<TTD::NSSnapValues::SnapPromiseReactionInfo>(spi->RejectReactionCount);
- for(uint32 i = 0; i < spi->RejectReactionCount; ++i)
- {
- this->rejectReactions->Item(i)->ExtractSnapPromiseReactionInto(spi->RejectReactions+ i, depOnList, alloc);
- }
- }
- //see what we need to do wrt dependencies
- if(depOnList.Count() == 0)
- {
- TTD::NSSnapObjects::StdExtractSetKindSpecificInfo<TTD::NSSnapObjects::SnapPromiseInfo*, TTD::NSSnapObjects::SnapObjectType::SnapPromiseObject>(objData, spi);
- }
- else
- {
- uint32 depOnCount = depOnList.Count();
- TTD_PTR_ID* depOnArray = alloc.SlabAllocateArray<TTD_PTR_ID>(depOnCount);
- for(uint32 i = 0; i < depOnCount; ++i)
- {
- depOnArray[i] = depOnList.Item(i);
- }
- TTD::NSSnapObjects::StdExtractSetKindSpecificInfo<TTD::NSSnapObjects::SnapPromiseInfo*, TTD::NSSnapObjects::SnapObjectType::SnapPromiseObject>(objData, spi, alloc, depOnCount, depOnArray);
- }
- }
- JavascriptPromise* JavascriptPromise::InitializePromise_TTD(ScriptContext* scriptContext, uint32 status, Var result, JsUtil::List<Js::JavascriptPromiseReaction*, HeapAllocator>& resolveReactions, JsUtil::List<Js::JavascriptPromiseReaction*, HeapAllocator>& rejectReactions)
- {
- Recycler* recycler = scriptContext->GetRecycler();
- JavascriptLibrary* library = scriptContext->GetLibrary();
- JavascriptPromise* promise = library->CreatePromise();
- promise->status = (PromiseStatus)status;
- promise->result = result;
- promise->resolveReactions = RecyclerNew(recycler, JavascriptPromiseReactionList, recycler);
- promise->resolveReactions->Copy(&resolveReactions);
- promise->rejectReactions = RecyclerNew(recycler, JavascriptPromiseReactionList, recycler);
- promise->rejectReactions->Copy(&rejectReactions);
- return promise;
- }
- #endif
- // NewPromiseCapability as described in ES6.0 (draft 29) Section 25.4.1.6
- JavascriptPromiseCapability* JavascriptPromise::NewPromiseCapability(Var constructor, ScriptContext* scriptContext)
- {
- if (!JavascriptOperators::IsConstructor(constructor))
- {
- JavascriptError::ThrowTypeError(scriptContext, JSERR_NeedFunction);
- }
- RecyclableObject* constructorFunc = RecyclableObject::FromVar(constructor);
- BEGIN_SAFE_REENTRANT_CALL(scriptContext->GetThreadContext())
- {
- return CreatePromiseCapabilityRecord(constructorFunc, scriptContext);
- }
- END_SAFE_REENTRANT_CALL
- }
- // CreatePromiseCapabilityRecord as described in ES6.0 (draft 29) Section 25.4.1.6.1
- JavascriptPromiseCapability* JavascriptPromise::CreatePromiseCapabilityRecord(RecyclableObject* constructor, ScriptContext* scriptContext)
- {
- JavascriptLibrary* library = scriptContext->GetLibrary();
- Var undefinedVar = library->GetUndefined();
- JavascriptPromiseCapability* promiseCapability = JavascriptPromiseCapability::New(undefinedVar, undefinedVar, undefinedVar, scriptContext);
- JavascriptPromiseCapabilitiesExecutorFunction* executor = library->CreatePromiseCapabilitiesExecutorFunction(EntryCapabilitiesExecutorFunction, promiseCapability);
- CallInfo callinfo = Js::CallInfo((Js::CallFlags)(Js::CallFlags::CallFlags_Value | Js::CallFlags::CallFlags_New), 2);
- Var argVars[] = { constructor, executor };
- Arguments args(callinfo, argVars);
- Var promise = JavascriptFunction::CallAsConstructor(constructor, nullptr, args, scriptContext);
- if (!JavascriptConversion::IsCallable(promiseCapability->GetResolve()) || !JavascriptConversion::IsCallable(promiseCapability->GetReject()))
- {
- JavascriptError::ThrowTypeError(scriptContext, JSERR_NeedFunction, _u("Promise"));
- }
- promiseCapability->SetPromise(promise);
- return promiseCapability;
- }
- // TriggerPromiseReactions as defined in ES 2015 Section 25.4.1.7
- Var JavascriptPromise::TriggerPromiseReactions(JavascriptPromiseReactionList* reactions, Var resolution, ScriptContext* scriptContext)
- {
- JavascriptLibrary* library = scriptContext->GetLibrary();
- if (reactions != nullptr)
- {
- for (int i = 0; i < reactions->Count(); i++)
- {
- JavascriptPromiseReaction* reaction = reactions->Item(i);
- EnqueuePromiseReactionTask(reaction, resolution, scriptContext);
- }
- }
- return library->GetUndefined();
- }
- void JavascriptPromise::EnqueuePromiseReactionTask(JavascriptPromiseReaction* reaction, Var resolution, ScriptContext* scriptContext)
- {
- Assert(resolution != nullptr);
- JavascriptLibrary* library = scriptContext->GetLibrary();
- JavascriptPromiseReactionTaskFunction* reactionTaskFunction = library->CreatePromiseReactionTaskFunction(EntryReactionTaskFunction, reaction, resolution);
- library->EnqueueTask(reactionTaskFunction);
- }
- JavascriptPromiseResolveOrRejectFunction::JavascriptPromiseResolveOrRejectFunction(DynamicType* type)
- : RuntimeFunction(type, &Js::JavascriptPromise::EntryInfo::ResolveOrRejectFunction), promise(nullptr), isReject(false), alreadyResolvedWrapper(nullptr)
- { }
- JavascriptPromiseResolveOrRejectFunction::JavascriptPromiseResolveOrRejectFunction(DynamicType* type, FunctionInfo* functionInfo, JavascriptPromise* promise, bool isReject, JavascriptPromiseResolveOrRejectFunctionAlreadyResolvedWrapper* alreadyResolvedRecord)
- : RuntimeFunction(type, functionInfo), promise(promise), isReject(isReject), alreadyResolvedWrapper(alreadyResolvedRecord)
- { }
- bool JavascriptPromiseResolveOrRejectFunction::Is(Var var)
- {
- if (JavascriptFunction::Is(var))
- {
- JavascriptFunction* obj = JavascriptFunction::UnsafeFromVar(var);
- return VirtualTableInfo<JavascriptPromiseResolveOrRejectFunction>::HasVirtualTable(obj)
- || VirtualTableInfo<CrossSiteObject<JavascriptPromiseResolveOrRejectFunction>>::HasVirtualTable(obj);
- }
- return false;
- }
- JavascriptPromiseResolveOrRejectFunction* JavascriptPromiseResolveOrRejectFunction::FromVar(Var var)
- {
- AssertOrFailFast(JavascriptPromiseResolveOrRejectFunction::Is(var));
- return static_cast<JavascriptPromiseResolveOrRejectFunction*>(var);
- }
- JavascriptPromiseResolveOrRejectFunction* JavascriptPromiseResolveOrRejectFunction::UnsafeFromVar(Var var)
- {
- Assert(JavascriptPromiseResolveOrRejectFunction::Is(var));
- return static_cast<JavascriptPromiseResolveOrRejectFunction*>(var);
- }
- JavascriptPromise* JavascriptPromiseResolveOrRejectFunction::GetPromise()
- {
- return this->promise;
- }
- bool JavascriptPromiseResolveOrRejectFunction::IsRejectFunction()
- {
- return this->isReject;
- }
- bool JavascriptPromiseResolveOrRejectFunction::IsAlreadyResolved()
- {
- Assert(this->alreadyResolvedWrapper);
- return this->alreadyResolvedWrapper->alreadyResolved;
- }
- void JavascriptPromiseResolveOrRejectFunction::SetAlreadyResolved(bool is)
- {
- Assert(this->alreadyResolvedWrapper);
- this->alreadyResolvedWrapper->alreadyResolved = is;
- }
- #if ENABLE_TTD
- void JavascriptPromiseResolveOrRejectFunction::MarkVisitKindSpecificPtrs(TTD::SnapshotExtractor* extractor)
- {
- TTDAssert(this->promise != nullptr, "Was not expecting that!!!");
- extractor->MarkVisitVar(this->promise);
- }
- TTD::NSSnapObjects::SnapObjectType JavascriptPromiseResolveOrRejectFunction::GetSnapTag_TTD() const
- {
- return TTD::NSSnapObjects::SnapObjectType::SnapPromiseResolveOrRejectFunctionObject;
- }
- void JavascriptPromiseResolveOrRejectFunction::ExtractSnapObjectDataInto(TTD::NSSnapObjects::SnapObject* objData, TTD::SlabAllocator& alloc)
- {
- TTD::NSSnapObjects::SnapPromiseResolveOrRejectFunctionInfo* sprri = alloc.SlabAllocateStruct<TTD::NSSnapObjects::SnapPromiseResolveOrRejectFunctionInfo>();
- uint32 depOnCount = 1;
- TTD_PTR_ID* depOnArray = alloc.SlabAllocateArray<TTD_PTR_ID>(depOnCount);
- sprri->PromiseId = TTD_CONVERT_VAR_TO_PTR_ID(this->promise);
- depOnArray[0] = sprri->PromiseId;
- sprri->IsReject = this->isReject;
- sprri->AlreadyResolvedWrapperId = TTD_CONVERT_PROMISE_INFO_TO_PTR_ID(this->alreadyResolvedWrapper);
- sprri->AlreadyResolvedValue = this->alreadyResolvedWrapper->alreadyResolved;
- TTD::NSSnapObjects::StdExtractSetKindSpecificInfo<TTD::NSSnapObjects::SnapPromiseResolveOrRejectFunctionInfo*, TTD::NSSnapObjects::SnapObjectType::SnapPromiseResolveOrRejectFunctionObject>(objData, sprri, alloc, depOnCount, depOnArray);
- }
- #endif
- JavascriptPromiseAsyncSpawnExecutorFunction::JavascriptPromiseAsyncSpawnExecutorFunction(DynamicType* type, FunctionInfo* functionInfo, JavascriptGenerator* generator, Var target)
- : RuntimeFunction(type, functionInfo), generator(generator), target(target)
- { }
- bool JavascriptPromiseAsyncSpawnExecutorFunction::Is(Var var)
- {
- if (JavascriptFunction::Is(var))
- {
- JavascriptFunction* obj = JavascriptFunction::UnsafeFromVar(var);
- return VirtualTableInfo<JavascriptPromiseAsyncSpawnExecutorFunction>::HasVirtualTable(obj)
- || VirtualTableInfo<CrossSiteObject<JavascriptPromiseAsyncSpawnExecutorFunction>>::HasVirtualTable(obj);
- }
- return false;
- }
- JavascriptPromiseAsyncSpawnExecutorFunction* JavascriptPromiseAsyncSpawnExecutorFunction::FromVar(Var var)
- {
- AssertOrFailFast(JavascriptPromiseAsyncSpawnExecutorFunction::Is(var));
- return static_cast<JavascriptPromiseAsyncSpawnExecutorFunction*>(var);
- }
- JavascriptPromiseAsyncSpawnExecutorFunction* JavascriptPromiseAsyncSpawnExecutorFunction::UnsafeFromVar(Var var)
- {
- Assert(JavascriptPromiseAsyncSpawnExecutorFunction::Is(var));
- return static_cast<JavascriptPromiseAsyncSpawnExecutorFunction*>(var);
- }
- JavascriptGenerator* JavascriptPromiseAsyncSpawnExecutorFunction::GetGenerator()
- {
- return this->generator;
- }
- Var JavascriptPromiseAsyncSpawnExecutorFunction::GetTarget()
- {
- return this->target;
- }
- #if ENABLE_TTD
- void JavascriptPromiseAsyncSpawnExecutorFunction::MarkVisitKindSpecificPtrs(TTD::SnapshotExtractor* extractor)
- {
- if (this->generator != nullptr)
- {
- extractor->MarkVisitVar(this->generator);
- }
- if (this->target != nullptr)
- {
- extractor->MarkVisitVar(this->target);
- }
- }
- TTD::NSSnapObjects::SnapObjectType JavascriptPromiseAsyncSpawnExecutorFunction::GetSnapTag_TTD() const
- {
- return TTD::NSSnapObjects::SnapObjectType::JavascriptPromiseAsyncSpawnExecutorFunction;
- }
- void JavascriptPromiseAsyncSpawnExecutorFunction::ExtractSnapObjectDataInto(TTD::NSSnapObjects::SnapObject* objData, TTD::SlabAllocator& alloc)
- {
- TTD::NSSnapObjects::SnapJavascriptPromiseAsyncSpawnExecutorFunctionInfo* info = alloc.SlabAllocateStruct<TTD::NSSnapObjects::SnapJavascriptPromiseAsyncSpawnExecutorFunctionInfo>();
- info->generator= TTD_CONVERT_VAR_TO_PTR_ID(this->generator);
- info->target = TTD_CONVERT_JSVAR_TO_TTDVAR(this->target);
- TTD::NSSnapObjects::StdExtractSetKindSpecificInfo<TTD::NSSnapObjects::SnapJavascriptPromiseAsyncSpawnExecutorFunctionInfo*, TTD::NSSnapObjects::SnapObjectType::JavascriptPromiseAsyncSpawnExecutorFunction>(objData, info);
- }
- #endif
- JavascriptPromiseAsyncSpawnStepArgumentExecutorFunction::JavascriptPromiseAsyncSpawnStepArgumentExecutorFunction(DynamicType* type, FunctionInfo* functionInfo, JavascriptGenerator* generator, Var argument, Var resolve, Var reject, bool isReject)
- : RuntimeFunction(type, functionInfo), generator(generator), argument(argument), resolve(resolve), reject(reject), isReject(isReject)
- { }
- bool JavascriptPromiseAsyncSpawnStepArgumentExecutorFunction::Is(Var var)
- {
- if (JavascriptFunction::Is(var))
- {
- JavascriptFunction* obj = JavascriptFunction::UnsafeFromVar(var);
- return VirtualTableInfo<JavascriptPromiseAsyncSpawnStepArgumentExecutorFunction>::HasVirtualTable(obj)
- || VirtualTableInfo<CrossSiteObject<JavascriptPromiseAsyncSpawnStepArgumentExecutorFunction>>::HasVirtualTable(obj);
- }
- return false;
- }
- JavascriptPromiseAsyncSpawnStepArgumentExecutorFunction* JavascriptPromiseAsyncSpawnStepArgumentExecutorFunction::FromVar(Var var)
- {
- AssertOrFailFast(JavascriptPromiseAsyncSpawnStepArgumentExecutorFunction::Is(var));
- return static_cast<JavascriptPromiseAsyncSpawnStepArgumentExecutorFunction*>(var);
- }
- JavascriptPromiseAsyncSpawnStepArgumentExecutorFunction* JavascriptPromiseAsyncSpawnStepArgumentExecutorFunction::UnsafeFromVar(Var var)
- {
- Assert(JavascriptPromiseAsyncSpawnStepArgumentExecutorFunction::Is(var));
- return static_cast<JavascriptPromiseAsyncSpawnStepArgumentExecutorFunction*>(var);
- }
- JavascriptGenerator* JavascriptPromiseAsyncSpawnStepArgumentExecutorFunction::GetGenerator()
- {
- return this->generator;
- }
- Var JavascriptPromiseAsyncSpawnStepArgumentExecutorFunction::GetResolve()
- {
- return this->resolve;
- }
- Var JavascriptPromiseAsyncSpawnStepArgumentExecutorFunction::GetReject()
- {
- return this->reject;
- }
- bool JavascriptPromiseAsyncSpawnStepArgumentExecutorFunction::GetIsReject()
- {
- return this->isReject;
- }
- Var JavascriptPromiseAsyncSpawnStepArgumentExecutorFunction::GetArgument()
- {
- return this->argument;
- }
- #if ENABLE_TTD
- void JavascriptPromiseAsyncSpawnStepArgumentExecutorFunction::MarkVisitKindSpecificPtrs(TTD::SnapshotExtractor* extractor)
- {
- if (this->generator != nullptr)
- {
- extractor->MarkVisitVar(this->generator);
- }
- if (this->reject != nullptr)
- {
- extractor->MarkVisitVar(this->reject);
- }
- if (this->resolve != nullptr)
- {
- extractor->MarkVisitVar(this->resolve);
- }
- if (this->argument != nullptr)
- {
- extractor->MarkVisitVar(this->argument);
- }
- }
- TTD::NSSnapObjects::SnapObjectType JavascriptPromiseAsyncSpawnStepArgumentExecutorFunction::GetSnapTag_TTD() const
- {
- return TTD::NSSnapObjects::SnapObjectType::JavascriptPromiseAsyncSpawnStepArgumentExecutorFunction;
- }
- void JavascriptPromiseAsyncSpawnStepArgumentExecutorFunction::ExtractSnapObjectDataInto(TTD::NSSnapObjects::SnapObject* objData, TTD::SlabAllocator& alloc)
- {
- TTD::NSSnapObjects::SnapJavascriptPromiseAsyncSpawnStepArgumentExecutorFunctionInfo* info = alloc.SlabAllocateStruct<TTD::NSSnapObjects::SnapJavascriptPromiseAsyncSpawnStepArgumentExecutorFunctionInfo>();
- info->generator = TTD_CONVERT_VAR_TO_PTR_ID(this->generator);
- info->reject = this->reject;
- info->resolve = this->resolve;
- info->argument = this->argument;
- info->isReject = this->isReject;
- info->entryPoint = 0;
- JavascriptMethod entryPoint = this->GetFunctionInfo()->GetOriginalEntryPoint();
- if (entryPoint == JavascriptPromise::EntryJavascriptPromiseAsyncSpawnStepNextExecutorFunction)
- {
- info->entryPoint = 1;
- }
- else if (entryPoint == JavascriptPromise::EntryJavascriptPromiseAsyncSpawnStepThrowExecutorFunction)
- {
- info->entryPoint = 2;
- }
- else if (entryPoint == JavascriptPromise::EntryJavascriptPromiseAsyncSpawnCallStepExecutorFunction)
- {
- info->entryPoint = 3;
- }
- else
- {
- TTDAssert(false, "Unexpected entrypoint found JavascriptPromiseAsyncSpawnStepArgumentExecutorFunction");
- }
- const uint32 maxDeps = 4;
- uint32 depCount = 0;
- TTD_PTR_ID* depArray = alloc.SlabReserveArraySpace<TTD_PTR_ID>(maxDeps);
- if (this->reject != nullptr && TTD::JsSupport::IsVarComplexKind(this->reject))
- {
- depArray[depCount] = TTD_CONVERT_VAR_TO_PTR_ID(this->reject);
- depCount++;
- }
- if (this->resolve != nullptr && TTD::JsSupport::IsVarComplexKind(this->resolve))
- {
- depArray[depCount] = TTD_CONVERT_VAR_TO_PTR_ID(this->resolve);
- depCount++;
- }
- if (this->argument != nullptr && TTD::JsSupport::IsVarComplexKind(this->argument))
- {
- depArray[depCount] = TTD_CONVERT_VAR_TO_PTR_ID(this->argument);
- depCount++;
- }
- if (this->generator != nullptr)
- {
- depArray[depCount] = TTD_CONVERT_VAR_TO_PTR_ID(this->generator);
- depCount++;
- }
- if (depCount > 0)
- {
- alloc.SlabCommitArraySpace<TTD_PTR_ID>(depCount, maxDeps);
- }
- else
- {
- alloc.SlabAbortArraySpace<TTD_PTR_ID>(maxDeps);
- }
- if (depCount == 0)
- {
- TTD::NSSnapObjects::StdExtractSetKindSpecificInfo<TTD::NSSnapObjects::SnapJavascriptPromiseAsyncSpawnStepArgumentExecutorFunctionInfo*, TTD::NSSnapObjects::SnapObjectType::JavascriptPromiseAsyncSpawnStepArgumentExecutorFunction>(objData, info);
- }
- else
- {
- TTDAssert(depArray != nullptr, "depArray should be non-null if depCount is > 0");
- TTD::NSSnapObjects::StdExtractSetKindSpecificInfo<TTD::NSSnapObjects::SnapJavascriptPromiseAsyncSpawnStepArgumentExecutorFunctionInfo*, TTD::NSSnapObjects::SnapObjectType::JavascriptPromiseAsyncSpawnStepArgumentExecutorFunction>(objData, info, alloc, depCount, depArray);
- }
- }
- #endif
- JavascriptPromiseCapabilitiesExecutorFunction::JavascriptPromiseCapabilitiesExecutorFunction(DynamicType* type, FunctionInfo* functionInfo, JavascriptPromiseCapability* capability)
- : RuntimeFunction(type, functionInfo), capability(capability)
- { }
- bool JavascriptPromiseCapabilitiesExecutorFunction::Is(Var var)
- {
- if (JavascriptFunction::Is(var))
- {
- JavascriptFunction* obj = JavascriptFunction::UnsafeFromVar(var);
- return VirtualTableInfo<JavascriptPromiseCapabilitiesExecutorFunction>::HasVirtualTable(obj)
- || VirtualTableInfo<CrossSiteObject<JavascriptPromiseCapabilitiesExecutorFunction>>::HasVirtualTable(obj);
- }
- return false;
- }
- JavascriptPromiseCapabilitiesExecutorFunction* JavascriptPromiseCapabilitiesExecutorFunction::FromVar(Var var)
- {
- AssertOrFailFast(JavascriptPromiseCapabilitiesExecutorFunction::Is(var));
- return static_cast<JavascriptPromiseCapabilitiesExecutorFunction*>(var);
- }
- JavascriptPromiseCapabilitiesExecutorFunction* JavascriptPromiseCapabilitiesExecutorFunction::UnsafeFromVar(Var var)
- {
- Assert(JavascriptPromiseCapabilitiesExecutorFunction::Is(var));
- return static_cast<JavascriptPromiseCapabilitiesExecutorFunction*>(var);
- }
- JavascriptPromiseCapability* JavascriptPromiseCapabilitiesExecutorFunction::GetCapability()
- {
- return this->capability;
- }
- #if ENABLE_TTD
- void JavascriptPromiseCapabilitiesExecutorFunction::MarkVisitKindSpecificPtrs(TTD::SnapshotExtractor* extractor)
- {
- TTDAssert(false, "Not Implemented Yet");
- }
- TTD::NSSnapObjects::SnapObjectType JavascriptPromiseCapabilitiesExecutorFunction::GetSnapTag_TTD() const
- {
- TTDAssert(false, "Not Implemented Yet");
- return TTD::NSSnapObjects::SnapObjectType::Invalid;
- }
- void JavascriptPromiseCapabilitiesExecutorFunction::ExtractSnapObjectDataInto(TTD::NSSnapObjects::SnapObject* objData, TTD::SlabAllocator& alloc)
- {
- TTDAssert(false, "Not Implemented Yet");
- }
- #endif
- JavascriptPromiseCapability* JavascriptPromiseCapability::New(Var promise, Var resolve, Var reject, ScriptContext* scriptContext)
- {
- return RecyclerNew(scriptContext->GetRecycler(), JavascriptPromiseCapability, promise, resolve, reject);
- }
- Var JavascriptPromiseCapability::GetResolve()
- {
- return this->resolve;
- }
- Var JavascriptPromiseCapability::GetReject()
- {
- return this->reject;
- }
- Var JavascriptPromiseCapability::GetPromise()
- {
- return this->promise;
- }
- void JavascriptPromiseCapability::SetPromise(Var promise)
- {
- this->promise = promise;
- }
- void JavascriptPromiseCapability::SetResolve(Var resolve)
- {
- this->resolve = resolve;
- }
- void JavascriptPromiseCapability::SetReject(Var reject)
- {
- this->reject = reject;
- }
- #if ENABLE_TTD
- void JavascriptPromiseCapability::MarkVisitPtrs(TTD::SnapshotExtractor* extractor)
- {
- TTDAssert(this->promise != nullptr && this->resolve != nullptr && this->reject != nullptr, "Seems odd, I was not expecting this!!!");
- extractor->MarkVisitVar(this->promise);
- extractor->MarkVisitVar(this->resolve);
- extractor->MarkVisitVar(this->reject);
- }
- void JavascriptPromiseCapability::ExtractSnapPromiseCapabilityInto(TTD::NSSnapValues::SnapPromiseCapabilityInfo* snapPromiseCapability, JsUtil::List<TTD_PTR_ID, HeapAllocator>& depOnList, TTD::SlabAllocator& alloc)
- {
- snapPromiseCapability->CapabilityId = TTD_CONVERT_PROMISE_INFO_TO_PTR_ID(this);
- snapPromiseCapability->PromiseVar = this->promise;
- if(TTD::JsSupport::IsVarComplexKind(this->promise))
- {
- depOnList.Add(TTD_CONVERT_VAR_TO_PTR_ID(this->resolve));
- }
- snapPromiseCapability->ResolveVar = this->resolve;
- if(TTD::JsSupport::IsVarComplexKind(this->resolve))
- {
- depOnList.Add(TTD_CONVERT_VAR_TO_PTR_ID(this->resolve));
- }
- snapPromiseCapability->RejectVar = this->reject;
- if(TTD::JsSupport::IsVarComplexKind(this->reject))
- {
- depOnList.Add(TTD_CONVERT_VAR_TO_PTR_ID(this->reject));
- }
- }
- #endif
- JavascriptPromiseReaction* JavascriptPromiseReaction::New(JavascriptPromiseCapability* capabilities, RecyclableObject* handler, ScriptContext* scriptContext)
- {
- return RecyclerNew(scriptContext->GetRecycler(), JavascriptPromiseReaction, capabilities, handler);
- }
- JavascriptPromiseCapability* JavascriptPromiseReaction::GetCapabilities()
- {
- return this->capabilities;
- }
- RecyclableObject* JavascriptPromiseReaction::GetHandler()
- {
- return this->handler;
- }
- #if ENABLE_TTD
- void JavascriptPromiseReaction::MarkVisitPtrs(TTD::SnapshotExtractor* extractor)
- {
- TTDAssert(this->handler != nullptr && this->capabilities != nullptr, "Seems odd, I was not expecting this!!!");
- extractor->MarkVisitVar(this->handler);
- this->capabilities->MarkVisitPtrs(extractor);
- }
- void JavascriptPromiseReaction::ExtractSnapPromiseReactionInto(TTD::NSSnapValues::SnapPromiseReactionInfo* snapPromiseReaction, JsUtil::List<TTD_PTR_ID, HeapAllocator>& depOnList, TTD::SlabAllocator& alloc)
- {
- TTDAssert(this->handler != nullptr && this->capabilities != nullptr, "Seems odd, I was not expecting this!!!");
- snapPromiseReaction->PromiseReactionId = TTD_CONVERT_PROMISE_INFO_TO_PTR_ID(this);
- snapPromiseReaction->HandlerObjId = TTD_CONVERT_VAR_TO_PTR_ID(this->handler);
- depOnList.Add(snapPromiseReaction->HandlerObjId);
- this->capabilities->ExtractSnapPromiseCapabilityInto(&snapPromiseReaction->Capabilities, depOnList, alloc);
- }
- #endif
- JavascriptPromiseReaction* JavascriptPromiseReactionTaskFunction::GetReaction()
- {
- return this->reaction;
- }
- Var JavascriptPromiseReactionTaskFunction::GetArgument()
- {
- return this->argument;
- }
- #if ENABLE_TTD
- void JavascriptPromiseReactionTaskFunction::MarkVisitKindSpecificPtrs(TTD::SnapshotExtractor* extractor)
- {
- TTDAssert(this->argument != nullptr && this->reaction != nullptr, "Was not expecting this!!!");
- extractor->MarkVisitVar(this->argument);
- this->reaction->MarkVisitPtrs(extractor);
- }
- TTD::NSSnapObjects::SnapObjectType JavascriptPromiseReactionTaskFunction::GetSnapTag_TTD() const
- {
- return TTD::NSSnapObjects::SnapObjectType::SnapPromiseReactionTaskFunctionObject;
- }
- void JavascriptPromiseReactionTaskFunction::ExtractSnapObjectDataInto(TTD::NSSnapObjects::SnapObject* objData, TTD::SlabAllocator& alloc)
- {
- TTD::NSSnapObjects::SnapPromiseReactionTaskFunctionInfo* sprtfi = alloc.SlabAllocateStruct<TTD::NSSnapObjects::SnapPromiseReactionTaskFunctionInfo>();
- JsUtil::List<TTD_PTR_ID, HeapAllocator> depOnList(&HeapAllocator::Instance);
- sprtfi->Argument = this->argument;
- if(this->argument != nullptr && TTD::JsSupport::IsVarComplexKind(this->argument))
- {
- depOnList.Add(TTD_CONVERT_VAR_TO_PTR_ID(this->argument));
- }
- this->reaction->ExtractSnapPromiseReactionInto(&sprtfi->Reaction, depOnList, alloc);
- //see what we need to do wrt dependencies
- if(depOnList.Count() == 0)
- {
- TTD::NSSnapObjects::StdExtractSetKindSpecificInfo<TTD::NSSnapObjects::SnapPromiseReactionTaskFunctionInfo*, TTD::NSSnapObjects::SnapObjectType::SnapPromiseReactionTaskFunctionObject>(objData, sprtfi);
- }
- else
- {
- uint32 depOnCount = depOnList.Count();
- TTD_PTR_ID* depOnArray = alloc.SlabAllocateArray<TTD_PTR_ID>(depOnCount);
- for(uint32 i = 0; i < depOnCount; ++i)
- {
- depOnArray[i] = depOnList.Item(i);
- }
- TTD::NSSnapObjects::StdExtractSetKindSpecificInfo<TTD::NSSnapObjects::SnapPromiseReactionTaskFunctionInfo*, TTD::NSSnapObjects::SnapObjectType::SnapPromiseReactionTaskFunctionObject>(objData, sprtfi, alloc, depOnCount, depOnArray);
- }
- }
- #endif
- JavascriptPromise* JavascriptPromiseResolveThenableTaskFunction::GetPromise()
- {
- return this->promise;
- }
- RecyclableObject* JavascriptPromiseResolveThenableTaskFunction::GetThenable()
- {
- return this->thenable;
- }
- RecyclableObject* JavascriptPromiseResolveThenableTaskFunction::GetThenFunction()
- {
- return this->thenFunction;
- }
- #if ENABLE_TTD
- void JavascriptPromiseResolveThenableTaskFunction::MarkVisitKindSpecificPtrs(TTD::SnapshotExtractor* extractor)
- {
- TTDAssert(false, "Not Implemented Yet");
- }
- TTD::NSSnapObjects::SnapObjectType JavascriptPromiseResolveThenableTaskFunction::GetSnapTag_TTD() const
- {
- TTDAssert(false, "Not Implemented Yet");
- return TTD::NSSnapObjects::SnapObjectType::Invalid;
- }
- void JavascriptPromiseResolveThenableTaskFunction::ExtractSnapObjectDataInto(TTD::NSSnapObjects::SnapObject* objData, TTD::SlabAllocator& alloc)
- {
- TTDAssert(false, "Not Implemented Yet");
- }
- #endif
- JavascriptPromiseAllResolveElementFunction::JavascriptPromiseAllResolveElementFunction(DynamicType* type)
- : RuntimeFunction(type, &Js::JavascriptPromise::EntryInfo::AllResolveElementFunction), index(0), values(nullptr), capabilities(nullptr), remainingElementsWrapper(nullptr), alreadyCalled(false)
- { }
- JavascriptPromiseAllResolveElementFunction::JavascriptPromiseAllResolveElementFunction(DynamicType* type, FunctionInfo* functionInfo, uint32 index, JavascriptArray* values, JavascriptPromiseCapability* capabilities, JavascriptPromiseAllResolveElementFunctionRemainingElementsWrapper* remainingElementsWrapper)
- : RuntimeFunction(type, functionInfo), index(index), values(values), capabilities(capabilities), remainingElementsWrapper(remainingElementsWrapper), alreadyCalled(false)
- { }
- bool JavascriptPromiseAllResolveElementFunction::Is(Var var)
- {
- if (JavascriptFunction::Is(var))
- {
- JavascriptFunction* obj = JavascriptFunction::UnsafeFromVar(var);
- return VirtualTableInfo<JavascriptPromiseAllResolveElementFunction>::HasVirtualTable(obj)
- || VirtualTableInfo<CrossSiteObject<JavascriptPromiseAllResolveElementFunction>>::HasVirtualTable(obj);
- }
- return false;
- }
- JavascriptPromiseAllResolveElementFunction* JavascriptPromiseAllResolveElementFunction::FromVar(Var var)
- {
- AssertOrFailFast(JavascriptPromiseAllResolveElementFunction::Is(var));
- return static_cast<JavascriptPromiseAllResolveElementFunction*>(var);
- }
- JavascriptPromiseAllResolveElementFunction* JavascriptPromiseAllResolveElementFunction::UnsafeFromVar(Var var)
- {
- Assert(JavascriptPromiseAllResolveElementFunction::Is(var));
- return static_cast<JavascriptPromiseAllResolveElementFunction*>(var);
- }
- JavascriptPromiseCapability* JavascriptPromiseAllResolveElementFunction::GetCapabilities()
- {
- return this->capabilities;
- }
- uint32 JavascriptPromiseAllResolveElementFunction::GetIndex()
- {
- return this->index;
- }
- uint32 JavascriptPromiseAllResolveElementFunction::GetRemainingElements()
- {
- return this->remainingElementsWrapper->remainingElements;
- }
- JavascriptArray* JavascriptPromiseAllResolveElementFunction::GetValues()
- {
- return this->values;
- }
- uint32 JavascriptPromiseAllResolveElementFunction::DecrementRemainingElements()
- {
- return --(this->remainingElementsWrapper->remainingElements);
- }
- bool JavascriptPromiseAllResolveElementFunction::IsAlreadyCalled() const
- {
- return this->alreadyCalled;
- }
- void JavascriptPromiseAllResolveElementFunction::SetAlreadyCalled(const bool is)
- {
- this->alreadyCalled = is;
- }
- #if ENABLE_TTD
- void JavascriptPromiseAllResolveElementFunction::MarkVisitKindSpecificPtrs(TTD::SnapshotExtractor* extractor)
- {
- TTDAssert(this->capabilities != nullptr && this->remainingElementsWrapper != nullptr && this->values != nullptr, "Don't think these can be null");
- this->capabilities->MarkVisitPtrs(extractor);
- extractor->MarkVisitVar(this->values);
- }
- TTD::NSSnapObjects::SnapObjectType JavascriptPromiseAllResolveElementFunction::GetSnapTag_TTD() const
- {
- return TTD::NSSnapObjects::SnapObjectType::SnapPromiseAllResolveElementFunctionObject;
- }
- void JavascriptPromiseAllResolveElementFunction::ExtractSnapObjectDataInto(TTD::NSSnapObjects::SnapObject* objData, TTD::SlabAllocator& alloc)
- {
- TTD::NSSnapObjects::SnapPromiseAllResolveElementFunctionInfo* sprai = alloc.SlabAllocateStruct<TTD::NSSnapObjects::SnapPromiseAllResolveElementFunctionInfo>();
- JsUtil::List<TTD_PTR_ID, HeapAllocator> depOnList(&HeapAllocator::Instance);
- this->capabilities->ExtractSnapPromiseCapabilityInto(&sprai->Capabilities, depOnList, alloc);
- sprai->Index = this->index;
- sprai->RemainingElementsWrapperId = TTD_CONVERT_PROMISE_INFO_TO_PTR_ID(this->remainingElementsWrapper);
- sprai->RemainingElementsValue = this->remainingElementsWrapper->remainingElements;
- sprai->Values = TTD_CONVERT_VAR_TO_PTR_ID(this->values);
- depOnList.Add(sprai->Values);
- sprai->AlreadyCalled = this->alreadyCalled;
- uint32 depOnCount = depOnList.Count();
- TTD_PTR_ID* depOnArray = alloc.SlabAllocateArray<TTD_PTR_ID>(depOnCount);
- for(uint32 i = 0; i < depOnCount; ++i)
- {
- depOnArray[i] = depOnList.Item(i);
- }
- TTD::NSSnapObjects::StdExtractSetKindSpecificInfo<TTD::NSSnapObjects::SnapPromiseAllResolveElementFunctionInfo*, TTD::NSSnapObjects::SnapObjectType::SnapPromiseAllResolveElementFunctionObject>(objData, sprai, alloc, depOnCount, depOnArray);
- }
- #endif
- Var JavascriptPromise::EntryGetterSymbolSpecies(RecyclableObject* function, CallInfo callInfo, ...)
- {
- ARGUMENTS(args, callInfo);
- Assert(args.Info.Count > 0);
- return args[0];
- }
- //static
- JavascriptPromise* JavascriptPromise::CreateEnginePromise(ScriptContext *scriptContext)
- {
- JavascriptPromiseResolveOrRejectFunction *resolve = nullptr;
- JavascriptPromiseResolveOrRejectFunction *reject = nullptr;
- JavascriptPromise *promise = scriptContext->GetLibrary()->CreatePromise();
- JavascriptPromise::InitializePromise(promise, &resolve, &reject, scriptContext);
- return promise;
- }
- } // namespace Js
|