nodejs
diff --git a/Collapse file
‎src/async_wrap.cc‎
Copy file name to clipboardExpand all lines: src/async_wrap.cc
+17-3Lines changed: 17 additions & 3 deletions b/Collapse file
‎src/async_wrap.cc‎
Copy file name to clipboardExpand all lines: src/async_wrap.cc
+17-3Lines changed: 17 additions & 3 deletions
diff --git a/Collapse file
‎test/parallel/test-async-local-storage-http-parser-leak.js‎
Copy file name to clipboard
+29Lines changed: 29 additions & 0 deletions b/Collapse file
‎test/parallel/test-async-local-storage-http-parser-leak.js‎
Copy file name to clipboard
+29Lines changed: 29 additions & 0 deletions
@@ -25,6 +25,9 @@
 #include "env-inl.h"
 #include "node_errors.h"
 #include "node_external_reference.h"
+#ifdef DEBUG
+#include <node_process-inl.h>
+#endif
 #include "tracing/traced_value.h"
 #include "util-inl.h"
 
@@ -333,9 +336,12 @@ void AsyncWrap::EmitDestroy(bool from_gc) {
   // Ensure no double destroy is emitted via AsyncReset().
   async_id_ = kInvalidAsyncId;
 
-  if (!persistent().IsEmpty() && !from_gc) {
-    HandleScope handle_scope(env()->isolate());
-    USE(object()->Set(env()->context(), env()->resource_symbol(), object()));
+  if (!from_gc) {
+    if (!persistent().IsEmpty()) {
+      HandleScope handle_scope(env()->isolate());
+      USE(object()->Set(env()->context(), env()->resource_symbol(), object()));
+    }
+    context_frame_.Reset();
   }
 }
 
@@ -659,6 +665,14 @@ MaybeLocal<Value> AsyncWrap::MakeCallback(const Local<Function> cb,
                                           Local<Value>* argv) {
   EmitTraceEventBefore();
 
+#ifdef DEBUG
+  if (context_frame_.IsEmpty()) {
+    ProcessEmitWarning(env(),
+                       "MakeCallback() called without context_frame, "
+                       "likely use after destroy of AsyncWrap.");
+  }
+#endif
+
   ProviderType provider = provider_type();
   async_context context { get_async_id(), get_trigger_async_id() };
   MaybeLocal<Value> ret =
 
@@ -0,0 +1,29 @@
+// Flags: --expose-gc
+'use strict';
+
+const common = require('../common');
+const { onGC } = require('../common/gc');
+const assert = require('node:assert');
+const { AsyncLocalStorage } = require('node:async_hooks');
+const { freeParser, parsers, HTTPParser } = require('_http_common');
+
+let storeGCed = false;
+
+const als = new AsyncLocalStorage();
+
+function test() {
+  const store = {};
+  onGC(store, { ongc: common.mustCall(() => { storeGCed = true; }) });
+  let parser;
+  als.run(store, common.mustCall(() => {
+    parser = parsers.alloc();
+    parser.initialize(HTTPParser.RESPONSE, {});
+  }));
+  freeParser(parser);
+}
+
+test();
+global.gc();
+setImmediate(common.mustCall(() => {
+  assert.ok(storeGCed);
+}));