JavascriptPromise.cpp 96 KB

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