Skip to content

Commit 2b59984

Browse files
avivkelleraduh95
authored andcommitted
deps: V8: backport 5177b10891e6
Original commit message: fix(inspector): hold on to promises Keep `m_evaluationResult` strong for evaluations until the promise settles or the request is cancelled. Bug: 536271637 Change-Id: If21cc4aa0ba6bb2e2722d5ee73eb7744a0ead207 Reviewed-on: https://chromium-review.googlesource.com/c/v8/v8/+/8123081 Commit-Queue: Simon Zünd <szuend@chromium.org> Reviewed-by: Simon Zünd <szuend@chromium.org> Reviewed-by: Kim-Anh Tran <kimanh@chromium.org> Cr-Commit-Position: refs/heads/main@{#108874} Refs: v8/v8@5177b10 Co-authored-by: avivkeller <me@aviv.sh> PR-URL: #64631 Reviewed-By: Daeyeon Jeong <daeyeon.dev@gmail.com> Reviewed-By: Chengzhong Wu <legendecas@gmail.com>
1 parent a646319 commit 2b59984

8 files changed

Lines changed: 218 additions & 7 deletions

File tree

‎common.gypi‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,7 @@
4242

4343
# Reset this number to 0 on major V8 upgrades.
4444
# Increment by one for each non-official patch applied to deps/v8.
45-
'v8_embedder_string': '-node.27',
45+
'v8_embedder_string': '-node.28',
4646

4747
##### V8 defaults for Node.js #####
4848

‎deps/v8/AUTHORS‎

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -77,6 +77,7 @@ Artem Kobzar <artem.kobzar@jetbrains.com>
7777
Arthur Islamov <arthur@islamov.ai>
7878
Asuka Shikina <shikina.asuka@gmail.com>
7979
Aurèle Barrière <aurele.barriere@gmail.com>
80+
Aviv Keller <me@aviv.sh>
8081
Bala Avulapati <bavulapati@gmail.com>
8182
Bangfu Tao <bangfu.tao@samsung.com>
8283
Ben Coe <bencoe@gmail.com>

‎deps/v8/src/inspector/injected-script.cc‎

Lines changed: 37 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -204,8 +204,7 @@ class InjectedScript::ProtocolPromiseHandler {
204204
PromiseHandlerTracker::DiscardReason::kFulfilled);
205205
}
206206

