JavascriptPromise.cpp 106 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090209120922093209420952096209720982099210021012102210321042105210621072108210921102111211221132114211521162117211821192120212121222123212421252126212721282129213021312132213321342135213621372138213921402141214221432144214521462147214821492150215121522153215421552156215721582159216021612162216321642165216621672168216921702171217221732174217521762177217821792180218121822183218421852186218721882189219021912192219321942195219621972198219922002201220222032204220522062207220822092210221122122213221422152216221722182219222022212222222322242225222622272228222922302231223222332234223522362237223822392240224122422243224422452246224722482249225022512252225322542255225622572258225922602261226222632264226522662267226822692270227122722273227422752276227722782279228022812282228322842285228622872288228922902291229222932294229522962297229822992300230123022303230423052306230723082309231023112312231323142315231623172318231923202321232223232324232523262327232823292330233123322333233423352336233723382339234023412342234323442345234623472348234923502351235223532354235523562357235823592360236123622363236423652366236723682369237023712372237323742375237623772378237923802381238223832384238523862387238823892390239123922393239423952396239723982399240024012402240324042405240624072408240924102411241224132414241524162417241824192420242124222423242424252426242724282429243024312432243324342435243624372438243924402441244224432444244524462447244824492450245124522453245424552456245724582459246024612462246324642465246624672468246924702471247224732474247524762477247824792480248124822483248424852486248724882489249024912492249324942495249624972498249925002501250225032504250525062507250825092510251125122513251425152516251725182519252025212522252325242525252625272528252925302531253225332534253525362537253825392540254125422543254425452546254725482549
  1. //-------------------------------------------------------------------------------------------------------
  2. // Copyright (C) Microsoft. All rights reserved.
  3. // Copyright (c) 2021 ChakraCore Project Contributors. All rights reserved.
  4. // Licensed under the MIT license. See LICENSE.txt file in the project root for full license information.
  5. //-------------------------------------------------------------------------------------------------------
  6. #include "RuntimeLibraryPch.h"
  7. namespace Js
  8. {
  9. JavascriptPromise::JavascriptPromise(DynamicType * type)
  10. : DynamicObject(type),
  11. isHandled(false),
  12. status(PromiseStatus::PromiseStatusCode_Undefined),
  13. result(nullptr),
  14. reactions(nullptr)
  15. {
  16. Assert(type->GetTypeId() == TypeIds_Promise);
  17. }
  18. // Promise() as defined by ES 2016 Sections 25.4.3.1
  19. Var JavascriptPromise::NewInstance(RecyclableObject* function, CallInfo callInfo, ...)
  20. {
  21. PROBE_STACK(function->GetScriptContext(), Js::Constants::MinStackDefault);
  22. ARGUMENTS(args, callInfo);
  23. AssertMsg(args.Info.Count > 0, "Should always have implicit 'this'");
  24. ScriptContext* scriptContext = function->GetScriptContext();
  25. JavascriptLibrary* library = scriptContext->GetLibrary();
  26. CHAKRATEL_LANGSTATS_INC_LANGFEATURECOUNT(ES6, Promise, scriptContext);
  27. // SkipDefaultNewObject function flag should have prevented the default object from
  28. // being created, except when call true a host dispatch
  29. Var newTarget = args.GetNewTarget();
  30. bool isCtorSuperCall = JavascriptOperators::GetAndAssertIsConstructorSuperCall(args);
  31. AUTO_TAG_NATIVE_LIBRARY_ENTRY(function, callInfo, _u("Promise"));
  32. // 1. If NewTarget is undefined, throw a TypeError exception.
  33. if ((callInfo.Flags & CallFlags_New) != CallFlags_New || (newTarget != nullptr && JavascriptOperators::IsUndefined(newTarget)))
  34. {
  35. JavascriptError::ThrowTypeError(scriptContext, JSERR_ClassConstructorCannotBeCalledWithoutNew, _u("Promise"));
  36. }
  37. // 2. If IsCallable(executor) is false, throw a TypeError exception.
  38. if (args.Info.Count < 2 || !JavascriptConversion::IsCallable(args[1]))
  39. {
  40. JavascriptError::ThrowTypeError(scriptContext, JSERR_FunctionArgument_NeedFunction, _u("Promise"));
  41. }
  42. RecyclableObject* executor = VarTo<RecyclableObject>(args[1]);
  43. // 3. Let promise be ? OrdinaryCreateFromConstructor(NewTarget, "%PromisePrototype%", <<[[PromiseState]], [[PromiseResult]], [[PromiseFulfillReactions]], [[PromiseRejectReactions]], [[PromiseIsHandled]] >>).
  44. JavascriptPromise* promise = library->CreatePromise();
  45. if (isCtorSuperCall)
  46. {
  47. JavascriptOperators::OrdinaryCreateFromConstructor(VarTo<RecyclableObject>(newTarget), promise, library->GetPromisePrototype(), scriptContext);
  48. }
  49. JavascriptPromiseResolveOrRejectFunction* resolve;
  50. JavascriptPromiseResolveOrRejectFunction* reject;
  51. // 4. Set promise's [[PromiseState]] internal slot to "pending".
  52. // 5. Set promise's [[PromiseFulfillReactions]] internal slot to a new empty List.
  53. // 6. Set promise's [[PromiseRejectReactions]] internal slot to a new empty List.
  54. // 7. Set promise's [[PromiseIsHandled]] internal slot to false.
  55. // 8. Let resolvingFunctions be CreateResolvingFunctions(promise).
  56. InitializePromise(promise, &resolve, &reject, scriptContext);
  57. JavascriptExceptionObject* exception = nullptr;
  58. // 9. Let completion be Call(executor, undefined, << resolvingFunctions.[[Resolve]], resolvingFunctions.[[Reject]] >>).
  59. try
  60. {
  61. BEGIN_SAFE_REENTRANT_CALL(scriptContext->GetThreadContext())
  62. {
  63. CALL_FUNCTION(scriptContext->GetThreadContext(),
  64. executor, CallInfo(CallFlags_Value, 3),
  65. library->GetUndefined(),
  66. resolve,
  67. reject);
  68. }
  69. END_SAFE_REENTRANT_CALL
  70. }
  71. catch (const JavascriptException& err)
  72. {
  73. exception = err.GetAndClear();
  74. }
  75. if (exception != nullptr)
  76. {
  77. // 10. If completion is an abrupt completion, then
  78. // a. Perform ? Call(resolvingFunctions.[[Reject]], undefined, << completion.[[Value]] >>).
  79. TryRejectWithExceptionObject(exception, reject, scriptContext);
  80. }
  81. // 11. Return promise.
  82. return promise;
  83. }
  84. void JavascriptPromise::InitializePromise(JavascriptPromise* promise, JavascriptPromiseResolveOrRejectFunction** resolve, JavascriptPromiseResolveOrRejectFunction** reject, ScriptContext* scriptContext)
  85. {
  86. Assert(promise->GetStatus() == PromiseStatusCode_Undefined);
  87. Assert(resolve);
  88. Assert(reject);
  89. Recycler* recycler = scriptContext->GetRecycler();
  90. JavascriptLibrary* library = scriptContext->GetLibrary();
  91. promise->SetStatus(PromiseStatusCode_Unresolved);
  92. promise->reactions = RecyclerNew(recycler, JavascriptPromiseReactionList, recycler);
  93. JavascriptPromiseResolveOrRejectFunctionAlreadyResolvedWrapper* alreadyResolvedRecord = RecyclerNewStructZ(scriptContext->GetRecycler(), JavascriptPromiseResolveOrRejectFunctionAlreadyResolvedWrapper);
  94. alreadyResolvedRecord->alreadyResolved = false;
  95. *resolve = library->CreatePromiseResolveOrRejectFunction(EntryResolveOrRejectFunction, promise, false, alreadyResolvedRecord);
  96. *reject = library->CreatePromiseResolveOrRejectFunction(EntryResolveOrRejectFunction, promise, true, alreadyResolvedRecord);
  97. }
  98. BOOL JavascriptPromise::GetDiagValueString(StringBuilder<ArenaAllocator>* stringBuilder, ScriptContext* requestContext)
  99. {
  100. stringBuilder->AppendCppLiteral(_u("[...]"));
  101. return TRUE;
  102. }
  103. BOOL JavascriptPromise::GetDiagTypeString(StringBuilder<ArenaAllocator>* stringBuilder, ScriptContext* requestContext)
  104. {
  105. stringBuilder->AppendCppLiteral(_u("Promise"));
  106. return TRUE;
  107. }
  108. JavascriptPromiseReactionList* JavascriptPromise::GetReactions()
  109. {
  110. return this->reactions;
  111. }
  112. // Promise.all as described in ES 2015 Section 25.4.4.1
  113. Var JavascriptPromise::EntryAll(RecyclableObject* function, CallInfo callInfo, ...)
  114. {
  115. PROBE_STACK(function->GetScriptContext(), Js::Constants::MinStackDefault);
  116. ARGUMENTS(args, callInfo);
  117. Assert(!(callInfo.Flags & CallFlags_New));
  118. ScriptContext* scriptContext = function->GetScriptContext();
  119. AUTO_TAG_NATIVE_LIBRARY_ENTRY(function, callInfo, _u("Promise.all"));
  120. // 1. Let C be the this value.
  121. Var constructor = args[0];
  122. // 2. If Type(C) is not Object, throw a TypeError exception.
  123. if (!JavascriptOperators::IsObject(constructor))
  124. {
  125. JavascriptError::ThrowTypeError(scriptContext, JSERR_This_NeedObject, _u("Promise.all"));
  126. }
  127. JavascriptLibrary* library = scriptContext->GetLibrary();
  128. Var iterable;
  129. if (args.Info.Count > 1)
  130. {
  131. iterable = args[1];
  132. }
  133. else
  134. {
  135. iterable = library->GetUndefined();
  136. }
  137. // 3. Let promiseCapability be NewPromiseCapability(C).
  138. JavascriptPromiseCapability* promiseCapability = NewPromiseCapability(constructor, scriptContext);
  139. // We know that constructor is an object at this point - further, we even know that it is a constructor - because NewPromiseCapability
  140. // would throw otherwise. That means we can safely cast constructor into a RecyclableObject* now and avoid having to perform ToObject
  141. // as part of the Invoke operation performed inside the loop below.
  142. RecyclableObject* constructorObject = VarTo<RecyclableObject>(constructor);
  143. uint32 index = 0;
  144. JavascriptArray* values = nullptr;
  145. // We can't use a simple counter for the remaining element count since each Promise.all Resolve Element Function needs to know how many
  146. // elements are remaining when it runs and needs to update that counter for all other functions created by this call to Promise.all.
  147. // We can't just use a static variable, either, since this element count is only used for the Promise.all Resolve Element Functions created
  148. // by this call to Promise.all.
  149. JavascriptPromiseAllResolveElementFunctionRemainingElementsWrapper* remainingElementsWrapper = RecyclerNewStructZ(scriptContext->GetRecycler(), JavascriptPromiseAllResolveElementFunctionRemainingElementsWrapper);
  150. remainingElementsWrapper->remainingElements = 1;
  151. JavascriptExceptionObject* exception = nullptr;
  152. try
  153. {
  154. // 4. Let iterator be GetIterator(iterable).
  155. RecyclableObject* iterator = JavascriptOperators::GetIterator(iterable, scriptContext);
  156. Var resolveVar = JavascriptOperators::GetProperty(constructorObject, Js::PropertyIds::resolve, scriptContext);
  157. if (!JavascriptConversion::IsCallable(resolveVar))
  158. {
  159. JavascriptError::ThrowTypeError(scriptContext, JSERR_NeedFunction);
  160. }
  161. RecyclableObject* resolveFunc = VarTo<RecyclableObject>(resolveVar);
  162. values = library->CreateArray(0);
  163. JavascriptOperators::DoIteratorStepAndValue(iterator, scriptContext, [&](Var next)
  164. {
  165. ThreadContext * threadContext = scriptContext->GetThreadContext();
  166. Var nextPromise = nullptr;
  167. BEGIN_SAFE_REENTRANT_CALL(threadContext)
  168. {
  169. nextPromise = CALL_FUNCTION(threadContext,
  170. resolveFunc, Js::CallInfo(CallFlags_Value, 2),
  171. constructorObject,
  172. next);
  173. }
  174. END_SAFE_REENTRANT_CALL
  175. JavascriptPromiseAllResolveElementFunction* resolveElement = library->CreatePromiseAllResolveElementFunction(EntryAllResolveElementFunction, index, values, promiseCapability, remainingElementsWrapper);
  176. remainingElementsWrapper->remainingElements++;
  177. RecyclableObject* nextPromiseObject;
  178. if (!JavascriptConversion::ToObject(nextPromise, scriptContext, &nextPromiseObject))
  179. {
  180. JavascriptError::ThrowTypeError(scriptContext, JSERR_NeedObject);
  181. }
  182. Var thenVar = JavascriptOperators::GetProperty(nextPromiseObject, Js::PropertyIds::then, scriptContext);
  183. if (!JavascriptConversion::IsCallable(thenVar))
  184. {
  185. JavascriptError::ThrowTypeError(scriptContext, JSERR_NeedFunction);
  186. }
  187. RecyclableObject* thenFunc = VarTo<RecyclableObject>(thenVar);
  188. BEGIN_SAFE_REENTRANT_CALL(threadContext)
  189. {
  190. CALL_FUNCTION(scriptContext->GetThreadContext(),
  191. thenFunc, Js::CallInfo(CallFlags_Value, 3),
  192. nextPromiseObject,
  193. resolveElement,
  194. promiseCapability->GetReject());
  195. }
  196. END_SAFE_REENTRANT_CALL
  197. index++;
  198. });
  199. remainingElementsWrapper->remainingElements--;
  200. if (remainingElementsWrapper->remainingElements == 0)
  201. {
  202. Assert(values != nullptr);
  203. TryCallResolveOrRejectHandler(promiseCapability->GetResolve(), values, scriptContext);
  204. }
  205. }
  206. catch (const JavascriptException& err)
  207. {
  208. exception = err.GetAndClear();
  209. }
  210. if (exception != nullptr)
  211. {
  212. TryRejectWithExceptionObject(exception, promiseCapability->GetReject(), scriptContext);
  213. }
  214. return promiseCapability->GetPromise();
  215. }
  216. Var JavascriptPromise::EntryAny(RecyclableObject* function, CallInfo callInfo, ...)
  217. {
  218. PROBE_STACK(function->GetScriptContext(), Js::Constants::MinStackDefault);
  219. ARGUMENTS(args, callInfo);
  220. Assert(!(callInfo.Flags & CallFlags_New));
  221. ScriptContext* scriptContext = function->GetScriptContext();
  222. AUTO_TAG_NATIVE_LIBRARY_ENTRY(function, callInfo, _u("Promise.any"));
  223. // 1. Let C be the this value.
  224. Var C = args[0];
  225. // 2. Let promiseCapability be ? NewPromiseCapability(C).
  226. JavascriptPromiseCapability* promiseCapability = NewPromiseCapability(C, scriptContext);
  227. RecyclableObject* constructor = UnsafeVarTo<RecyclableObject>(C);
  228. JavascriptLibrary* library = scriptContext->GetLibrary();
  229. RecyclableObject* promiseResolve = nullptr;
  230. RecyclableObject* iteratorRecord = nullptr;
  231. try {
  232. // 3. Let promiseResolve be GetPromiseResolve(C).
  233. // 4. IfAbruptRejectPromise(promiseResolve, promiseCapability).
  234. Var resolveVar = JavascriptOperators::GetProperty(constructor, Js::PropertyIds::resolve, scriptContext);
  235. if (!JavascriptConversion::IsCallable(resolveVar))
  236. {
  237. JavascriptError::ThrowTypeError(scriptContext, JSERR_NeedFunction);
  238. }
  239. promiseResolve = UnsafeVarTo<RecyclableObject>(resolveVar);
  240. // 5. Let iteratorRecord be GetIterator(iterable).
  241. // 6. IfAbruptRejectPromise(iteratorRecord, promiseCapability).
  242. Var iterable = args.Info.Count > 1 ? args[1] : library->GetUndefined();
  243. iteratorRecord = JavascriptOperators::GetIterator(iterable, scriptContext);
  244. }
  245. catch (const JavascriptException& err)
  246. {
  247. JavascriptExceptionObject* exception = err.GetAndClear();
  248. return JavascriptPromise::CreateRejectedPromise(exception->GetThrownObject(scriptContext), scriptContext);
  249. }
  250. // Abstract operation PerformPromiseAny
  251. // 7. Let result be PerformPromiseAny(iteratorRecord, C, promiseCapability, promiseResolve).
  252. try {
  253. // 1. Assert: ! IsConstructor(constructor) is true.
  254. // 2. Assert: resultCapability is a PromiseCapability Record.
  255. // 3. Assert: ! IsCallable(promiseResolve) is true.
  256. // 4. Let errors be a new empty List.
  257. JavascriptArray* errors = library->CreateArray();
  258. // 5. Let remainingElementsCount be a new Record { [[Value]]: 1 }.
  259. JavascriptPromiseAllResolveElementFunctionRemainingElementsWrapper* remainingElementsWrapper = RecyclerNewStructZ(scriptContext->GetRecycler(), JavascriptPromiseAllResolveElementFunctionRemainingElementsWrapper);
  260. remainingElementsWrapper->remainingElements = 1;
  261. // 6. Let index be 0.
  262. uint32 index = 0;
  263. // 7. Repeat,
  264. JavascriptOperators::DoIteratorStepAndValue(iteratorRecord, scriptContext, [&](Var nextValue) {
  265. // a. Let next be IteratorStep(iteratorRecord).
  266. // e. Let nextValue be IteratorValue(next).
  267. // h. Append undefined to errors.
  268. errors->DirectAppendItem(library->GetUndefined());
  269. // i. Let nextPromise be ? Call(promiseResolve, constructor, << nextValue >> ).
  270. ThreadContext* threadContext = scriptContext->GetThreadContext();
  271. Var nextPromise = nullptr;
  272. BEGIN_SAFE_REENTRANT_CALL(threadContext);
  273. {
  274. nextPromise = CALL_FUNCTION(threadContext,
  275. promiseResolve, Js::CallInfo(CallFlags_Value, 2),
  276. constructor,
  277. nextValue);
  278. }
  279. END_SAFE_REENTRANT_CALL;
  280. JavascriptPromiseResolveOrRejectFunctionAlreadyResolvedWrapper* alreadyCalledWrapper = RecyclerNewStructZ(scriptContext->GetRecycler(), JavascriptPromiseResolveOrRejectFunctionAlreadyResolvedWrapper);
  281. alreadyCalledWrapper->alreadyResolved = false;
  282. // j. Let steps be the algorithm steps defined in Promise.any Reject Element Functions.
  283. // k. Let rejectElement be ! CreateBuiltinFunction(steps, << [[AlreadyCalled]], [[Index]], [[Errors]], [[Capability]], [[RemainingElements]] >> ).
  284. // p. Set rejectElement.[[RemainingElements]] to remainingElementsCount.
  285. Var rejectElement = library->CreatePromiseAnyRejectElementFunction(EntryAnyRejectElementFunction, index, errors, promiseCapability, remainingElementsWrapper, alreadyCalledWrapper);
  286. // q. Set remainingElementsCount.[[Value]] to remainingElementsCount.[[Value]] + 1.
  287. remainingElementsWrapper->remainingElements++;
  288. // r. Perform ? Invoke(nextPromise, "then", << resultCapability.[[Resolve]], rejectElement >> ).
  289. RecyclableObject* nextPromiseObject;
  290. if (!JavascriptConversion::ToObject(nextPromise, scriptContext, &nextPromiseObject))
  291. {
  292. JavascriptError::ThrowTypeError(scriptContext, JSERR_NeedObject);
  293. }
  294. Var thenVar = JavascriptOperators::GetProperty(nextPromiseObject, Js::PropertyIds::then, scriptContext);
  295. if (!JavascriptConversion::IsCallable(thenVar))
  296. {
  297. JavascriptError::ThrowTypeError(scriptContext, JSERR_NeedFunction);
  298. }
  299. RecyclableObject* thenFunc = UnsafeVarTo<RecyclableObject>(thenVar);
  300. BEGIN_SAFE_REENTRANT_CALL(threadContext)
  301. {
  302. CALL_FUNCTION(scriptContext->GetThreadContext(),
  303. thenFunc, Js::CallInfo(CallFlags_Value, 3),
  304. nextPromiseObject,
  305. promiseCapability->GetResolve(),
  306. rejectElement);
  307. }
  308. END_SAFE_REENTRANT_CALL;
  309. // s.Increase index by 1.
  310. index++;
  311. });
  312. // 7.d. If next is false, then
  313. // 7.d.i. Set iteratorRecord.[[Done]] to true.
  314. // 7.d.ii. Set remainingElementsCount.[[Value]] to remainingElementsCount.[[Value]] - 1.
  315. remainingElementsWrapper->remainingElements--;
  316. // 7.d.iii. If remainingElementsCount.[[Value]] is 0, then
  317. if (remainingElementsWrapper->remainingElements == 0)
  318. {
  319. // 7.d.iii.1 Let error be a newly created AggregateError object.
  320. JavascriptError* pError = library->CreateAggregateError();
  321. JavascriptError::SetErrorsList(pError, errors, scriptContext);
  322. JavascriptError::SetErrorMessage(pError, JSERR_PromiseAllRejected, _u(""), scriptContext);
  323. JavascriptExceptionOperators::Throw(pError, scriptContext);
  324. }
  325. }
  326. catch (const JavascriptException& err)
  327. {
  328. // 8. If result is an abrupt completion, then
  329. // a. If iteratorRecord.[[Done]] is false, set result to IteratorClose(iteratorRecord, result).
  330. // b. IfAbruptRejectPromise(result, promiseCapability).
  331. JavascriptExceptionObject* exception = err.GetAndClear();
  332. TryRejectWithExceptionObject(exception, promiseCapability->GetReject(), scriptContext);
  333. }
  334. return promiseCapability->GetPromise();
  335. }
  336. Var JavascriptPromise::EntryAnyRejectElementFunction(RecyclableObject* function, CallInfo callInfo, ...)
  337. {
  338. ScriptContext* scriptContext = function->GetScriptContext();
  339. PROBE_STACK(scriptContext, Js::Constants::MinStackDefault);
  340. ARGUMENTS(args, callInfo);
  341. Assert(!(callInfo.Flags & CallFlags_New));
  342. JavascriptLibrary* library = scriptContext->GetLibrary();
  343. Var undefinedVar = library ->GetUndefined();
  344. Var x = args.Info.Count > 1 ? args[1] : undefinedVar;
  345. // 1. Let F be the active function object.
  346. JavascriptPromiseAnyRejectElementFunction* anyRejectElementFunction = VarTo<JavascriptPromiseAnyRejectElementFunction>(function);
  347. // 2. Let alreadyCalled be F. [[AlreadyCalled]].
  348. // 3. If alreadyCalled. [[Value]] is true, return undefined.
  349. if (anyRejectElementFunction->IsAlreadyCalled())
  350. {
  351. return undefinedVar;
  352. }
  353. // 4. Set alreadyCalled.[[Value]] to true.
  354. anyRejectElementFunction->SetAlreadyCalled(true);
  355. // 5. Let index be F.[[Index]].
  356. uint32 index = anyRejectElementFunction->GetIndex();
  357. // 6. Let errors be F.[[Errors]].
  358. JavascriptArray* errors = anyRejectElementFunction->GetValues();
  359. // 7. Let promiseCapability be F.[[Capability]].
  360. JavascriptPromiseCapability* promiseCapability = anyRejectElementFunction->GetCapabilities();
  361. // 9. Set errors[index] to x.
  362. errors->DirectSetItemAt(index, x);
  363. // 8. Let remainingElementsCount be F.[[RemainingElements]].
  364. // 10. Set remainingElementsCount.[[Value]] to remainingElementsCount.[[Value]] - 1.
  365. // 11. If remainingElementsCount.[[Value]] is 0, then
  366. if (anyRejectElementFunction->DecrementRemainingElements() == 0)
  367. {
  368. // a. Let error be a newly created AggregateError object.
  369. JavascriptError* pError = library->CreateAggregateError();
  370. // b. Perform ! DefinePropertyOrThrow(error, "errors", Property Descriptor { [[Configurable]]: true, [[Enumerable]]: false, [[Writable]]: true, [[Value]]: ! CreateArrayFromList(errors) }).
  371. JavascriptError::SetErrorsList(pError, errors, scriptContext);
  372. JavascriptError::SetErrorMessage(pError, JSERR_PromiseAllRejected, _u(""), scriptContext);
  373. // c. Return ? Call(promiseCapability.[[Reject]], undefined, << error >> ).
  374. return TryCallResolveOrRejectHandler(promiseCapability->GetReject(), pError, scriptContext);
  375. }
  376. return undefinedVar;
  377. }
  378. Var JavascriptPromise::EntryAllSettled(RecyclableObject* function, CallInfo callInfo, ...)
  379. {
  380. PROBE_STACK(function->GetScriptContext(), Js::Constants::MinStackDefault);
  381. ARGUMENTS(args, callInfo);
  382. Assert(!(callInfo.Flags & CallFlags_New));
  383. ScriptContext* scriptContext = function->GetScriptContext();
  384. AUTO_TAG_NATIVE_LIBRARY_ENTRY(function, callInfo, _u("Promise.allSettled"));
  385. // 1. Let C be the this value.
  386. Var constructor = args[0];
  387. // 2. If Type(C) is not Object, throw a TypeError exception.
  388. if (!JavascriptOperators::IsObject(constructor))
  389. {
  390. JavascriptError::ThrowTypeError(scriptContext, JSERR_This_NeedObject, _u("Promise.allSettled"));
  391. }
  392. JavascriptLibrary* library = scriptContext->GetLibrary();
  393. Var iterable;
  394. if (args.Info.Count > 1)
  395. {
  396. iterable = args[1];
  397. }
  398. else
  399. {
  400. iterable = library->GetUndefined();
  401. }
  402. // 3. Let promiseCapability be NewPromiseCapability(C).
  403. JavascriptPromiseCapability* promiseCapability = NewPromiseCapability(constructor, scriptContext);
  404. // We know that constructor is an object at this point - further, we even know that it is a constructor - because NewPromiseCapability
  405. // would throw otherwise. That means we can safely cast constructor into a RecyclableObject* now and avoid having to perform ToObject
  406. // as part of the Invoke operation performed inside the loop below.
  407. RecyclableObject* constructorObject = VarTo<RecyclableObject>(constructor);
  408. uint32 index = 0;
  409. JavascriptArray* values = nullptr;
  410. // We can't use a simple counter for the remaining element count since each Promise.all Resolve Element Function needs to know how many
  411. // elements are remaining when it runs and needs to update that counter for all other functions created by this call to Promise.all.
  412. // We can't just use a static variable, either, since this element count is only used for the Promise.all Resolve Element Functions created
  413. // by this call to Promise.all.
  414. JavascriptPromiseAllResolveElementFunctionRemainingElementsWrapper* remainingElementsWrapper = RecyclerNewStructZ(scriptContext->GetRecycler(), JavascriptPromiseAllResolveElementFunctionRemainingElementsWrapper);
  415. remainingElementsWrapper->remainingElements = 1;
  416. JavascriptExceptionObject* exception = nullptr;
  417. try
  418. {
  419. // 4. Let iterator be GetIterator(iterable).
  420. RecyclableObject* iterator = JavascriptOperators::GetIterator(iterable, scriptContext);
  421. // Abstract operation PerformPromiseAllSettled
  422. Var resolveVar = JavascriptOperators::GetProperty(constructorObject, Js::PropertyIds::resolve, scriptContext);
  423. if (!JavascriptConversion::IsCallable(resolveVar))
  424. {
  425. JavascriptError::ThrowTypeError(scriptContext, JSERR_NeedFunction);
  426. }
  427. RecyclableObject* resolveFunc = VarTo<RecyclableObject>(resolveVar);
  428. values = library->CreateArray(0);
  429. JavascriptOperators::DoIteratorStepAndValue(iterator, scriptContext, [&](Var next)
  430. {
  431. ThreadContext* threadContext = scriptContext->GetThreadContext();
  432. Var nextPromise = nullptr;
  433. BEGIN_SAFE_REENTRANT_CALL(threadContext)
  434. {
  435. nextPromise = CALL_FUNCTION(threadContext,
  436. resolveFunc, Js::CallInfo(CallFlags_Value, 2),
  437. constructorObject,
  438. next);
  439. }
  440. END_SAFE_REENTRANT_CALL
  441. JavascriptPromiseResolveOrRejectFunctionAlreadyResolvedWrapper* alreadyCalledWrapper = RecyclerNewStructZ(scriptContext->GetRecycler(), JavascriptPromiseResolveOrRejectFunctionAlreadyResolvedWrapper);
  442. alreadyCalledWrapper->alreadyResolved = false;
  443. Var resolveElement = library->CreatePromiseAllSettledResolveOrRejectElementFunction(EntryAllSettledResolveOrRejectElementFunction, index, values, promiseCapability, remainingElementsWrapper, alreadyCalledWrapper, false);
  444. Var rejectElement = library->CreatePromiseAllSettledResolveOrRejectElementFunction(EntryAllSettledResolveOrRejectElementFunction, index, values, promiseCapability, remainingElementsWrapper, alreadyCalledWrapper, true);
  445. remainingElementsWrapper->remainingElements++;
  446. RecyclableObject* nextPromiseObject;
  447. if (!JavascriptConversion::ToObject(nextPromise, scriptContext, &nextPromiseObject))
  448. {
  449. JavascriptError::ThrowTypeError(scriptContext, JSERR_NeedObject);
  450. }
  451. Var thenVar = JavascriptOperators::GetProperty(nextPromiseObject, Js::PropertyIds::then, scriptContext);
  452. if (!JavascriptConversion::IsCallable(thenVar))
  453. {
  454. JavascriptError::ThrowTypeError(scriptContext, JSERR_NeedFunction);
  455. }
  456. RecyclableObject* thenFunc = VarTo<RecyclableObject>(thenVar);
  457. BEGIN_SAFE_REENTRANT_CALL(threadContext)
  458. {
  459. CALL_FUNCTION(scriptContext->GetThreadContext(),
  460. thenFunc, Js::CallInfo(CallFlags_Value, 3),
  461. nextPromiseObject,
  462. resolveElement,
  463. rejectElement);
  464. }
  465. END_SAFE_REENTRANT_CALL
  466. index++;
  467. });
  468. remainingElementsWrapper->remainingElements--;
  469. if (remainingElementsWrapper->remainingElements == 0)
  470. {
  471. Assert(values != nullptr);
  472. TryCallResolveOrRejectHandler(promiseCapability->GetResolve(), values, scriptContext);
  473. }
  474. }
  475. catch (const JavascriptException& err)
  476. {
  477. exception = err.GetAndClear();
  478. }
  479. if (exception != nullptr)
  480. {
  481. TryRejectWithExceptionObject(exception, promiseCapability->GetReject(), scriptContext);
  482. }
  483. return promiseCapability->GetPromise();
  484. }
  485. // Promise.prototype.catch as defined in ES 2015 Section 25.4.5.1
  486. Var JavascriptPromise::EntryCatch(RecyclableObject* function, CallInfo callInfo, ...)
  487. {
  488. PROBE_STACK(function->GetScriptContext(), Js::Constants::MinStackDefault);
  489. ARGUMENTS(args, callInfo);
  490. Assert(!(callInfo.Flags & CallFlags_New));
  491. ScriptContext* scriptContext = function->GetScriptContext();
  492. AUTO_TAG_NATIVE_LIBRARY_ENTRY(function, callInfo, _u("Promise.prototype.catch"));
  493. RecyclableObject* promise;
  494. if (!JavascriptConversion::ToObject(args[0], scriptContext, &promise))
  495. {
  496. JavascriptError::ThrowTypeError(scriptContext, JSERR_This_NeedObject, _u("Promise.prototype.catch"));
  497. }
  498. Var funcVar = JavascriptOperators::GetProperty(promise, Js::PropertyIds::then, scriptContext);
  499. if (!JavascriptConversion::IsCallable(funcVar))
  500. {
  501. JavascriptError::ThrowTypeError(scriptContext, JSERR_FunctionArgument_NeedFunction, _u("Promise.prototype.catch"));
  502. }
  503. Var onRejected;
  504. RecyclableObject* undefinedVar = scriptContext->GetLibrary()->GetUndefined();
  505. if (args.Info.Count > 1)
  506. {
  507. onRejected = args[1];
  508. }
  509. else
  510. {
  511. onRejected = undefinedVar;
  512. }
  513. RecyclableObject* func = VarTo<RecyclableObject>(funcVar);
  514. BEGIN_SAFE_REENTRANT_CALL(scriptContext->GetThreadContext())
  515. {
  516. return CALL_FUNCTION(scriptContext->GetThreadContext(),
  517. func, Js::CallInfo(CallFlags_Value, 3),
  518. promise,
  519. undefinedVar,
  520. onRejected);
  521. }
  522. END_SAFE_REENTRANT_CALL
  523. }
  524. // Promise.race as described in ES 2015 Section 25.4.4.3
  525. Var JavascriptPromise::EntryRace(RecyclableObject* function, CallInfo callInfo, ...)
  526. {
  527. PROBE_STACK(function->GetScriptContext(), Js::Constants::MinStackDefault);
  528. ARGUMENTS(args, callInfo);
  529. Assert(!(callInfo.Flags & CallFlags_New));
  530. ScriptContext* scriptContext = function->GetScriptContext();
  531. AUTO_TAG_NATIVE_LIBRARY_ENTRY(function, callInfo, _u("Promise.race"));
  532. // 1. Let C be the this value.
  533. Var constructor = args[0];
  534. // 2. If Type(C) is not Object, throw a TypeError exception.
  535. if (!JavascriptOperators::IsObject(constructor))
  536. {
  537. JavascriptError::ThrowTypeError(scriptContext, JSERR_This_NeedObject, _u("Promise.race"));
  538. }
  539. Var undefinedVar = scriptContext->GetLibrary()->GetUndefined();
  540. Var iterable;
  541. if (args.Info.Count > 1)
  542. {
  543. iterable = args[1];
  544. }
  545. else
  546. {
  547. iterable = undefinedVar;
  548. }
  549. // 3. Let promiseCapability be NewPromiseCapability(C).
  550. JavascriptPromiseCapability* promiseCapability = NewPromiseCapability(constructor, scriptContext);
  551. // We know that constructor is an object at this point - further, we even know that it is a constructor - because NewPromiseCapability
  552. // would throw otherwise. That means we can safely cast constructor into a RecyclableObject* now and avoid having to perform ToObject
  553. // as part of the Invoke operation performed inside the loop below.
  554. RecyclableObject* constructorObject = VarTo<RecyclableObject>(constructor);
  555. JavascriptExceptionObject* exception = nullptr;
  556. try
  557. {
  558. // 4. Let iterator be GetIterator(iterable).
  559. RecyclableObject* iterator = JavascriptOperators::GetIterator(iterable, scriptContext);
  560. Var resolveVar = JavascriptOperators::GetProperty(constructorObject, Js::PropertyIds::resolve, scriptContext);
  561. if (!JavascriptConversion::IsCallable(resolveVar))
  562. {
  563. JavascriptError::ThrowTypeError(scriptContext, JSERR_NeedFunction);
  564. }
  565. RecyclableObject* resolveFunc = VarTo<RecyclableObject>(resolveVar);
  566. JavascriptOperators::DoIteratorStepAndValue(iterator, scriptContext, [&](Var next)
  567. {
  568. ThreadContext * threadContext = scriptContext->GetThreadContext();
  569. Var nextPromise = nullptr;
  570. BEGIN_SAFE_REENTRANT_CALL(threadContext)
  571. {
  572. nextPromise = CALL_FUNCTION(threadContext,
  573. resolveFunc, Js::CallInfo(CallFlags_Value, 2),
  574. constructorObject,
  575. next);
  576. }
  577. END_SAFE_REENTRANT_CALL
  578. RecyclableObject* nextPromiseObject;
  579. if (!JavascriptConversion::ToObject(nextPromise, scriptContext, &nextPromiseObject))
  580. {
  581. JavascriptError::ThrowTypeError(scriptContext, JSERR_NeedObject);
  582. }
  583. Var thenVar = JavascriptOperators::GetProperty(nextPromiseObject, Js::PropertyIds::then, scriptContext);
  584. if (!JavascriptConversion::IsCallable(thenVar))
  585. {
  586. JavascriptError::ThrowTypeError(scriptContext, JSERR_NeedFunction);
  587. }
  588. RecyclableObject* thenFunc = VarTo<RecyclableObject>(thenVar);
  589. BEGIN_SAFE_REENTRANT_CALL(threadContext)
  590. {
  591. CALL_FUNCTION(threadContext,
  592. thenFunc, Js::CallInfo(CallFlags_Value, 3),
  593. nextPromiseObject,
  594. promiseCapability->GetResolve(),
  595. promiseCapability->GetReject());
  596. }
  597. END_SAFE_REENTRANT_CALL
  598. });
  599. }
  600. catch (const JavascriptException& err)
  601. {
  602. exception = err.GetAndClear();
  603. }
  604. if (exception != nullptr)
  605. {
  606. TryRejectWithExceptionObject(exception, promiseCapability->GetReject(), scriptContext);
  607. }
  608. return promiseCapability->GetPromise();
  609. }
  610. // Promise.reject as described in ES 2015 Section 25.4.4.4
  611. Var JavascriptPromise::EntryReject(RecyclableObject* function, CallInfo callInfo, ...)
  612. {
  613. PROBE_STACK(function->GetScriptContext(), Js::Constants::MinStackDefault);
  614. ARGUMENTS(args, callInfo);
  615. Assert(!(callInfo.Flags & CallFlags_New));
  616. ScriptContext* scriptContext = function->GetScriptContext();
  617. AUTO_TAG_NATIVE_LIBRARY_ENTRY(function, callInfo, _u("Promise.reject"));
  618. // 1. Let C be the this value.
  619. Var constructor = args[0];
  620. // 2. If Type(C) is not Object, throw a TypeError exception.
  621. if (!JavascriptOperators::IsObject(constructor))
  622. {
  623. JavascriptError::ThrowTypeError(scriptContext, JSERR_This_NeedObject, _u("Promise.reject"));
  624. }
  625. Var r;
  626. if (args.Info.Count > 1)
  627. {
  628. r = args[1];
  629. }
  630. else
  631. {
  632. r = scriptContext->GetLibrary()->GetUndefined();
  633. }
  634. // 3. Let promiseCapability be NewPromiseCapability(C).
  635. // 4. Perform ? Call(promiseCapability.[[Reject]], undefined, << r >>).
  636. // 5. Return promiseCapability.[[Promise]].
  637. return CreateRejectedPromise(r, scriptContext, constructor);
  638. }
  639. // Promise.resolve as described in ES 2015 Section 25.4.4.5
  640. Var JavascriptPromise::EntryResolve(RecyclableObject* function, CallInfo callInfo, ...)
  641. {
  642. PROBE_STACK(function->GetScriptContext(), Js::Constants::MinStackDefault);
  643. ARGUMENTS(args, callInfo);
  644. Assert(!(callInfo.Flags & CallFlags_New));
  645. ScriptContext* scriptContext = function->GetScriptContext();
  646. AUTO_TAG_NATIVE_LIBRARY_ENTRY(function, callInfo, _u("Promise.resolve"));
  647. Var x;
  648. // 1. Let C be the this value.
  649. Var constructor = args[0];
  650. // 2. If Type(C) is not Object, throw a TypeError exception.
  651. if (!JavascriptOperators::IsObject(constructor))
  652. {
  653. JavascriptError::ThrowTypeError(scriptContext, JSERR_This_NeedObject, _u("Promise.resolve"));
  654. }
  655. if (args.Info.Count > 1)
  656. {
  657. x = args[1];
  658. }
  659. else
  660. {
  661. x = scriptContext->GetLibrary()->GetUndefined();
  662. }
  663. return PromiseResolve(constructor, x, scriptContext);
  664. }
  665. JavascriptPromise* JavascriptPromise::InternalPromiseResolve(Var value, ScriptContext* scriptContext)
  666. {
  667. Var constructor = scriptContext->GetLibrary()->GetPromiseConstructor();
  668. Var promise = PromiseResolve(constructor, value, scriptContext);
  669. return UnsafeVarTo<JavascriptPromise>(promise);
  670. }
  671. Var JavascriptPromise::PromiseResolve(Var constructor, Var value, ScriptContext* scriptContext)
  672. {
  673. if (VarIs<JavascriptPromise>(value))
  674. {
  675. Var valueConstructor = JavascriptOperators::GetProperty(
  676. (RecyclableObject*)value,
  677. PropertyIds::constructor,
  678. scriptContext);
  679. // If `value` is a Promise or Promise subclass instance and its "constructor"
  680. // property is `constructor`, then return the value unchanged
  681. if (JavascriptConversion::SameValue(valueConstructor, constructor))
  682. {
  683. return value;
  684. }
  685. }
  686. return CreateResolvedPromise(value, scriptContext, constructor);
  687. }
  688. // Promise.prototype.then as described in ES 2015 Section 25.4.5.3
  689. Var JavascriptPromise::EntryThen(RecyclableObject* function, CallInfo callInfo, ...)
  690. {
  691. PROBE_STACK(function->GetScriptContext(), Js::Constants::MinStackDefault);
  692. ARGUMENTS(args, callInfo);
  693. Assert(!(callInfo.Flags & CallFlags_New));
  694. ScriptContext* scriptContext = function->GetScriptContext();
  695. AUTO_TAG_NATIVE_LIBRARY_ENTRY(function, callInfo, _u("Promise.prototype.then"));
  696. if (args.Info.Count < 1 || !VarIs<JavascriptPromise>(args[0]))
  697. {
  698. JavascriptError::ThrowTypeError(scriptContext, JSERR_This_NeedPromise, _u("Promise.prototype.then"));
  699. }
  700. JavascriptLibrary* library = scriptContext->GetLibrary();
  701. JavascriptPromise* promise = VarTo<JavascriptPromise>(args[0]);
  702. RecyclableObject* rejectionHandler;
  703. RecyclableObject* fulfillmentHandler;
  704. if (args.Info.Count > 1 && JavascriptConversion::IsCallable(args[1]))
  705. {
  706. fulfillmentHandler = VarTo<RecyclableObject>(args[1]);
  707. }
  708. else
  709. {
  710. fulfillmentHandler = library->GetIdentityFunction();
  711. }
  712. if (args.Info.Count > 2 && JavascriptConversion::IsCallable(args[2]))
  713. {
  714. rejectionHandler = VarTo<RecyclableObject>(args[2]);
  715. }
  716. else
  717. {
  718. rejectionHandler = library->GetThrowerFunction();
  719. }
  720. return CreateThenPromise(promise, fulfillmentHandler, rejectionHandler, scriptContext);
  721. }
  722. // Promise.prototype.finally as described in the draft ES 2018 #sec-promise.prototype.finally
  723. Var JavascriptPromise::EntryFinally(RecyclableObject* function, CallInfo callInfo, ...)
  724. {
  725. PROBE_STACK(function->GetScriptContext(), Js::Constants::MinStackDefault);
  726. ARGUMENTS(args, callInfo);
  727. Assert(!(callInfo.Flags & CallFlags_New));
  728. ScriptContext* scriptContext = function->GetScriptContext();
  729. AUTO_TAG_NATIVE_LIBRARY_ENTRY(function, callInfo, _u("Promise.prototype.finally"));
  730. // 1. Let promise be the this value
  731. // 2. If Type(promise) is not Object, throw a TypeError exception
  732. if (args.Info.Count < 1 || !JavascriptOperators::IsObject(args[0]))
  733. {
  734. JavascriptError::ThrowTypeError(scriptContext, JSERR_This_NeedObject, _u("Promise.prototype.finally"));
  735. }
  736. JavascriptLibrary* library = scriptContext->GetLibrary();
  737. RecyclableObject* promise = UnsafeVarTo<RecyclableObject>(args[0]);
  738. // 3. Let C be ? SpeciesConstructor(promise, %Promise%).
  739. RecyclableObject* constructor = JavascriptOperators::SpeciesConstructor(promise, scriptContext->GetLibrary()->GetPromiseConstructor(), scriptContext);
  740. // 4. Assert IsConstructor(C)
  741. Assert(JavascriptOperators::IsConstructor(constructor));
  742. // 5. If IsCallable(onFinally) is false
  743. // a. Let thenFinally be onFinally
  744. // b. Let catchFinally be onFinally
  745. // 6. Else,
  746. // a. Let thenFinally be a new built-in function object as defined in ThenFinally Function.
  747. // b. Let catchFinally be a new built-in function object as defined in CatchFinally Function.
  748. // c. Set thenFinally and catchFinally's [[Constructor]] internal slots to C.
  749. // d. Set thenFinally and catchFinally's [[OnFinally]] internal slots to onFinally.
  750. Var thenFinally = nullptr;
  751. Var catchFinally = nullptr;
  752. if (args.Info.Count > 1)
  753. {
  754. if (JavascriptConversion::IsCallable(args[1]))
  755. {
  756. //note to avoid duplicating code the ThenFinallyFunction works as both thenFinally and catchFinally using a flag
  757. thenFinally = library->CreatePromiseThenFinallyFunction(EntryThenFinallyFunction, VarTo<RecyclableObject>(args[1]), constructor, false);
  758. catchFinally = library->CreatePromiseThenFinallyFunction(EntryThenFinallyFunction, VarTo<RecyclableObject>(args[1]), constructor, true);
  759. }
  760. else
  761. {
  762. thenFinally = args[1];
  763. catchFinally = args[1];
  764. }
  765. }
  766. else
  767. {
  768. thenFinally = library->GetUndefined();
  769. catchFinally = library->GetUndefined();
  770. }
  771. Assert(thenFinally != nullptr && catchFinally != nullptr);
  772. // 7. Return ? Invoke(promise, "then", << thenFinally, catchFinally >>).
  773. Var funcVar = JavascriptOperators::GetProperty(promise, Js::PropertyIds::then, scriptContext);
  774. if (!JavascriptConversion::IsCallable(funcVar))
  775. {
  776. JavascriptError::ThrowTypeError(scriptContext, JSERR_FunctionArgument_NeedFunction, _u("Promise.prototype.finally"));
  777. }
  778. RecyclableObject* func = UnsafeVarTo<RecyclableObject>(funcVar);
  779. BEGIN_SAFE_REENTRANT_CALL(scriptContext->GetThreadContext())
  780. {
  781. return CALL_FUNCTION(scriptContext->GetThreadContext(),
  782. func, Js::CallInfo(CallFlags_Value, 3),
  783. promise,
  784. thenFinally,
  785. catchFinally);
  786. }
  787. END_SAFE_REENTRANT_CALL
  788. }
  789. // ThenFinallyFunction as described in draft ES2018 #sec-thenfinallyfunctions
  790. // AND CatchFinallyFunction as described in draft ES2018 #sec-catchfinallyfunctions
  791. Var JavascriptPromise::EntryThenFinallyFunction(RecyclableObject* function, CallInfo callInfo, ...)
  792. {
  793. PROBE_STACK(function->GetScriptContext(), Js::Constants::MinStackDefault);
  794. ARGUMENTS(args, callInfo);
  795. Assert(!(callInfo.Flags & CallFlags_New));
  796. ScriptContext* scriptContext = function->GetScriptContext();
  797. JavascriptLibrary* library = scriptContext->GetLibrary();
  798. JavascriptPromiseThenFinallyFunction* thenFinallyFunction = VarTo<JavascriptPromiseThenFinallyFunction>(function);
  799. // 1. Let onFinally be F.[[OnFinally]]
  800. // 2. Assert: IsCallable(onFinally)=true
  801. Assert(JavascriptConversion::IsCallable(thenFinallyFunction->GetOnFinally()));
  802. // 3. Let result be ? Call(onFinally, undefined)
  803. Var result = nullptr;
  804. BEGIN_SAFE_REENTRANT_CALL(scriptContext->GetThreadContext())
  805. {
  806. result = CALL_FUNCTION(scriptContext->GetThreadContext(), thenFinallyFunction->GetOnFinally(), CallInfo(CallFlags_Value, 1), library->GetUndefined());
  807. }
  808. END_SAFE_REENTRANT_CALL
  809. Assert(result);
  810. // 4. Let C be F.[[Constructor]]
  811. // 5. Assert IsConstructor(C)
  812. Assert(JavascriptOperators::IsConstructor(thenFinallyFunction->GetConstructor()));
  813. // 6. Let promise be ? PromiseResolve(c, result)
  814. Var promiseVar = CreateResolvedPromise(result, scriptContext, thenFinallyFunction->GetConstructor());
  815. // 7. Let valueThunk be equivalent to a function that returns value
  816. // OR 7. Let thrower be equivalent to a function that throws reason
  817. Var valueOrReason = nullptr;
  818. if (args.Info.Count > 1)
  819. {
  820. valueOrReason = args[1];
  821. }
  822. else
  823. {
  824. valueOrReason = scriptContext->GetLibrary()->GetUndefined();
  825. }
  826. JavascriptPromiseThunkFinallyFunction* thunkFinallyFunction = library->CreatePromiseThunkFinallyFunction(EntryThunkFinallyFunction, valueOrReason, thenFinallyFunction->GetShouldThrow());
  827. // 8. Return ? Invoke(promise, "then", <<valueThunk>>)
  828. RecyclableObject* promise = JavascriptOperators::ToObject(promiseVar, scriptContext);
  829. Var funcVar = JavascriptOperators::GetProperty(promise, Js::PropertyIds::then, scriptContext);
  830. if (!JavascriptConversion::IsCallable(funcVar))
  831. {
  832. JavascriptError::ThrowTypeError(scriptContext, JSERR_FunctionArgument_NeedFunction, _u("Promise.prototype.finally"));
  833. }
  834. RecyclableObject* func = VarTo<RecyclableObject>(funcVar);
  835. BEGIN_SAFE_REENTRANT_CALL(scriptContext->GetThreadContext())
  836. {
  837. return CALL_FUNCTION(scriptContext->GetThreadContext(),
  838. func, Js::CallInfo(CallFlags_Value, 2),
  839. promiseVar,
  840. thunkFinallyFunction);
  841. }
  842. END_SAFE_REENTRANT_CALL
  843. }
  844. // valueThunk Function as referenced within draft ES2018 #sec-thenfinallyfunctions
  845. // and thrower as referenced within draft ES2018 #sec-catchfinallyfunctions
  846. Var JavascriptPromise::EntryThunkFinallyFunction(RecyclableObject* function, CallInfo callInfo, ...)
  847. {
  848. PROBE_STACK(function->GetScriptContext(), Js::Constants::MinStackDefault);
  849. ARGUMENTS(args, callInfo);
  850. Assert(!(callInfo.Flags & CallFlags_New));
  851. JavascriptPromiseThunkFinallyFunction* thunkFinallyFunction = VarTo<JavascriptPromiseThunkFinallyFunction>(function);
  852. if (!thunkFinallyFunction->GetShouldThrow())
  853. {
  854. return thunkFinallyFunction->GetValue();
  855. }
  856. else
  857. {
  858. JavascriptExceptionOperators::Throw(thunkFinallyFunction->GetValue(), function->GetScriptContext());
  859. }
  860. }
  861. // Promise Reject and Resolve Functions as described in ES 2015 Section 25.4.1.4.1 and 25.4.1.4.2
  862. Var JavascriptPromise::EntryResolveOrRejectFunction(RecyclableObject* function, CallInfo callInfo, ...)
  863. {
  864. PROBE_STACK(function->GetScriptContext(), Js::Constants::MinStackDefault);
  865. ARGUMENTS(args, callInfo);
  866. Assert(!(callInfo.Flags & CallFlags_New));
  867. ScriptContext* scriptContext = function->GetScriptContext();
  868. JavascriptLibrary* library = scriptContext->GetLibrary();
  869. Var undefinedVar = library->GetUndefined();
  870. Var resolution;
  871. if (args.Info.Count > 1)
  872. {
  873. resolution = args[1];
  874. }
  875. else
  876. {
  877. resolution = undefinedVar;
  878. }
  879. JavascriptPromiseResolveOrRejectFunction* resolveOrRejectFunction = VarTo<JavascriptPromiseResolveOrRejectFunction>(function);
  880. if (resolveOrRejectFunction->IsAlreadyResolved())
  881. {
  882. return undefinedVar;
  883. }
  884. resolveOrRejectFunction->SetAlreadyResolved(true);
  885. bool rejecting = resolveOrRejectFunction->IsRejectFunction();
  886. JavascriptPromise* promise = resolveOrRejectFunction->GetPromise();
  887. return promise->ResolveHelper(resolution, rejecting, scriptContext);
  888. }
  889. Var JavascriptPromise::Resolve(Var resolution, ScriptContext* scriptContext)
  890. {
  891. return this->ResolveHelper(resolution, false, scriptContext);
  892. }
  893. Var JavascriptPromise::Reject(Var resolution, ScriptContext* scriptContext)
  894. {
  895. return this->ResolveHelper(resolution, true, scriptContext);
  896. }
  897. Var JavascriptPromise::ResolveHelper(Var resolution, bool isRejecting, ScriptContext* scriptContext)
  898. {
  899. JavascriptLibrary* library = scriptContext->GetLibrary();
  900. Var undefinedVar = library->GetUndefined();
  901. // We only need to check SameValue and check for thenable resolution in the Resolve function case (not Reject)
  902. if (!isRejecting)
  903. {
  904. if (JavascriptConversion::SameValue(resolution, this))
  905. {
  906. JavascriptError* selfResolutionError = scriptContext->GetLibrary()->CreateTypeError();
  907. JavascriptError::SetErrorMessage(selfResolutionError, JSERR_PromiseSelfResolution, _u(""), scriptContext);
  908. resolution = selfResolutionError;
  909. isRejecting = true;
  910. }
  911. else if (VarIs<RecyclableObject>(resolution))
  912. {
  913. try
  914. {
  915. RecyclableObject* thenable = VarTo<RecyclableObject>(resolution);
  916. Var then = JavascriptOperators::GetPropertyNoCache(thenable, Js::PropertyIds::then, scriptContext);
  917. if (JavascriptConversion::IsCallable(then))
  918. {
  919. JavascriptPromiseResolveThenableTaskFunction* resolveThenableTaskFunction = library->CreatePromiseResolveThenableTaskFunction(EntryResolveThenableTaskFunction, this, thenable, VarTo<RecyclableObject>(then));
  920. library->EnqueueTask(resolveThenableTaskFunction);
  921. return undefinedVar;
  922. }
  923. }
  924. catch (const JavascriptException& err)
  925. {
  926. resolution = err.GetAndClear()->GetThrownObject(scriptContext);
  927. if (resolution == nullptr)
  928. {
  929. resolution = undefinedVar;
  930. }
  931. isRejecting = true;
  932. }
  933. }
  934. }
  935. PromiseStatus newStatus;
  936. // Need to check rejecting state again as it might have changed due to failures
  937. if (isRejecting)
  938. {
  939. newStatus = PromiseStatusCode_HasRejection;
  940. if (!GetIsHandled())
  941. {
  942. scriptContext->GetLibrary()->CallNativeHostPromiseRejectionTracker(this, resolution, false);
  943. }
  944. }
  945. else
  946. {
  947. newStatus = PromiseStatusCode_HasResolution;
  948. }
  949. Assert(resolution != nullptr);
  950. // SList only supports "prepend" operation, so we need to reverse the list
  951. // before triggering reactions
  952. JavascriptPromiseReactionList* reactions = this->GetReactions();
  953. if (reactions != nullptr)
  954. {
  955. reactions->Reverse();
  956. }
  957. this->result = resolution;
  958. this->reactions = nullptr;
  959. this->SetStatus(newStatus);
  960. return TriggerPromiseReactions(reactions, isRejecting, resolution, scriptContext);
  961. }
  962. // Promise Capabilities Executor Function as described in ES 2015 Section 25.4.1.6.2
  963. Var JavascriptPromise::EntryCapabilitiesExecutorFunction(RecyclableObject* function, CallInfo callInfo, ...)
  964. {
  965. PROBE_STACK(function->GetScriptContext(), Js::Constants::MinStackDefault);
  966. ARGUMENTS(args, callInfo);
  967. Assert(!(callInfo.Flags & CallFlags_New));
  968. ScriptContext* scriptContext = function->GetScriptContext();
  969. Var undefinedVar = scriptContext->GetLibrary()->GetUndefined();
  970. Var resolve = undefinedVar;
  971. Var reject = undefinedVar;
  972. if (args.Info.Count > 1)
  973. {
  974. resolve = args[1];
  975. if (args.Info.Count > 2)
  976. {
  977. reject = args[2];
  978. }
  979. }
  980. JavascriptPromiseCapabilitiesExecutorFunction* capabilitiesExecutorFunction = VarTo<JavascriptPromiseCapabilitiesExecutorFunction>(function);
  981. JavascriptPromiseCapability* promiseCapability = capabilitiesExecutorFunction->GetCapability();
  982. if (!JavascriptOperators::IsUndefined(promiseCapability->GetResolve()) || !JavascriptOperators::IsUndefined(promiseCapability->GetReject()))
  983. {
  984. JavascriptError::ThrowTypeErrorVar(scriptContext, JSERR_UnexpectedMetadataFailure, _u("Promise"));
  985. }
  986. promiseCapability->SetResolve(resolve);
  987. promiseCapability->SetReject(reject);
  988. return undefinedVar;
  989. }
  990. // Promise Reaction Task Function as described in ES 2015 Section 25.4.2.1
  991. Var JavascriptPromise::EntryReactionTaskFunction(RecyclableObject* function, CallInfo callInfo, ...)
  992. {
  993. PROBE_STACK(function->GetScriptContext(), Js::Constants::MinStackDefault);
  994. ARGUMENTS(args, callInfo);
  995. Assert(!(callInfo.Flags & CallFlags_New));
  996. ScriptContext* scriptContext = function->GetScriptContext();
  997. Var undefinedVar = scriptContext->GetLibrary()->GetUndefined();
  998. JavascriptPromiseReactionTaskFunction* reactionTaskFunction = VarTo<JavascriptPromiseReactionTaskFunction>(function);
  999. JavascriptPromiseReaction* reaction = reactionTaskFunction->GetReaction();
  1000. Var argument = reactionTaskFunction->GetArgument();
  1001. JavascriptPromiseCapability* promiseCapability = reaction->GetCapabilities();
  1002. RecyclableObject* handler = reaction->GetHandler();
  1003. Var handlerResult = nullptr;
  1004. JavascriptExceptionObject* exception = nullptr;
  1005. {
  1006. bool isPromiseRejectionHandled = true;
  1007. if (scriptContext->IsScriptContextInDebugMode())
  1008. {
  1009. // only necessary to determine if false if debugger is attached. This way we'll
  1010. // correctly break on exceptions raised in promises that result in uhandled rejection
  1011. // notifications
  1012. Var promiseVar = promiseCapability->GetPromise();
  1013. if (VarIs<JavascriptPromise>(promiseVar))
  1014. {
  1015. JavascriptPromise* promise = VarTo<JavascriptPromise>(promiseVar);
  1016. isPromiseRejectionHandled = !promise->WillRejectionBeUnhandled();
  1017. }
  1018. }
  1019. Js::JavascriptExceptionOperators::AutoCatchHandlerExists autoCatchHandlerExists(scriptContext, isPromiseRejectionHandled);
  1020. try
  1021. {
  1022. BEGIN_SAFE_REENTRANT_CALL(scriptContext->GetThreadContext())
  1023. {
  1024. handlerResult = CALL_FUNCTION(scriptContext->GetThreadContext(),
  1025. handler, Js::CallInfo(Js::CallFlags::CallFlags_Value, 2),
  1026. undefinedVar,
  1027. argument);
  1028. }
  1029. END_SAFE_REENTRANT_CALL
  1030. }
  1031. catch (const JavascriptException& err)
  1032. {
  1033. exception = err.GetAndClear();
  1034. }
  1035. }
  1036. if (exception != nullptr)
  1037. {
  1038. return TryRejectWithExceptionObject(exception, promiseCapability->GetReject(), scriptContext);
  1039. }
  1040. Assert(handlerResult != nullptr);
  1041. return TryCallResolveOrRejectHandler(promiseCapability->GetResolve(), handlerResult, scriptContext);
  1042. }
  1043. /**
  1044. * Determine if at the current point in time, the given promise has a path of reactions that result
  1045. * in an unhandled rejection. This doesn't account for potential of a rejection handler added later
  1046. * in time.
  1047. */
  1048. bool JavascriptPromise::WillRejectionBeUnhandled()
  1049. {
  1050. bool willBeUnhandled = !this->GetIsHandled();
  1051. if (!willBeUnhandled)
  1052. {
  1053. // if this promise is handled, then we need to do a depth-first search over this promise's reject
  1054. // reactions. If we find a reaction that
  1055. // - associated promise is "unhandled" (ie, it's never been "then'd")
  1056. // - AND its rejection handler is our default "thrower function"
  1057. // then this promise results in an unhandled rejection path.
  1058. JsUtil::Stack<JavascriptPromise*, HeapAllocator> stack(&HeapAllocator::Instance);
  1059. SimpleHashTable<JavascriptPromise*, int, HeapAllocator> visited(&HeapAllocator::Instance);
  1060. stack.Push(this);
  1061. visited.Add(this, 1);
  1062. while (!willBeUnhandled && !stack.Empty())
  1063. {
  1064. JavascriptPromise * curr = stack.Pop();
  1065. {
  1066. JavascriptPromiseReactionList* reactions = curr->GetReactions();
  1067. JavascriptPromiseReactionList::Iterator it = reactions->GetIterator();
  1068. while (it.Next())
  1069. {
  1070. JavascriptPromiseReactionPair pair = it.Data();
  1071. JavascriptPromiseReaction* reaction = pair.rejectReaction;
  1072. Var promiseVar = reaction->GetCapabilities()->GetPromise();
  1073. if (VarIs<JavascriptPromise>(promiseVar))
  1074. {
  1075. JavascriptPromise* p = VarTo<JavascriptPromise>(promiseVar);
  1076. if (!p->GetIsHandled())
  1077. {
  1078. RecyclableObject* handler = reaction->GetHandler();
  1079. if (VarIs<JavascriptFunction>(handler))
  1080. {
  1081. JavascriptFunction* func = VarTo<JavascriptFunction>(handler);
  1082. FunctionInfo* functionInfo = func->GetFunctionInfo();
  1083. #ifdef DEBUG
  1084. if (!func->IsCrossSiteObject())
  1085. {
  1086. // assert that Thrower function's FunctionInfo hasn't changed
  1087. AssertMsg(func->GetScriptContext()->GetLibrary()->GetThrowerFunction()->GetFunctionInfo() == &JavascriptPromise::EntryInfo::Thrower, "unexpected FunctionInfo for thrower function!");
  1088. }
  1089. #endif
  1090. // If the function info is the default thrower function's function info, then assume that this is unhandled
  1091. // this will work across script contexts
  1092. if (functionInfo == &JavascriptPromise::EntryInfo::Thrower)
  1093. {
  1094. willBeUnhandled = true;
  1095. break;
  1096. }
  1097. }
  1098. }
  1099. AssertMsg(visited.HasEntry(p) == false, "Unexpected cycle in promise reaction tree!");
  1100. if (!visited.HasEntry(p))
  1101. {
  1102. stack.Push(p);
  1103. visited.Add(p, 1);
  1104. }
  1105. }
  1106. }
  1107. }
  1108. }
  1109. }
  1110. return willBeUnhandled;
  1111. }
  1112. Var JavascriptPromise::TryCallResolveOrRejectHandler(Var handler, Var value, ScriptContext* scriptContext)
  1113. {
  1114. Var undefinedVar = scriptContext->GetLibrary()->GetUndefined();
  1115. if (!JavascriptConversion::IsCallable(handler))
  1116. {
  1117. JavascriptError::ThrowTypeError(scriptContext, JSERR_NeedFunction);
  1118. }
  1119. RecyclableObject* handlerFunc = VarTo<RecyclableObject>(handler);
  1120. BEGIN_SAFE_REENTRANT_CALL(scriptContext->GetThreadContext())
  1121. {
  1122. return CALL_FUNCTION(scriptContext->GetThreadContext(),
  1123. handlerFunc, CallInfo(CallFlags_Value, 2),
  1124. undefinedVar,
  1125. value);
  1126. }
  1127. END_SAFE_REENTRANT_CALL
  1128. }
  1129. Var JavascriptPromise::TryRejectWithExceptionObject(JavascriptExceptionObject* exceptionObject, Var handler, ScriptContext* scriptContext)
  1130. {
  1131. Var thrownObject = exceptionObject->GetThrownObject(scriptContext);
  1132. if (thrownObject == nullptr)
  1133. {
  1134. thrownObject = scriptContext->GetLibrary()->GetUndefined();
  1135. }
  1136. return TryCallResolveOrRejectHandler(handler, thrownObject, scriptContext);
  1137. }
  1138. Var JavascriptPromise::CreateRejectedPromise(Var resolution, ScriptContext* scriptContext, Var promiseConstructor)
  1139. {
  1140. if (promiseConstructor == nullptr)
  1141. {
  1142. promiseConstructor = scriptContext->GetLibrary()->GetPromiseConstructor();
  1143. }
  1144. JavascriptPromiseCapability* promiseCapability = NewPromiseCapability(promiseConstructor, scriptContext);
  1145. TryCallResolveOrRejectHandler(promiseCapability->GetReject(), resolution, scriptContext);
  1146. return promiseCapability->GetPromise();
  1147. }
  1148. Var JavascriptPromise::CreateResolvedPromise(Var resolution, ScriptContext* scriptContext, Var promiseConstructor)
  1149. {
  1150. if (promiseConstructor == nullptr)
  1151. {
  1152. promiseConstructor = scriptContext->GetLibrary()->GetPromiseConstructor();
  1153. }
  1154. JavascriptPromiseCapability* promiseCapability = NewPromiseCapability(promiseConstructor, scriptContext);
  1155. TryCallResolveOrRejectHandler(promiseCapability->GetResolve(), resolution, scriptContext);
  1156. return promiseCapability->GetPromise();
  1157. }
  1158. Var JavascriptPromise::CreatePassThroughPromise(JavascriptPromise* sourcePromise, ScriptContext* scriptContext)
  1159. {
  1160. JavascriptLibrary* library = scriptContext->GetLibrary();
  1161. return CreateThenPromise(sourcePromise, library->GetIdentityFunction(), library->GetThrowerFunction(), scriptContext);
  1162. }
  1163. Var JavascriptPromise::CreateThenPromise(JavascriptPromise* sourcePromise, RecyclableObject* fulfillmentHandler, RecyclableObject* rejectionHandler, ScriptContext* scriptContext)
  1164. {
  1165. JavascriptFunction* defaultConstructor = scriptContext->GetLibrary()->GetPromiseConstructor();
  1166. RecyclableObject* constructor = JavascriptOperators::SpeciesConstructor(sourcePromise, defaultConstructor, scriptContext);
  1167. AssertOrFailFast(JavascriptOperators::IsConstructor(constructor));
  1168. bool isDefaultConstructor = constructor == defaultConstructor;
  1169. JavascriptPromiseCapability* promiseCapability = (JavascriptPromiseCapability*)JavascriptOperators::NewObjectCreationHelper_ReentrancySafe(constructor, isDefaultConstructor, scriptContext->GetThreadContext(), [=]()->JavascriptPromiseCapability*
  1170. {
  1171. return NewPromiseCapability(constructor, scriptContext);
  1172. });
  1173. PerformPromiseThen(sourcePromise, promiseCapability, fulfillmentHandler, rejectionHandler, scriptContext);
  1174. return promiseCapability->GetPromise();
  1175. }
  1176. void JavascriptPromise::PerformPromiseThen(
  1177. JavascriptPromise* sourcePromise,
  1178. JavascriptPromiseCapability* capability,
  1179. RecyclableObject* fulfillmentHandler,
  1180. RecyclableObject* rejectionHandler,
  1181. ScriptContext* scriptContext)
  1182. {
  1183. auto* resolveReaction = JavascriptPromiseReaction::New(capability, fulfillmentHandler, scriptContext);
  1184. auto* rejectReaction = JavascriptPromiseReaction::New(capability, rejectionHandler, scriptContext);
  1185. switch (sourcePromise->GetStatus())
  1186. {
  1187. case PromiseStatusCode_Unresolved:
  1188. JavascriptPromiseReactionPair pair;
  1189. pair.resolveReaction = resolveReaction;
  1190. pair.rejectReaction = rejectReaction;
  1191. sourcePromise->reactions->Prepend(pair);
  1192. break;
  1193. case PromiseStatusCode_HasResolution:
  1194. EnqueuePromiseReactionTask(
  1195. resolveReaction,
  1196. CrossSite::MarshalVar(scriptContext, sourcePromise->result),
  1197. scriptContext);
  1198. break;
  1199. case PromiseStatusCode_HasRejection:
  1200. {
  1201. if (!sourcePromise->GetIsHandled())
  1202. {
  1203. scriptContext->GetLibrary()->CallNativeHostPromiseRejectionTracker(
  1204. sourcePromise,
  1205. CrossSite::MarshalVar(scriptContext, sourcePromise->result),
  1206. true);
  1207. }
  1208. EnqueuePromiseReactionTask(
  1209. rejectReaction,
  1210. CrossSite::MarshalVar(scriptContext, sourcePromise->result),
  1211. scriptContext);
  1212. break;
  1213. }
  1214. default:
  1215. AssertMsg(false, "Promise status is in an invalid state");
  1216. break;
  1217. }
  1218. sourcePromise->SetIsHandled();
  1219. }
  1220. // Promise Resolve Thenable Job as described in ES 2015 Section 25.4.2.2
  1221. Var JavascriptPromise::EntryResolveThenableTaskFunction(RecyclableObject* function, CallInfo callInfo, ...)
  1222. {
  1223. PROBE_STACK(function->GetScriptContext(), Js::Constants::MinStackDefault);
  1224. ARGUMENTS(args, callInfo);
  1225. Assert(!(callInfo.Flags & CallFlags_New));
  1226. ScriptContext* scriptContext = function->GetScriptContext();
  1227. JavascriptLibrary* library = scriptContext->GetLibrary();
  1228. JavascriptPromiseResolveThenableTaskFunction* resolveThenableTaskFunction = VarTo<JavascriptPromiseResolveThenableTaskFunction>(function);
  1229. JavascriptPromise* promise = resolveThenableTaskFunction->GetPromise();
  1230. RecyclableObject* thenable = resolveThenableTaskFunction->GetThenable();
  1231. RecyclableObject* thenFunction = resolveThenableTaskFunction->GetThenFunction();
  1232. JavascriptPromiseResolveOrRejectFunctionAlreadyResolvedWrapper* alreadyResolvedRecord = RecyclerNewStructZ(scriptContext->GetRecycler(), JavascriptPromiseResolveOrRejectFunctionAlreadyResolvedWrapper);
  1233. alreadyResolvedRecord->alreadyResolved = false;
  1234. JavascriptPromiseResolveOrRejectFunction* resolve = library->CreatePromiseResolveOrRejectFunction(EntryResolveOrRejectFunction, promise, false, alreadyResolvedRecord);
  1235. JavascriptPromiseResolveOrRejectFunction* reject = library->CreatePromiseResolveOrRejectFunction(EntryResolveOrRejectFunction, promise, true, alreadyResolvedRecord);
  1236. JavascriptExceptionObject* exception = nullptr;
  1237. {
  1238. bool isPromiseRejectionHandled = true;
  1239. if (scriptContext->IsScriptContextInDebugMode())
  1240. {
  1241. // only necessary to determine if false if debugger is attached. This way we'll
  1242. // correctly break on exceptions raised in promises that result in uhandled rejections
  1243. isPromiseRejectionHandled = !promise->WillRejectionBeUnhandled();
  1244. }
  1245. Js::JavascriptExceptionOperators::AutoCatchHandlerExists autoCatchHandlerExists(scriptContext, isPromiseRejectionHandled);
  1246. try
  1247. {
  1248. BEGIN_SAFE_REENTRANT_CALL(scriptContext->GetThreadContext())
  1249. {
  1250. return CALL_FUNCTION(scriptContext->GetThreadContext(),
  1251. thenFunction, Js::CallInfo(Js::CallFlags::CallFlags_Value, 3),
  1252. thenable,
  1253. resolve,
  1254. reject);
  1255. }
  1256. END_SAFE_REENTRANT_CALL
  1257. }
  1258. catch (const JavascriptException& err)
  1259. {
  1260. exception = err.GetAndClear();
  1261. }
  1262. }
  1263. Assert(exception != nullptr);
  1264. return TryRejectWithExceptionObject(exception, reject, scriptContext);
  1265. }
  1266. // Promise Identity Function as described in ES 2015Section 25.4.5.3.1
  1267. Var JavascriptPromise::EntryIdentityFunction(RecyclableObject* function, CallInfo callInfo, ...)
  1268. {
  1269. PROBE_STACK(function->GetScriptContext(), Js::Constants::MinStackDefault);
  1270. ARGUMENTS(args, callInfo);
  1271. Assert(!(callInfo.Flags & CallFlags_New));
  1272. if (args.Info.Count > 1)
  1273. {
  1274. Assert(args[1] != nullptr);
  1275. return args[1];
  1276. }
  1277. else
  1278. {
  1279. return function->GetScriptContext()->GetLibrary()->GetUndefined();
  1280. }
  1281. }
  1282. // Promise Thrower Function as described in ES 2015Section 25.4.5.3.3
  1283. Var JavascriptPromise::EntryThrowerFunction(RecyclableObject* function, CallInfo callInfo, ...)
  1284. {
  1285. PROBE_STACK(function->GetScriptContext(), Js::Constants::MinStackDefault);
  1286. ARGUMENTS(args, callInfo);
  1287. Assert(!(callInfo.Flags & CallFlags_New));
  1288. ScriptContext* scriptContext = function->GetScriptContext();
  1289. Var arg;
  1290. if (args.Info.Count > 1)
  1291. {
  1292. Assert(args[1] != nullptr);
  1293. arg = args[1];
  1294. }
  1295. else
  1296. {
  1297. arg = scriptContext->GetLibrary()->GetUndefined();
  1298. }
  1299. JavascriptExceptionOperators::Throw(arg, scriptContext);
  1300. }
  1301. // Promise.all Resolve Element Function as described in ES6.0 (Release Candidate 3) Section 25.4.4.1.2
  1302. Var JavascriptPromise::EntryAllResolveElementFunction(RecyclableObject* function, CallInfo callInfo, ...)
  1303. {
  1304. PROBE_STACK(function->GetScriptContext(), Js::Constants::MinStackDefault);
  1305. ARGUMENTS(args, callInfo);
  1306. Assert(!(callInfo.Flags & CallFlags_New));
  1307. ScriptContext* scriptContext = function->GetScriptContext();
  1308. Var undefinedVar = scriptContext->GetLibrary()->GetUndefined();
  1309. Var x;
  1310. if (args.Info.Count > 1)
  1311. {
  1312. x = args[1];
  1313. }
  1314. else
  1315. {
  1316. x = undefinedVar;
  1317. }
  1318. JavascriptPromiseAllResolveElementFunction* allResolveElementFunction = VarTo<JavascriptPromiseAllResolveElementFunction>(function);
  1319. if (allResolveElementFunction->IsAlreadyCalled())
  1320. {
  1321. return undefinedVar;
  1322. }
  1323. allResolveElementFunction->SetAlreadyCalled(true);
  1324. uint32 index = allResolveElementFunction->GetIndex();
  1325. JavascriptArray* values = allResolveElementFunction->GetValues();
  1326. JavascriptPromiseCapability* promiseCapability = allResolveElementFunction->GetCapabilities();
  1327. JavascriptExceptionObject* exception = nullptr;
  1328. try
  1329. {
  1330. values->SetItem(index, x, PropertyOperation_None);
  1331. }
  1332. catch (const JavascriptException& err)
  1333. {
  1334. exception = err.GetAndClear();
  1335. }
  1336. if (exception != nullptr)
  1337. {
  1338. return TryRejectWithExceptionObject(exception, promiseCapability->GetReject(), scriptContext);
  1339. }
  1340. if (allResolveElementFunction->DecrementRemainingElements() == 0)
  1341. {
  1342. return TryCallResolveOrRejectHandler(promiseCapability->GetResolve(), values, scriptContext);
  1343. }
  1344. return undefinedVar;
  1345. }
  1346. Var JavascriptPromise::EntryAllSettledResolveOrRejectElementFunction(RecyclableObject* function, CallInfo callInfo, ...)
  1347. {
  1348. PROBE_STACK(function->GetScriptContext(), Js::Constants::MinStackDefault);
  1349. ARGUMENTS(args, callInfo);
  1350. Assert(!(callInfo.Flags & CallFlags_New));
  1351. ScriptContext* scriptContext = function->GetScriptContext();
  1352. Var undefinedVar = scriptContext->GetLibrary()->GetUndefined();
  1353. Var x;
  1354. if (args.Info.Count > 1)
  1355. {
  1356. x = args[1];
  1357. }
  1358. else
  1359. {
  1360. x = undefinedVar;
  1361. }
  1362. JavascriptPromiseAllSettledResolveOrRejectElementFunction* allSettledResolveElementFunction = VarTo<JavascriptPromiseAllSettledResolveOrRejectElementFunction>(function);
  1363. if (allSettledResolveElementFunction->IsAlreadyCalled())
  1364. {
  1365. return undefinedVar;
  1366. }
  1367. allSettledResolveElementFunction->SetAlreadyCalled(true);
  1368. bool isRejecting = allSettledResolveElementFunction->IsRejectFunction();
  1369. uint32 index = allSettledResolveElementFunction->GetIndex();
  1370. JavascriptArray* values = allSettledResolveElementFunction->GetValues();
  1371. JavascriptPromiseCapability* promiseCapability = allSettledResolveElementFunction->GetCapabilities();
  1372. JavascriptExceptionObject* exception = nullptr;
  1373. try
  1374. {
  1375. RecyclableObject* obj = scriptContext->GetLibrary()->CreateObject();
  1376. Var statusString = isRejecting ?
  1377. scriptContext->GetPropertyString(PropertyIds::rejected) :
  1378. scriptContext->GetPropertyString(PropertyIds::fulfilled);
  1379. JavascriptOperators::SetProperty(obj, obj, PropertyIds::status, statusString, scriptContext);
  1380. PropertyIds valuePropId = isRejecting ? PropertyIds::reason : PropertyIds::value;
  1381. JavascriptOperators::SetProperty(obj, obj, valuePropId, x, scriptContext);
  1382. values->SetItem(index, obj, PropertyOperation_None);
  1383. }
  1384. catch (const JavascriptException& err)
  1385. {
  1386. exception = err.GetAndClear();
  1387. }
  1388. if (exception != nullptr)
  1389. {
  1390. return TryRejectWithExceptionObject(exception, promiseCapability->GetReject(), scriptContext);
  1391. }
  1392. if (allSettledResolveElementFunction->DecrementRemainingElements() == 0)
  1393. {
  1394. return TryCallResolveOrRejectHandler(promiseCapability->GetResolve(), values, scriptContext);
  1395. }
  1396. return undefinedVar;
  1397. }
  1398. #if ENABLE_TTD
  1399. void JavascriptPromise::MarkVisitKindSpecificPtrs(TTD::SnapshotExtractor* extractor)
  1400. {
  1401. if(this->result != nullptr)
  1402. {
  1403. extractor->MarkVisitVar(this->result);
  1404. }
  1405. if(this->reactions != nullptr)
  1406. {
  1407. this->reactions->Map([&](JavascriptPromiseReactionPair pair) {
  1408. pair.rejectReaction->MarkVisitPtrs(extractor);
  1409. pair.resolveReaction->MarkVisitPtrs(extractor);
  1410. });
  1411. }
  1412. }
  1413. TTD::NSSnapObjects::SnapObjectType JavascriptPromise::GetSnapTag_TTD() const
  1414. {
  1415. return TTD::NSSnapObjects::SnapObjectType::SnapPromiseObject;
  1416. }
  1417. void JavascriptPromise::ExtractSnapObjectDataInto(TTD::NSSnapObjects::SnapObject* objData, TTD::SlabAllocator& alloc)
  1418. {
  1419. JsUtil::List<TTD_PTR_ID, HeapAllocator> depOnList(&HeapAllocator::Instance);
  1420. TTD::NSSnapObjects::SnapPromiseInfo* spi = alloc.SlabAllocateStruct<TTD::NSSnapObjects::SnapPromiseInfo>();
  1421. spi->Result = this->result;
  1422. //Primitive kinds always inflated first so we only need to deal with complex kinds as depends on
  1423. if(this->result != nullptr && TTD::JsSupport::IsVarComplexKind(this->result))
  1424. {
  1425. depOnList.Add(TTD_CONVERT_VAR_TO_PTR_ID(this->result));
  1426. }
  1427. spi->Status = this->GetStatus();
  1428. spi->isHandled = this->GetIsHandled();
  1429. // get count of # of reactions
  1430. spi->ResolveReactionCount = 0;
  1431. if (this->reactions != nullptr)
  1432. {
  1433. this->reactions->Map([&spi](JavascriptPromiseReactionPair pair) {
  1434. spi->ResolveReactionCount++;
  1435. });
  1436. }
  1437. spi->RejectReactionCount = spi->ResolveReactionCount;
  1438. // move resolve & reject reactions into slab
  1439. spi->ResolveReactions = nullptr;
  1440. spi->RejectReactions = nullptr;
  1441. if(spi->ResolveReactionCount != 0)
  1442. {
  1443. spi->ResolveReactions = alloc.SlabAllocateArray<TTD::NSSnapValues::SnapPromiseReactionInfo>(spi->ResolveReactionCount);
  1444. spi->RejectReactions = alloc.SlabAllocateArray<TTD::NSSnapValues::SnapPromiseReactionInfo>(spi->RejectReactionCount);
  1445. JavascriptPromiseReactionList::Iterator it = this->reactions->GetIterator();
  1446. uint32 i = 0;
  1447. while (it.Next())
  1448. {
  1449. it.Data().resolveReaction->ExtractSnapPromiseReactionInto(spi->ResolveReactions + i, depOnList, alloc);
  1450. it.Data().rejectReaction->ExtractSnapPromiseReactionInto(spi->RejectReactions + i, depOnList, alloc);
  1451. ++i;
  1452. }
  1453. }
  1454. //see what we need to do wrt dependencies
  1455. if(depOnList.Count() == 0)
  1456. {
  1457. TTD::NSSnapObjects::StdExtractSetKindSpecificInfo<TTD::NSSnapObjects::SnapPromiseInfo*, TTD::NSSnapObjects::SnapObjectType::SnapPromiseObject>(objData, spi);
  1458. }
  1459. else
  1460. {
  1461. uint32 depOnCount = depOnList.Count();
  1462. TTD_PTR_ID* depOnArray = alloc.SlabAllocateArray<TTD_PTR_ID>(depOnCount);
  1463. for(uint32 i = 0; i < depOnCount; ++i)
  1464. {
  1465. depOnArray[i] = depOnList.Item(i);
  1466. }
  1467. TTD::NSSnapObjects::StdExtractSetKindSpecificInfo<TTD::NSSnapObjects::SnapPromiseInfo*, TTD::NSSnapObjects::SnapObjectType::SnapPromiseObject>(objData, spi, alloc, depOnCount, depOnArray);
  1468. }
  1469. }
  1470. JavascriptPromise* JavascriptPromise::InitializePromise_TTD(ScriptContext* scriptContext, uint32 status, bool isHandled, Var result, SList<Js::JavascriptPromiseReaction*, HeapAllocator>& resolveReactions,SList<Js::JavascriptPromiseReaction*, HeapAllocator>& rejectReactions)
  1471. {
  1472. Recycler* recycler = scriptContext->GetRecycler();
  1473. JavascriptLibrary* library = scriptContext->GetLibrary();
  1474. JavascriptPromise* promise = library->CreatePromise();
  1475. promise->SetStatus((PromiseStatus)status);
  1476. if (isHandled)
  1477. {
  1478. promise->SetIsHandled();
  1479. }
  1480. promise->result = result;
  1481. promise->reactions = RecyclerNew(recycler, JavascriptPromiseReactionList, recycler);
  1482. SList<Js::JavascriptPromiseReaction*, HeapAllocator>::Iterator resolveIterator = resolveReactions.GetIterator();
  1483. SList<Js::JavascriptPromiseReaction*, HeapAllocator>::Iterator rejectIterator = rejectReactions.GetIterator();
  1484. bool hasResolve = resolveIterator.Next();
  1485. bool hasReject = rejectIterator.Next();
  1486. while (hasResolve && hasReject)
  1487. {
  1488. JavascriptPromiseReactionPair pair;
  1489. pair.resolveReaction = resolveIterator.Data();
  1490. pair.rejectReaction = rejectIterator.Data();
  1491. promise->reactions->Prepend(pair);
  1492. hasResolve = resolveIterator.Next();
  1493. hasReject = rejectIterator.Next();
  1494. }
  1495. AssertMsg(hasResolve == false && hasReject == false, "mismatched resolve/reject reaction counts");
  1496. promise->reactions->Reverse();
  1497. return promise;
  1498. }
  1499. #endif
  1500. // NewPromiseCapability as described in ES6.0 (draft 29) Section 25.4.1.6
  1501. JavascriptPromiseCapability* JavascriptPromise::NewPromiseCapability(Var constructor, ScriptContext* scriptContext)
  1502. {
  1503. if (!JavascriptOperators::IsConstructor(constructor))
  1504. {
  1505. JavascriptError::ThrowTypeError(scriptContext, JSERR_NeedFunction);
  1506. }
  1507. RecyclableObject* constructorFunc = VarTo<RecyclableObject>(constructor);
  1508. BEGIN_SAFE_REENTRANT_CALL(scriptContext->GetThreadContext())
  1509. {
  1510. return CreatePromiseCapabilityRecord(constructorFunc, scriptContext);
  1511. }
  1512. END_SAFE_REENTRANT_CALL
  1513. }
  1514. JavascriptPromiseCapability* JavascriptPromise::UnusedPromiseCapability(ScriptContext* scriptContext)
  1515. {
  1516. // OPTIMIZE: In async functions and async generators, await resolves the operand
  1517. // and then executes PerformPromiseThen, attaching handlers that resume the coroutine.
  1518. // The promise capability provided is unused. For these operations we should be able
  1519. // to eliminate the extra promise allocation.
  1520. return NewPromiseCapability(scriptContext->GetLibrary()->GetPromiseConstructor(), scriptContext);
  1521. }
  1522. // CreatePromiseCapabilityRecord as described in ES6.0 (draft 29) Section 25.4.1.6.1
  1523. JavascriptPromiseCapability* JavascriptPromise::CreatePromiseCapabilityRecord(RecyclableObject* constructor, ScriptContext* scriptContext)
  1524. {
  1525. JavascriptLibrary* library = scriptContext->GetLibrary();
  1526. Var undefinedVar = library->GetUndefined();
  1527. JavascriptPromiseCapability* promiseCapability = JavascriptPromiseCapability::New(undefinedVar, undefinedVar, undefinedVar, scriptContext);
  1528. JavascriptPromiseCapabilitiesExecutorFunction* executor = library->CreatePromiseCapabilitiesExecutorFunction(EntryCapabilitiesExecutorFunction, promiseCapability);
  1529. CallInfo callinfo = Js::CallInfo((Js::CallFlags)(Js::CallFlags::CallFlags_Value | Js::CallFlags::CallFlags_New), 2);
  1530. Var argVars[] = { constructor, executor };
  1531. Arguments args(callinfo, argVars);
  1532. Var promise = JavascriptFunction::CallAsConstructor(constructor, nullptr, args, scriptContext);
  1533. if (!JavascriptConversion::IsCallable(promiseCapability->GetResolve()) || !JavascriptConversion::IsCallable(promiseCapability->GetReject()))
  1534. {
  1535. JavascriptError::ThrowTypeError(scriptContext, JSERR_NeedFunction, _u("Promise"));
  1536. }
  1537. promiseCapability->SetPromise(promise);
  1538. return promiseCapability;
  1539. }
  1540. // TriggerPromiseReactions as defined in ES 2015 Section 25.4.1.7
  1541. Var JavascriptPromise::TriggerPromiseReactions(JavascriptPromiseReactionList* reactions, bool isRejecting, Var resolution, ScriptContext* scriptContext)
  1542. {
  1543. JavascriptLibrary* library = scriptContext->GetLibrary();
  1544. if (reactions != nullptr)
  1545. {
  1546. JavascriptPromiseReactionList::Iterator it = reactions->GetIterator();
  1547. while (it.Next())
  1548. {
  1549. JavascriptPromiseReaction* reaction;
  1550. if (isRejecting)
  1551. {
  1552. reaction = it.Data().rejectReaction;
  1553. }
  1554. else
  1555. {
  1556. reaction = it.Data().resolveReaction;
  1557. }
  1558. EnqueuePromiseReactionTask(reaction, resolution, scriptContext);
  1559. }
  1560. }
  1561. return library->GetUndefined();
  1562. }
  1563. void JavascriptPromise::EnqueuePromiseReactionTask(JavascriptPromiseReaction* reaction, Var resolution, ScriptContext* scriptContext)
  1564. {
  1565. Assert(resolution != nullptr);
  1566. JavascriptLibrary* library = scriptContext->GetLibrary();
  1567. JavascriptPromiseReactionTaskFunction* reactionTaskFunction = library->CreatePromiseReactionTaskFunction(EntryReactionTaskFunction, reaction, resolution);
  1568. library->EnqueueTask(reactionTaskFunction);
  1569. }
  1570. JavascriptPromiseResolveOrRejectFunction::JavascriptPromiseResolveOrRejectFunction(DynamicType* type)
  1571. : RuntimeFunction(type, &Js::JavascriptPromise::EntryInfo::ResolveOrRejectFunction), promise(nullptr), isReject(false), alreadyResolvedWrapper(nullptr)
  1572. { }
  1573. JavascriptPromiseResolveOrRejectFunction::JavascriptPromiseResolveOrRejectFunction(DynamicType* type, FunctionInfo* functionInfo, JavascriptPromise* promise, bool isReject, JavascriptPromiseResolveOrRejectFunctionAlreadyResolvedWrapper* alreadyResolvedRecord)
  1574. : RuntimeFunction(type, functionInfo), promise(promise), isReject(isReject), alreadyResolvedWrapper(alreadyResolvedRecord)
  1575. { }
  1576. template <> bool VarIsImpl<JavascriptPromiseResolveOrRejectFunction>(RecyclableObject* obj)
  1577. {
  1578. if (VarIs<JavascriptFunction>(obj))
  1579. {
  1580. return VirtualTableInfo<JavascriptPromiseResolveOrRejectFunction>::HasVirtualTable(obj)
  1581. || VirtualTableInfo<CrossSiteObject<JavascriptPromiseResolveOrRejectFunction>>::HasVirtualTable(obj);
  1582. }
  1583. return false;
  1584. }
  1585. JavascriptPromise* JavascriptPromiseResolveOrRejectFunction::GetPromise()
  1586. {
  1587. return this->promise;
  1588. }
  1589. bool JavascriptPromiseResolveOrRejectFunction::IsRejectFunction()
  1590. {
  1591. return this->isReject;
  1592. }
  1593. bool JavascriptPromiseResolveOrRejectFunction::IsAlreadyResolved()
  1594. {
  1595. Assert(this->alreadyResolvedWrapper);
  1596. return this->alreadyResolvedWrapper->alreadyResolved;
  1597. }
  1598. void JavascriptPromiseResolveOrRejectFunction::SetAlreadyResolved(bool is)
  1599. {
  1600. Assert(this->alreadyResolvedWrapper);
  1601. this->alreadyResolvedWrapper->alreadyResolved = is;
  1602. }
  1603. #if ENABLE_TTD
  1604. void JavascriptPromiseResolveOrRejectFunction::MarkVisitKindSpecificPtrs(TTD::SnapshotExtractor* extractor)
  1605. {
  1606. TTDAssert(this->promise != nullptr, "Was not expecting that!!!");
  1607. extractor->MarkVisitVar(this->promise);
  1608. }
  1609. TTD::NSSnapObjects::SnapObjectType JavascriptPromiseResolveOrRejectFunction::GetSnapTag_TTD() const
  1610. {
  1611. return TTD::NSSnapObjects::SnapObjectType::SnapPromiseResolveOrRejectFunctionObject;
  1612. }
  1613. void JavascriptPromiseResolveOrRejectFunction::ExtractSnapObjectDataInto(TTD::NSSnapObjects::SnapObject* objData, TTD::SlabAllocator& alloc)
  1614. {
  1615. TTD::NSSnapObjects::SnapPromiseResolveOrRejectFunctionInfo* sprri = alloc.SlabAllocateStruct<TTD::NSSnapObjects::SnapPromiseResolveOrRejectFunctionInfo>();
  1616. uint32 depOnCount = 1;
  1617. TTD_PTR_ID* depOnArray = alloc.SlabAllocateArray<TTD_PTR_ID>(depOnCount);
  1618. sprri->PromiseId = TTD_CONVERT_VAR_TO_PTR_ID(this->promise);
  1619. depOnArray[0] = sprri->PromiseId;
  1620. sprri->IsReject = this->isReject;
  1621. sprri->AlreadyResolvedWrapperId = TTD_CONVERT_PROMISE_INFO_TO_PTR_ID(this->alreadyResolvedWrapper);
  1622. sprri->AlreadyResolvedValue = this->alreadyResolvedWrapper->alreadyResolved;
  1623. TTD::NSSnapObjects::StdExtractSetKindSpecificInfo<TTD::NSSnapObjects::SnapPromiseResolveOrRejectFunctionInfo*, TTD::NSSnapObjects::SnapObjectType::SnapPromiseResolveOrRejectFunctionObject>(objData, sprri, alloc, depOnCount, depOnArray);
  1624. }
  1625. #endif
  1626. JavascriptPromiseCapabilitiesExecutorFunction::JavascriptPromiseCapabilitiesExecutorFunction(DynamicType* type, FunctionInfo* functionInfo, JavascriptPromiseCapability* capability)
  1627. : RuntimeFunction(type, functionInfo), capability(capability)
  1628. { }
  1629. template <> bool VarIsImpl<JavascriptPromiseCapabilitiesExecutorFunction>(RecyclableObject* obj)
  1630. {
  1631. if (VarIs<JavascriptFunction>(obj))
  1632. {
  1633. return VirtualTableInfo<JavascriptPromiseCapabilitiesExecutorFunction>::HasVirtualTable(obj)
  1634. || VirtualTableInfo<CrossSiteObject<JavascriptPromiseCapabilitiesExecutorFunction>>::HasVirtualTable(obj);
  1635. }
  1636. return false;
  1637. }
  1638. JavascriptPromiseCapability* JavascriptPromiseCapabilitiesExecutorFunction::GetCapability()
  1639. {
  1640. return this->capability;
  1641. }
  1642. #if ENABLE_TTD
  1643. void JavascriptPromiseCapabilitiesExecutorFunction::MarkVisitKindSpecificPtrs(TTD::SnapshotExtractor* extractor)
  1644. {
  1645. TTDAssert(false, "Not Implemented Yet");
  1646. }
  1647. TTD::NSSnapObjects::SnapObjectType JavascriptPromiseCapabilitiesExecutorFunction::GetSnapTag_TTD() const
  1648. {
  1649. TTDAssert(false, "Not Implemented Yet");
  1650. return TTD::NSSnapObjects::SnapObjectType::Invalid;
  1651. }
  1652. void JavascriptPromiseCapabilitiesExecutorFunction::ExtractSnapObjectDataInto(TTD::NSSnapObjects::SnapObject* objData, TTD::SlabAllocator& alloc)
  1653. {
  1654. TTDAssert(false, "Not Implemented Yet");
  1655. }
  1656. #endif
  1657. JavascriptPromiseCapability* JavascriptPromiseCapability::New(Var promise, Var resolve, Var reject, ScriptContext* scriptContext)
  1658. {
  1659. return RecyclerNew(scriptContext->GetRecycler(), JavascriptPromiseCapability, promise, resolve, reject);
  1660. }
  1661. Var JavascriptPromiseCapability::GetResolve()
  1662. {
  1663. return this->resolve;
  1664. }
  1665. Var JavascriptPromiseCapability::GetReject()
  1666. {
  1667. return this->reject;
  1668. }
  1669. Var JavascriptPromiseCapability::GetPromise()
  1670. {
  1671. return this->promise;
  1672. }
  1673. void JavascriptPromiseCapability::SetPromise(Var promise)
  1674. {
  1675. this->promise = promise;
  1676. }
  1677. void JavascriptPromiseCapability::SetResolve(Var resolve)
  1678. {
  1679. this->resolve = resolve;
  1680. }
  1681. void JavascriptPromiseCapability::SetReject(Var reject)
  1682. {
  1683. this->reject = reject;
  1684. }
  1685. #if ENABLE_TTD
  1686. void JavascriptPromiseCapability::MarkVisitPtrs(TTD::SnapshotExtractor* extractor)
  1687. {
  1688. TTDAssert(this->promise != nullptr && this->resolve != nullptr && this->reject != nullptr, "Seems odd, I was not expecting this!!!");
  1689. extractor->MarkVisitVar(this->promise);
  1690. extractor->MarkVisitVar(this->resolve);
  1691. extractor->MarkVisitVar(this->reject);
  1692. }
  1693. void JavascriptPromiseCapability::ExtractSnapPromiseCapabilityInto(TTD::NSSnapValues::SnapPromiseCapabilityInfo* snapPromiseCapability, JsUtil::List<TTD_PTR_ID, HeapAllocator>& depOnList, TTD::SlabAllocator& alloc)
  1694. {
  1695. snapPromiseCapability->CapabilityId = TTD_CONVERT_PROMISE_INFO_TO_PTR_ID(this);
  1696. snapPromiseCapability->PromiseVar = this->promise;
  1697. if(TTD::JsSupport::IsVarComplexKind(this->promise))
  1698. {
  1699. depOnList.Add(TTD_CONVERT_VAR_TO_PTR_ID(this->resolve));
  1700. }
  1701. snapPromiseCapability->ResolveVar = this->resolve;
  1702. if(TTD::JsSupport::IsVarComplexKind(this->resolve))
  1703. {
  1704. depOnList.Add(TTD_CONVERT_VAR_TO_PTR_ID(this->resolve));
  1705. }
  1706. snapPromiseCapability->RejectVar = this->reject;
  1707. if(TTD::JsSupport::IsVarComplexKind(this->reject))
  1708. {
  1709. depOnList.Add(TTD_CONVERT_VAR_TO_PTR_ID(this->reject));
  1710. }
  1711. }
  1712. #endif
  1713. JavascriptPromiseReaction* JavascriptPromiseReaction::New(JavascriptPromiseCapability* capabilities, RecyclableObject* handler, ScriptContext* scriptContext)
  1714. {
  1715. return RecyclerNew(scriptContext->GetRecycler(), JavascriptPromiseReaction, capabilities, handler);
  1716. }
  1717. JavascriptPromiseCapability* JavascriptPromiseReaction::GetCapabilities()
  1718. {
  1719. return this->capabilities;
  1720. }
  1721. RecyclableObject* JavascriptPromiseReaction::GetHandler()
  1722. {
  1723. return this->handler;
  1724. }
  1725. #if ENABLE_TTD
  1726. void JavascriptPromiseReaction::MarkVisitPtrs(TTD::SnapshotExtractor* extractor)
  1727. {
  1728. TTDAssert(this->handler != nullptr && this->capabilities != nullptr, "Seems odd, I was not expecting this!!!");
  1729. extractor->MarkVisitVar(this->handler);
  1730. this->capabilities->MarkVisitPtrs(extractor);
  1731. }
  1732. void JavascriptPromiseReaction::ExtractSnapPromiseReactionInto(TTD::NSSnapValues::SnapPromiseReactionInfo* snapPromiseReaction, JsUtil::List<TTD_PTR_ID, HeapAllocator>& depOnList, TTD::SlabAllocator& alloc)
  1733. {
  1734. TTDAssert(this->handler != nullptr && this->capabilities != nullptr, "Seems odd, I was not expecting this!!!");
  1735. snapPromiseReaction->PromiseReactionId = TTD_CONVERT_PROMISE_INFO_TO_PTR_ID(this);
  1736. snapPromiseReaction->HandlerObjId = TTD_CONVERT_VAR_TO_PTR_ID(this->handler);
  1737. depOnList.Add(snapPromiseReaction->HandlerObjId);
  1738. this->capabilities->ExtractSnapPromiseCapabilityInto(&snapPromiseReaction->Capabilities, depOnList, alloc);
  1739. }
  1740. #endif
  1741. template <> bool VarIsImpl<JavascriptPromiseReactionTaskFunction>(RecyclableObject* obj)
  1742. {
  1743. if (VarIs<JavascriptFunction>(obj))
  1744. {
  1745. return VirtualTableInfo<JavascriptPromiseReactionTaskFunction>::HasVirtualTable(obj)
  1746. || VirtualTableInfo<CrossSiteObject<JavascriptPromiseReactionTaskFunction>>::HasVirtualTable(obj);
  1747. }
  1748. return false;
  1749. }
  1750. JavascriptPromiseReaction* JavascriptPromiseReactionTaskFunction::GetReaction()
  1751. {
  1752. return this->reaction;
  1753. }
  1754. Var JavascriptPromiseReactionTaskFunction::GetArgument()
  1755. {
  1756. return this->argument;
  1757. }
  1758. #if ENABLE_TTD
  1759. void JavascriptPromiseReactionTaskFunction::MarkVisitKindSpecificPtrs(TTD::SnapshotExtractor* extractor)
  1760. {
  1761. TTDAssert(this->argument != nullptr && this->reaction != nullptr, "Was not expecting this!!!");
  1762. extractor->MarkVisitVar(this->argument);
  1763. this->reaction->MarkVisitPtrs(extractor);
  1764. }
  1765. TTD::NSSnapObjects::SnapObjectType JavascriptPromiseReactionTaskFunction::GetSnapTag_TTD() const
  1766. {
  1767. return TTD::NSSnapObjects::SnapObjectType::SnapPromiseReactionTaskFunctionObject;
  1768. }
  1769. void JavascriptPromiseReactionTaskFunction::ExtractSnapObjectDataInto(TTD::NSSnapObjects::SnapObject* objData, TTD::SlabAllocator& alloc)
  1770. {
  1771. TTD::NSSnapObjects::SnapPromiseReactionTaskFunctionInfo* sprtfi = alloc.SlabAllocateStruct<TTD::NSSnapObjects::SnapPromiseReactionTaskFunctionInfo>();
  1772. JsUtil::List<TTD_PTR_ID, HeapAllocator> depOnList(&HeapAllocator::Instance);
  1773. sprtfi->Argument = this->argument;
  1774. if(this->argument != nullptr && TTD::JsSupport::IsVarComplexKind(this->argument))
  1775. {
  1776. depOnList.Add(TTD_CONVERT_VAR_TO_PTR_ID(this->argument));
  1777. }
  1778. this->reaction->ExtractSnapPromiseReactionInto(&sprtfi->Reaction, depOnList, alloc);
  1779. //see what we need to do wrt dependencies
  1780. if(depOnList.Count() == 0)
  1781. {
  1782. TTD::NSSnapObjects::StdExtractSetKindSpecificInfo<TTD::NSSnapObjects::SnapPromiseReactionTaskFunctionInfo*, TTD::NSSnapObjects::SnapObjectType::SnapPromiseReactionTaskFunctionObject>(objData, sprtfi);
  1783. }
  1784. else
  1785. {
  1786. uint32 depOnCount = depOnList.Count();
  1787. TTD_PTR_ID* depOnArray = alloc.SlabAllocateArray<TTD_PTR_ID>(depOnCount);
  1788. for(uint32 i = 0; i < depOnCount; ++i)
  1789. {
  1790. depOnArray[i] = depOnList.Item(i);
  1791. }
  1792. TTD::NSSnapObjects::StdExtractSetKindSpecificInfo<TTD::NSSnapObjects::SnapPromiseReactionTaskFunctionInfo*, TTD::NSSnapObjects::SnapObjectType::SnapPromiseReactionTaskFunctionObject>(objData, sprtfi, alloc, depOnCount, depOnArray);
  1793. }
  1794. }
  1795. #endif
  1796. template <> bool VarIsImpl<JavascriptPromiseThenFinallyFunction>(RecyclableObject* obj)
  1797. {
  1798. if (VarIs<JavascriptFunction>(obj))
  1799. {
  1800. return VirtualTableInfo<JavascriptPromiseThenFinallyFunction>::HasVirtualTable(obj)
  1801. || VirtualTableInfo<CrossSiteObject<JavascriptPromiseThenFinallyFunction>>::HasVirtualTable(obj);
  1802. }
  1803. return false;
  1804. }
  1805. template <> bool VarIsImpl<JavascriptPromiseThunkFinallyFunction>(RecyclableObject* obj)
  1806. {
  1807. if (VarIs<JavascriptFunction>(obj))
  1808. {
  1809. return VirtualTableInfo<JavascriptPromiseThunkFinallyFunction>::HasVirtualTable(obj)
  1810. || VirtualTableInfo<CrossSiteObject<JavascriptPromiseThunkFinallyFunction>>::HasVirtualTable(obj);
  1811. }
  1812. return false;
  1813. }
  1814. template <> bool VarIsImpl<JavascriptPromiseResolveThenableTaskFunction>(RecyclableObject* obj)
  1815. {
  1816. if (VarIs<JavascriptFunction>(obj))
  1817. {
  1818. return VirtualTableInfo<JavascriptPromiseResolveThenableTaskFunction>::HasVirtualTable(obj)
  1819. || VirtualTableInfo<CrossSiteObject<JavascriptPromiseResolveThenableTaskFunction>>::HasVirtualTable(obj);
  1820. }
  1821. return false;
  1822. }
  1823. JavascriptPromise* JavascriptPromiseResolveThenableTaskFunction::GetPromise()
  1824. {
  1825. return this->promise;
  1826. }
  1827. RecyclableObject* JavascriptPromiseResolveThenableTaskFunction::GetThenable()
  1828. {
  1829. return this->thenable;
  1830. }
  1831. RecyclableObject* JavascriptPromiseResolveThenableTaskFunction::GetThenFunction()
  1832. {
  1833. return this->thenFunction;
  1834. }
  1835. #if ENABLE_TTD
  1836. void JavascriptPromiseResolveThenableTaskFunction::MarkVisitKindSpecificPtrs(TTD::SnapshotExtractor* extractor)
  1837. {
  1838. TTDAssert(false, "Not Implemented Yet");
  1839. }
  1840. TTD::NSSnapObjects::SnapObjectType JavascriptPromiseResolveThenableTaskFunction::GetSnapTag_TTD() const
  1841. {
  1842. TTDAssert(false, "Not Implemented Yet");
  1843. return TTD::NSSnapObjects::SnapObjectType::Invalid;
  1844. }
  1845. void JavascriptPromiseResolveThenableTaskFunction::ExtractSnapObjectDataInto(TTD::NSSnapObjects::SnapObject* objData, TTD::SlabAllocator& alloc)
  1846. {
  1847. TTDAssert(false, "Not Implemented Yet");
  1848. }
  1849. #endif
  1850. JavascriptPromiseAllSettledResolveOrRejectElementFunction::JavascriptPromiseAllSettledResolveOrRejectElementFunction(DynamicType* type)
  1851. : JavascriptPromiseAllResolveElementFunction(type), alreadyCalledWrapper(nullptr), isRejecting(false)
  1852. { }
  1853. JavascriptPromiseAllSettledResolveOrRejectElementFunction::JavascriptPromiseAllSettledResolveOrRejectElementFunction(DynamicType* type, FunctionInfo* functionInfo, uint32 index, JavascriptArray* values, JavascriptPromiseCapability* capabilities, JavascriptPromiseAllResolveElementFunctionRemainingElementsWrapper* remainingElementsWrapper, JavascriptPromiseResolveOrRejectFunctionAlreadyResolvedWrapper* alreadyCalledWrapper, bool isRejecting)
  1854. : JavascriptPromiseAllResolveElementFunction(type, functionInfo, index, values, capabilities, remainingElementsWrapper), alreadyCalledWrapper(alreadyCalledWrapper), isRejecting(isRejecting)
  1855. { }
  1856. bool JavascriptPromiseAllSettledResolveOrRejectElementFunction::IsAlreadyCalled() const
  1857. {
  1858. Assert(this->alreadyCalledWrapper);
  1859. return this->alreadyCalledWrapper->alreadyResolved;
  1860. }
  1861. void JavascriptPromiseAllSettledResolveOrRejectElementFunction::SetAlreadyCalled(const bool is)
  1862. {
  1863. Assert(this->alreadyCalledWrapper);
  1864. this->alreadyCalledWrapper->alreadyResolved = is;
  1865. }
  1866. bool JavascriptPromiseAllSettledResolveOrRejectElementFunction::IsRejectFunction()
  1867. {
  1868. return this->isRejecting;
  1869. }
  1870. template <> bool VarIsImpl<JavascriptPromiseAllSettledResolveOrRejectElementFunction>(RecyclableObject* obj)
  1871. {
  1872. if (VarIs<JavascriptFunction>(obj))
  1873. {
  1874. return VirtualTableInfo<JavascriptPromiseAllSettledResolveOrRejectElementFunction>::HasVirtualTable(obj)
  1875. || VirtualTableInfo<CrossSiteObject<JavascriptPromiseAllSettledResolveOrRejectElementFunction>>::HasVirtualTable(obj);
  1876. }
  1877. return false;
  1878. }
  1879. #if ENABLE_TTD
  1880. void JavascriptPromiseAllSettledResolveOrRejectElementFunction::MarkVisitKindSpecificPtrs(TTD::SnapshotExtractor* extractor)
  1881. {
  1882. TTDAssert(this->capabilities != nullptr && this->remainingElementsWrapper != nullptr && this->alreadyCalledWrapper != nullptr && this->values != nullptr, "Don't think these can be null");
  1883. this->capabilities->MarkVisitPtrs(extractor);
  1884. extractor->MarkVisitVar(this->values);
  1885. }
  1886. TTD::NSSnapObjects::SnapObjectType JavascriptPromiseAllSettledResolveOrRejectElementFunction::GetSnapTag_TTD() const
  1887. {
  1888. return TTD::NSSnapObjects::SnapObjectType::SnapPromiseAllSettledResolveOrRejectElementFunctionObject;
  1889. }
  1890. void JavascriptPromiseAllSettledResolveOrRejectElementFunction::ExtractSnapObjectDataInto(TTD::NSSnapObjects::SnapObject* objData, TTD::SlabAllocator& alloc)
  1891. {
  1892. TTD::NSSnapObjects::SnapPromiseAllResolveElementFunctionInfo* sprai = alloc.SlabAllocateStruct<TTD::NSSnapObjects::SnapPromiseAllResolveElementFunctionInfo>();
  1893. JsUtil::List<TTD_PTR_ID, HeapAllocator> depOnList(&HeapAllocator::Instance);
  1894. this->capabilities->ExtractSnapPromiseCapabilityInto(&sprai->Capabilities, depOnList, alloc);
  1895. sprai->Index = this->index;
  1896. sprai->RemainingElementsWrapperId = TTD_CONVERT_PROMISE_INFO_TO_PTR_ID(this->remainingElementsWrapper);
  1897. sprai->RemainingElementsValue = this->remainingElementsWrapper->remainingElements;
  1898. sprai->Values = TTD_CONVERT_VAR_TO_PTR_ID(this->values);
  1899. depOnList.Add(sprai->Values);
  1900. sprai->AlreadyCalled = this->alreadyCalled;
  1901. uint32 depOnCount = depOnList.Count();
  1902. TTD_PTR_ID* depOnArray = alloc.SlabAllocateArray<TTD_PTR_ID>(depOnCount);
  1903. for (uint32 i = 0; i < depOnCount; ++i)
  1904. {
  1905. depOnArray[i] = depOnList.Item(i);
  1906. }
  1907. TTD::NSSnapObjects::StdExtractSetKindSpecificInfo<TTD::NSSnapObjects::SnapPromiseAllResolveElementFunctionInfo*, TTD::NSSnapObjects::SnapObjectType::SnapPromiseAllResolveElementFunctionObject>(objData, sprai, alloc, depOnCount, depOnArray);
  1908. }
  1909. #endif
  1910. JavascriptPromiseAnyRejectElementFunction::JavascriptPromiseAnyRejectElementFunction(DynamicType* type)
  1911. : JavascriptPromiseAllResolveElementFunction(type), alreadyCalledWrapper(nullptr)
  1912. { }
  1913. JavascriptPromiseAnyRejectElementFunction::JavascriptPromiseAnyRejectElementFunction(DynamicType* type, FunctionInfo* functionInfo, uint32 index, JavascriptArray* values, JavascriptPromiseCapability* capabilities, JavascriptPromiseAllResolveElementFunctionRemainingElementsWrapper* remainingElementsWrapper, JavascriptPromiseResolveOrRejectFunctionAlreadyResolvedWrapper* alreadyCalledWrapper)
  1914. : JavascriptPromiseAllResolveElementFunction(type, functionInfo, index, values, capabilities, remainingElementsWrapper), alreadyCalledWrapper(alreadyCalledWrapper)
  1915. { }
  1916. #if ENABLE_TTD
  1917. void JavascriptPromiseAnyRejectElementFunction::MarkVisitKindSpecificPtrs(TTD::SnapshotExtractor* extractor)
  1918. {
  1919. TTDAssert(this->capabilities != nullptr && this->remainingElementsWrapper != nullptr && this->alreadyCalledWrapper != nullptr && this->values != nullptr, "Don't think these can be null");
  1920. this->capabilities->MarkVisitPtrs(extractor);
  1921. extractor->MarkVisitVar(this->values);
  1922. }
  1923. TTD::NSSnapObjects::SnapObjectType JavascriptPromiseAnyRejectElementFunction::GetSnapTag_TTD() const
  1924. {
  1925. return TTD::NSSnapObjects::SnapObjectType::SnapPromiseAnyRejectElementFunctionObject;
  1926. }
  1927. void JavascriptPromiseAnyRejectElementFunction::ExtractSnapObjectDataInto(TTD::NSSnapObjects::SnapObject* objData, TTD::SlabAllocator& alloc)
  1928. {
  1929. TTD::NSSnapObjects::SnapPromiseAllResolveElementFunctionInfo* sprai = alloc.SlabAllocateStruct<TTD::NSSnapObjects::SnapPromiseAllResolveElementFunctionInfo>();
  1930. JsUtil::List<TTD_PTR_ID, HeapAllocator> depOnList(&HeapAllocator::Instance);
  1931. this->capabilities->ExtractSnapPromiseCapabilityInto(&sprai->Capabilities, depOnList, alloc);
  1932. sprai->Index = this->index;
  1933. sprai->RemainingElementsWrapperId = TTD_CONVERT_PROMISE_INFO_TO_PTR_ID(this->remainingElementsWrapper);
  1934. sprai->RemainingElementsValue = this->remainingElementsWrapper->remainingElements;
  1935. sprai->Values = TTD_CONVERT_VAR_TO_PTR_ID(this->values);
  1936. depOnList.Add(sprai->Values);
  1937. sprai->AlreadyCalled = this->alreadyCalled;
  1938. uint32 depOnCount = depOnList.Count();
  1939. TTD_PTR_ID* depOnArray = alloc.SlabAllocateArray<TTD_PTR_ID>(depOnCount);
  1940. for (uint32 i = 0; i < depOnCount; ++i)
  1941. {
  1942. depOnArray[i] = depOnList.Item(i);
  1943. }
  1944. TTD::NSSnapObjects::StdExtractSetKindSpecificInfo<TTD::NSSnapObjects::SnapPromiseAllResolveElementFunctionInfo*, TTD::NSSnapObjects::SnapObjectType::SnapPromiseAllResolveElementFunctionObject>(objData, sprai, alloc, depOnCount, depOnArray);
  1945. }
  1946. #endif
  1947. template <> bool VarIsImpl<JavascriptPromiseAnyRejectElementFunction>(RecyclableObject* obj)
  1948. {
  1949. if (VarIs<JavascriptFunction>(obj))
  1950. {
  1951. return VirtualTableInfo<JavascriptPromiseAnyRejectElementFunction>::HasVirtualTable(obj)
  1952. || VirtualTableInfo<CrossSiteObject<JavascriptPromiseAnyRejectElementFunction>>::HasVirtualTable(obj);
  1953. }
  1954. return false;
  1955. }
  1956. JavascriptPromiseAllResolveElementFunction::JavascriptPromiseAllResolveElementFunction(DynamicType* type)
  1957. : RuntimeFunction(type, &Js::JavascriptPromise::EntryInfo::AllResolveElementFunction), index(0), values(nullptr), capabilities(nullptr), remainingElementsWrapper(nullptr), alreadyCalled(false)
  1958. { }
  1959. JavascriptPromiseAllResolveElementFunction::JavascriptPromiseAllResolveElementFunction(DynamicType* type, FunctionInfo* functionInfo, uint32 index, JavascriptArray* values, JavascriptPromiseCapability* capabilities, JavascriptPromiseAllResolveElementFunctionRemainingElementsWrapper* remainingElementsWrapper)
  1960. : RuntimeFunction(type, functionInfo), index(index), values(values), capabilities(capabilities), remainingElementsWrapper(remainingElementsWrapper), alreadyCalled(false)
  1961. { }
  1962. template <> bool VarIsImpl<JavascriptPromiseAllResolveElementFunction>(RecyclableObject* obj)
  1963. {
  1964. if (VarIs<JavascriptFunction>(obj))
  1965. {
  1966. return VirtualTableInfo<JavascriptPromiseAllResolveElementFunction>::HasVirtualTable(obj)
  1967. || VirtualTableInfo<CrossSiteObject<JavascriptPromiseAllResolveElementFunction>>::HasVirtualTable(obj);
  1968. }
  1969. return false;
  1970. }
  1971. JavascriptPromiseCapability* JavascriptPromiseAllResolveElementFunction::GetCapabilities()
  1972. {
  1973. return this->capabilities;
  1974. }
  1975. uint32 JavascriptPromiseAllResolveElementFunction::GetIndex()
  1976. {
  1977. return this->index;
  1978. }
  1979. uint32 JavascriptPromiseAllResolveElementFunction::GetRemainingElements()
  1980. {
  1981. return this->remainingElementsWrapper->remainingElements;
  1982. }
  1983. JavascriptArray* JavascriptPromiseAllResolveElementFunction::GetValues()
  1984. {
  1985. return this->values;
  1986. }
  1987. uint32 JavascriptPromiseAllResolveElementFunction::DecrementRemainingElements()
  1988. {
  1989. return --(this->remainingElementsWrapper->remainingElements);
  1990. }
  1991. bool JavascriptPromiseAllResolveElementFunction::IsAlreadyCalled() const
  1992. {
  1993. return this->alreadyCalled;
  1994. }
  1995. void JavascriptPromiseAllResolveElementFunction::SetAlreadyCalled(const bool is)
  1996. {
  1997. this->alreadyCalled = is;
  1998. }
  1999. #if ENABLE_TTD
  2000. void JavascriptPromiseAllResolveElementFunction::MarkVisitKindSpecificPtrs(TTD::SnapshotExtractor* extractor)
  2001. {
  2002. TTDAssert(this->capabilities != nullptr && this->remainingElementsWrapper != nullptr && this->values != nullptr, "Don't think these can be null");
  2003. this->capabilities->MarkVisitPtrs(extractor);
  2004. extractor->MarkVisitVar(this->values);
  2005. }
  2006. TTD::NSSnapObjects::SnapObjectType JavascriptPromiseAllResolveElementFunction::GetSnapTag_TTD() const
  2007. {
  2008. return TTD::NSSnapObjects::SnapObjectType::SnapPromiseAllResolveElementFunctionObject;
  2009. }
  2010. void JavascriptPromiseAllResolveElementFunction::ExtractSnapObjectDataInto(TTD::NSSnapObjects::SnapObject* objData, TTD::SlabAllocator& alloc)
  2011. {
  2012. TTD::NSSnapObjects::SnapPromiseAllResolveElementFunctionInfo* sprai = alloc.SlabAllocateStruct<TTD::NSSnapObjects::SnapPromiseAllResolveElementFunctionInfo>();
  2013. JsUtil::List<TTD_PTR_ID, HeapAllocator> depOnList(&HeapAllocator::Instance);
  2014. this->capabilities->ExtractSnapPromiseCapabilityInto(&sprai->Capabilities, depOnList, alloc);
  2015. sprai->Index = this->index;
  2016. sprai->RemainingElementsWrapperId = TTD_CONVERT_PROMISE_INFO_TO_PTR_ID(this->remainingElementsWrapper);
  2017. sprai->RemainingElementsValue = this->remainingElementsWrapper->remainingElements;
  2018. sprai->Values = TTD_CONVERT_VAR_TO_PTR_ID(this->values);
  2019. depOnList.Add(sprai->Values);
  2020. sprai->AlreadyCalled = this->alreadyCalled;
  2021. uint32 depOnCount = depOnList.Count();
  2022. TTD_PTR_ID* depOnArray = alloc.SlabAllocateArray<TTD_PTR_ID>(depOnCount);
  2023. for(uint32 i = 0; i < depOnCount; ++i)
  2024. {
  2025. depOnArray[i] = depOnList.Item(i);
  2026. }
  2027. TTD::NSSnapObjects::StdExtractSetKindSpecificInfo<TTD::NSSnapObjects::SnapPromiseAllResolveElementFunctionInfo*, TTD::NSSnapObjects::SnapObjectType::SnapPromiseAllResolveElementFunctionObject>(objData, sprai, alloc, depOnCount, depOnArray);
  2028. }
  2029. #endif
  2030. Var JavascriptPromise::EntryGetterSymbolSpecies(RecyclableObject* function, CallInfo callInfo, ...)
  2031. {
  2032. ARGUMENTS(args, callInfo);
  2033. Assert(args.Info.Count > 0);
  2034. return args[0];
  2035. }
  2036. //static
  2037. JavascriptPromise* JavascriptPromise::CreateEnginePromise(ScriptContext *scriptContext)
  2038. {
  2039. JavascriptPromiseResolveOrRejectFunction *resolve = nullptr;
  2040. JavascriptPromiseResolveOrRejectFunction *reject = nullptr;
  2041. JavascriptPromise *promise = scriptContext->GetLibrary()->CreatePromise();
  2042. JavascriptPromise::InitializePromise(promise, &resolve, &reject, scriptContext);
  2043. return promise;
  2044. }
  2045. } // namespace Js