-
Notifications
You must be signed in to change notification settings - Fork 29.8k
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
test: check destroy hooks are called before exit
Verify that the destroy callback for a TCP server is called before exit if it is closed in another destroy callback. Fixes: #13262 PR-URL: #13369 Reviewed-By: Trevor Norris <[email protected]> Reviewed-By: Andreas Madsen <[email protected]>
- Loading branch information
1 parent
1e44fd9
commit 78b1358
Showing
2 changed files
with
64 additions
and
0 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,37 @@ | ||
'use strict'; | ||
// Test that async ids that are added to the destroy queue while running a | ||
// `destroy` callback are handled correctly. | ||
|
||
const common = require('../common'); | ||
const assert = require('assert'); | ||
const async_hooks = require('async_hooks'); | ||
|
||
const initCalls = new Set(); | ||
let destroyResCallCount = 0; | ||
let res2; | ||
|
||
async_hooks.createHook({ | ||
init: common.mustCallAtLeast((id, provider, triggerId) => { | ||
if (provider === 'foobar') | ||
initCalls.add(id); | ||
}, 2), | ||
destroy: common.mustCallAtLeast((id) => { | ||
if (!initCalls.has(id)) return; | ||
|
||
switch (destroyResCallCount++) { | ||
case 0: | ||
// Trigger the second `destroy` call. | ||
res2.emitDestroy(); | ||
break; | ||
case 2: | ||
assert.fail('More than 2 destroy() invocations'); | ||
break; | ||
} | ||
}, 2) | ||
}).enable(); | ||
|
||
const res1 = new async_hooks.AsyncResource('foobar'); | ||
res2 = new async_hooks.AsyncResource('foobar'); | ||
res1.emitDestroy(); | ||
|
||
process.on('exit', () => assert.strictEqual(destroyResCallCount, 2)); |
27 changes: 27 additions & 0 deletions
27
test/parallel/test-async-hooks-top-level-clearimmediate.js
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,27 @@ | ||
'use strict'; | ||
|
||
// Regression test for https://github.com/nodejs/node/issues/13262 | ||
|
||
const common = require('../common'); | ||
const assert = require('assert'); | ||
const async_hooks = require('async_hooks'); | ||
|
||
let seenId, seenResource; | ||
|
||
async_hooks.createHook({ | ||
init: common.mustCall((id, provider, triggerId, resource) => { | ||
seenId = id; | ||
seenResource = resource; | ||
assert.strictEqual(provider, 'Immediate'); | ||
assert.strictEqual(triggerId, 1); | ||
}), | ||
before: common.mustNotCall(), | ||
after: common.mustNotCall(), | ||
destroy: common.mustCall((id) => { | ||
assert.strictEqual(seenId, id); | ||
}) | ||
}).enable(); | ||
|
||
const immediate = setImmediate(common.mustNotCall()); | ||
assert.strictEqual(immediate, seenResource); | ||
clearImmediate(immediate); |