207-
ProtocolPromiseHandler(PromiseHandlerTracker::Id id,
208-
V8InspectorSessionImpl* session,
207+
ProtocolPromiseHandler(V8InspectorSessionImpl* session,
209208
int executionContextId, const String16& objectGroup,
210209
std::unique_ptr<WrapOptions> wrapOptions,
211210
bool replMode, bool throwOnSideEffect,
@@ -220,7 +219,13 @@ class InjectedScript::ProtocolPromiseHandler {
220219
m_replMode(replMode),
221220
m_throwOnSideEffect(throwOnSideEffect),
222221
m_callback(std::move(callback)),
223-
m_evaluationResult(m_inspector->isolate(), evaluationResult) {
222+
m_evaluationResult(m_inspector->isolate(), evaluationResult) {}
223+
224+
voidmakeWeak(PromiseHandlerTracker::Id id) {
225+
if (m_isActive || m_evaluationResult.IsEmpty() ||
226+
m_evaluationResult.IsWeak()) {
227+
return;
228+
}
224229
m_evaluationResult.SetWeak(reinterpret_cast<PromiseHandlerTracker::Id*>(id),
225230
cleanup, v8::WeakCallbackType::kParameter);
226231
}
@@ -238,6 +243,7 @@ class InjectedScript::ProtocolPromiseHandler {
238243
}
239244

240245
voidthenCallback(v8::Local<v8::Value> value) {
246+
m_isActive = true;
241247
// We don't need the m_evaluationResult in the `thenCallback`, but we also
242248
// don't want `cleanup` running in case we re-enter JS.
243249
m_evaluationResult.Reset();
@@ -285,9 +291,10 @@ class InjectedScript::ProtocolPromiseHandler {
285291
}
286292

287293
voidcatchCallback(v8::Local<v8::Value> result) {
294+
m_isActive = true;
288295
// Hold strongly onto m_evaluationResult now to prevent `cleanup` from
289296
// running in case any code below triggers GC.
290-
m_evaluationResult.ClearWeak();
297+
if (m_evaluationResult.IsWeak()) m_evaluationResult.ClearWeak();
291298
V8InspectorSessionImpl* session =
292299
m_inspector->sessionById(m_contextGroupId, m_sessionId);
293300
if (!session) return;
@@ -393,6 +400,7 @@ class InjectedScript::ProtocolPromiseHandler {
393400
std::unique_ptr<WrapOptions> m_wrapOptions;
394401
bool m_replMode;
395402
bool m_throwOnSideEffect;
403+
bool m_isActive = false;
396404
std::weak_ptr<EvaluateCallback> m_callback;
397405
v8::Global<v8::Promise> m_evaluationResult;
398406
};
@@ -1190,8 +1198,7 @@ template <typename... Args>
11901198
PromiseHandlerTracker::Id PromiseHandlerTracker::create(Args&&... args) {
11911199
Id id = m_lastUsedId++;
11921200
InjectedScript::ProtocolPromiseHandler* handler =
1193-
newInjectedScript::ProtocolPromiseHandler(id,
1194-
std::forward<Args>(args)...);
1201+
newInjectedScript::ProtocolPromiseHandler(std::forward<Args>(args)...);
11951202
m_promiseHandlers.emplace(id, handler);
11961203
return id;
11971204
}
@@ -1225,6 +1232,30 @@ InjectedScript::ProtocolPromiseHandler* PromiseHandlerTracker::get(
12251232
return iter->second.get();
12261233
}
12271234

1235+
voidPromiseHandlerTracker::makeWeakForContext(int executionContextId) {
1236+
for (auto& [id, handler] : m_promiseHandlers) {
1237+
if (handler->m_executionContextId == executionContextId) {
1238+
handler->makeWeak(id);
1239+
}
1240+
}
1241+
}
1242+
1243+
voidPromiseHandlerTracker::makeWeakForObjectGroup(
1244+
int sessionId, const String16& objectGroup) {
1245+
for (auto& [id, handler] : m_promiseHandlers) {
1246+
if (handler->m_sessionId == sessionId &&
1247+
handler->m_objectGroup == objectGroup) {
1248+
handler->makeWeak(id);
1249+
}
1250+
}
1251+
}
1252+
1253+
voidPromiseHandlerTracker::makeWeakForSession(int sessionId) {
1254+
for (auto& [id, handler] : m_promiseHandlers) {
1255+
if (handler->m_sessionId == sessionId) handler->makeWeak(id);
1256+
}
1257+
}
1258+
12281259
voidPromiseHandlerTracker::sendFailure(
12291260
InjectedScript::ProtocolPromiseHandler* handler,
12301261
const protocol::DispatchResponse& response) const {

‎deps/v8/src/inspector/injected-script.h‎

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -298,6 +298,9 @@ class PromiseHandlerTracker {
298298
Id create(Args&&... args);
299299
voiddiscard(Id id, DiscardReason reason);
300300
InjectedScript::ProtocolPromiseHandler* get(Id id) const;
301+
voidmakeWeakForContext(int executionContextId);
302+
voidmakeWeakForObjectGroup(int sessionId, const String16& objectGroup);
303+
voidmakeWeakForSession(int sessionId);
301304

302305
private:
303306
voidsendFailure(InjectedScript::ProtocolPromiseHandler* handler,

‎deps/v8/src/inspector/v8-inspector-impl.cc‎

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -319,6 +319,7 @@ void V8InspectorImpl::contextCollected(int groupId, int contextId) {
319319
session->runtimeAgent()->reportExecutionContextDestroyed(inspectedContext);
320320
});
321321
discardInspectedContext(groupId, contextId);
322+
m_promiseHandlerTracker.makeWeakForContext(contextId);
322323
}
323324

324325
voidV8InspectorImpl::resetContextGroup(int contextGroupId) {

‎deps/v8/src/inspector/v8-inspector-session-impl.cc‎

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -224,6 +224,7 @@ void V8InspectorSessionImpl::discardInjectedScripts() {
224224
[&sessionId](InspectedContext* context) {
225225
context->discardInjectedScript(sessionId);
226226
});
227+
m_inspector->promiseHandlerTracker().makeWeakForSession(sessionId);
227228
}
228229

229230
Response V8InspectorSessionImpl::findInjectedScript(
@@ -260,6 +261,10 @@ void V8InspectorSessionImpl::releaseObjectGroup(const String16& objectGroup) {
260261
InjectedScript* injectedScript = context->getInjectedScript(sessionId);
261262
if (injectedScript) injectedScript->releaseObjectGroup(objectGroup);
262263
});
264+
if (!objectGroup.isEmpty()) {
265+
m_inspector->promiseHandlerTracker().makeWeakForObjectGroup(m_sessionId,
266+
objectGroup);
267+
}
263268
}
264269

265270
boolV8InspectorSessionImpl::unwrapObject(
Lines changed: 65 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,65 @@
1+
Tests the lifetime of pending Runtime.evaluate requests.
2+
3+
Running test: testPromiseIsKeptAlive
4+
Using replMode:
5+
{
6+
id : <messageId>
7+
result : {
8+
result : {
9+
description : 42
10+
type : number
11+
value : 42
12+
}
13+
}
14+
}
15+
Using awaitPromise:
16+
{
17+
id : <messageId>
18+
result : {
19+
result : {
20+
description : 42
21+
type : number
22+
value : 42
23+
}
24+
}
25+
}
26+
27+
Running test: testObjectGroupReleaseMakesPromiseCollectible
28+
Using replMode:
29+
{
30+
error : {
31+
code : -32000
32+
message : Promise was collected
33+
}
34+
id : <messageId>
35+
}
36+
Using awaitPromise:
37+
{
38+
error : {
39+
code : -32000
40+
message : Promise was collected
41+
}
42+
id : <messageId>
43+
}
44+
45+
Running test: testContextDestructionDiscardsPromise
46+
Using replMode:
47+
{
48+
error : {
49+
code : -32000
50+
message : Execution context was destroyed.
51+
}
52+
id : <messageId>
53+
}
54+
Using awaitPromise:
55+
{
56+
error : {
57+
code : -32000
58+
message : Execution context was destroyed.
59+
}
60+
id : <messageId>
61+
}
62+
63+
Running test: testSessionDestructionMakesPromiseCollectible
64+
Promise is alive before disconnect: true
65+
Promise is alive after disconnect: false
Lines changed: 105 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,105 @@
1+
// Copyright 2026 the V8 project authors. All rights reserved.
2+
// Use of this source code is governed by a BSD-style license that can be
3+
// found in the LICENSE file.
4+
5+
// Flags: --no-stress-incremental-marking
6+
7+
let{Protocol}=InspectorTest.start(
8+
'Tests the lifetime of pending Runtime.evaluate requests.');
9+
10+
constevaluationModes=[
11+
{
12+
name: 'replMode',
13+
arguments: {replMode: true},
14+
expression:
15+
'await new Promise(resolve => globalThis.resolve = resolve); 42',
16+
resolveExpression: 'resolve()',
17+
pendingExpression: 'await new Promise(() => {})',
18+
},
19+
{
20+
name: 'awaitPromise',
21+
arguments: {awaitPromise: true},
22+
expression: `(() => {
23+
let resolve;
24+
const promise = new Promise(r => resolve = r);
25+
promise.resolve = resolve;
26+
globalThis.weak = new WeakRef(promise);
27+
return promise;
28+
})()`,
29+
resolveExpression: 'weak.deref().resolve(42)',
30+
pendingExpression: 'new Promise(() => {})',
31+
},
32+
];
33+
34+
functionevaluate(Protocol,mode,expression,extraArguments={}){
35+
returnProtocol.Runtime.evaluate(
36+
{...mode.arguments, ...extraArguments, expression});
37+
}
38+
39+
InspectorTest.runAsyncTestSuite([
40+
asyncfunctiontestPromiseIsKeptAlive(){
41+
for(constmodeofevaluationModes){
42+
InspectorTest.log(`Using ${mode.name}:`);
43+
constevaluation=evaluate(Protocol,mode,mode.expression);
44+
45+
awaitProtocol.HeapProfiler.collectGarbage();
46+
awaitProtocol.Runtime.evaluate({expression: mode.resolveExpression});
47+
48+
InspectorTest.logMessage(awaitevaluation);
49+
}
50+
},
51+
52+
asyncfunctiontestObjectGroupReleaseMakesPromiseCollectible(){
53+
for(constmodeofevaluationModes){
54+
InspectorTest.log(`Using ${mode.name}:`);
55+
constevaluation=evaluate(
56+
Protocol,mode,mode.pendingExpression,
57+
{objectGroup: 'evaluation'});
58+
59+
awaitProtocol.Runtime.releaseObjectGroup({objectGroup: 'evaluation'});
60+
awaitProtocol.HeapProfiler.collectGarbage();
61+
62+
InspectorTest.logMessage(awaitevaluation);
63+
}
64+
},
65+
66+
asyncfunctiontestContextDestructionDiscardsPromise(){
67+
for(constmodeofevaluationModes){
68+
InspectorTest.log(`Using ${mode.name}:`);
69+
constcontextGroup=newInspectorTest.ContextGroup();
70+
constsession=contextGroup.connect();
71+
constevaluation=evaluate(
72+
session.Protocol,mode,mode.pendingExpression);
73+
74+
awaitsession.Protocol.Runtime.evaluate(
75+
{expression: 'inspector.fireContextDestroyed()'});
76+
77+
InspectorTest.logMessage(awaitevaluation);
78+
session.disconnect();
79+
}
80+
},
81+
82+
asyncfunctiontestSessionDestructionMakesPromiseCollectible(){
83+
constcontextGroup=newInspectorTest.ContextGroup();
84+
constsession1=contextGroup.connect();
85+
constsession2=contextGroup.connect();
86+
session1.Protocol.Runtime.evaluate({
87+
expression: evaluationModes[1].expression,
88+
awaitPromise: true,
89+
});
90+
91+
awaitsession2.Protocol.HeapProfiler.collectGarbage();
92+
letresult=awaitsession2.Protocol.Runtime.evaluate(
93+
{expression: 'weak.deref() !== undefined'});
94+
InspectorTest.log(
95+
`Promise is alive before disconnect: ${result.result.result.value}`);
96+
97+
session1.disconnect();
98+
awaitsession2.Protocol.HeapProfiler.collectGarbage();
99+
result=awaitsession2.Protocol.Runtime.evaluate(
100+
{expression: 'weak.deref() !== undefined'});
101+
InspectorTest.log(
102+
`Promise is alive after disconnect: ${result.result.result.value}`);
103+
session2.disconnect();
104+
},
105+
]);

0 commit comments

Comments
 (0)