File tree Expand file tree Collapse file tree 5 files changed +8
-19
lines changed
Expand file tree Collapse file tree 5 files changed +8
-19
lines changed Original file line number Diff line number Diff line change @@ -532,7 +532,7 @@ function emitAfterScript(asyncId) {
532532
533533function emitDestroyScript(asyncId) {
534534 // Return early if there are no destroy callbacks, or invalid asyncId.
535- if (!hasHooks(kDestroy) || asyncId <= 0 )
535+ if (!hasHooks(kDestroy) || !( asyncId > 0) )
536536 return;
537537 async_wrap.queueDestroyAsyncId(asyncId);
538538}
Original file line number Diff line number Diff line change @@ -27,7 +27,6 @@ const {
2727 getDefaultTriggerAsyncId,
2828 newAsyncId,
2929 initHooksExist,
30- destroyHooksExist,
3130 emitInit,
3231 emitBefore,
3332 emitAfter,
@@ -94,8 +93,7 @@ function processTicksAndRejections() {
9493 }
9594 }
9695 } finally {
97- if (destroyHooksExist())
98- emitDestroy(asyncId);
96+ emitDestroy(asyncId);
9997 }
10098
10199 emitAfter(asyncId);
Original file line number Diff line number Diff line change @@ -92,7 +92,6 @@ const {
9292 getDefaultTriggerAsyncId,
9393 newAsyncId,
9494 initHooksExist,
95- destroyHooksExist,
9695 // The needed emit*() functions.
9796 emitInit,
9897 emitBefore,
@@ -508,8 +507,7 @@ function getTimerCallbacks(runNextTicks) {
508507 } finally {
509508 immediate._onImmediate = null;
510509
511- if (destroyHooksExist())
512- emitDestroy(asyncId);
510+ emitDestroy(asyncId);
513511
514512 outstandingQueue.head = immediate = immediate._idleNext;
515513 }
@@ -585,8 +583,7 @@ function getTimerCallbacks(runNextTicks) {
585583 if (timer[kRefed])
586584 timeoutInfo[0]--;
587585
588- if (destroyHooksExist())
589- emitDestroy(asyncId);
586+ emitDestroy(asyncId);
590587 }
591588 continue;
592589 }
@@ -621,8 +618,7 @@ function getTimerCallbacks(runNextTicks) {
621618 if (timer[kRefed])
622619 timeoutInfo[0]--;
623620
624- if (destroyHooksExist())
625- emitDestroy(asyncId);
621+ emitDestroy(asyncId);
626622 }
627623 }
628624
Original file line number Diff line number Diff line change @@ -63,7 +63,6 @@ let timersPromises;
6363let timers;
6464
6565const {
66- destroyHooksExist,
6766 // The needed emit*() functions.
6867 emitDestroy,
6968} = require('internal/async_hooks');
@@ -78,9 +77,7 @@ function unenroll(item) {
7877 if (item[kHasPrimitive])
7978 delete knownTimersById[item[async_id_symbol]];
8079
81- // Fewer checks may be possible, but these cover everything.
82- if (destroyHooksExist() && item[async_id_symbol] !== undefined)
83- emitDestroy(item[async_id_symbol]);
80+ emitDestroy(item[async_id_symbol]);
8481
8582 L.remove(item);
8683
@@ -239,9 +236,7 @@ function clearImmediate(immediate) {
239236 }
240237 immediate[kRefed] = null;
241238
242- if (destroyHooksExist() && immediate[async_id_symbol] !== undefined) {
243- emitDestroy(immediate[async_id_symbol]);
244- }
239+ emitDestroy(immediate[async_id_symbol]);
245240
246241 immediate._onImmediate = null;
247242
Original file line number Diff line number Diff line change 11Error: test
22 at one (*fixtures*async-error.js:4:9)
33 at two (*fixtures*async-error.js:17:9)
4- at process.processTicksAndRejections (node:internal*process*task_queues:105 :5)
4+ at process.processTicksAndRejections (node:internal*process*task_queues:103 :5)
55 at async three (*fixtures*async-error.js:20:3)
66 at async four (*fixtures*async-error.js:24:3)
77 at async main (*async_error_nexttick_main.js:7:5)
You can’t perform that action at this time.
0 commit comments