diff --git a/lib/async_hooks.js b/lib/async_hooks.js index 354fb1114f..d5d5407b1d 100644 --- a/lib/async_hooks.js +++ b/lib/async_hooks.js @@ -43,7 +43,7 @@ const { kInit, kBefore, kAfter, kDestroy, kCurrentAsyncId, kCurrentTriggerId, const { async_id_symbol, trigger_id_symbol } = async_wrap; -// Used in AsyncHook and AsyncEvent. +// Used in AsyncHook and AsyncResource. const init_symbol = Symbol('init'); const before_symbol = Symbol('before'); const after_symbol = Symbol('after'); @@ -192,7 +192,7 @@ function triggerId() { // Embedder API // -class AsyncEvent { +class AsyncResource { constructor(type, triggerId) { this[async_id_symbol] = ++async_uid_fields[kAsyncUidCntr]; // Read and reset the current kInitTriggerId so that when the constructor @@ -480,7 +480,7 @@ module.exports = { currentId, triggerId, // Embedder API - AsyncEvent, + AsyncResource, runInAsyncIdScope, // Sensitive Embedder API newUid, diff --git a/test/async-hooks/test-embedder.api.async-event.after-on-destroyed.js b/test/async-hooks/test-embedder.api.async-event.after-on-destroyed.js index c5d52a362d..eb4772d5f6 100644 --- a/test/async-hooks/test-embedder.api.async-event.after-on-destroyed.js +++ b/test/async-hooks/test-embedder.api.async-event.after-on-destroyed.js @@ -3,7 +3,7 @@ const common = require('../common'); const assert = require('assert'); const async_hooks = require('async_hooks'); -const { AsyncEvent } = async_hooks; +const { AsyncResource } = async_hooks; const { spawn } = require('child_process'); const corruptedMsg = /async hook stack has become corrupted/; const heartbeatMsg = /heartbeat: still alive/; @@ -17,13 +17,13 @@ if (process.argv[2] === 'child') { // once 'destroy' has been emitted, we can no longer emit 'after' // Emitting 'before', 'after' and then 'destroy' - const event1 = new AsyncEvent('event1', async_hooks.currentId()); + const event1 = new AsyncResource('event1', async_hooks.currentId()); event1.emitBefore(); event1.emitAfter(); event1.emitDestroy(); // Emitting 'after' after 'destroy' - const event2 = new AsyncEvent('event2', async_hooks.currentId()); + const event2 = new AsyncResource('event2', async_hooks.currentId()); event2.emitDestroy(); console.log('heartbeat: still alive'); diff --git a/test/async-hooks/test-embedder.api.async-event.before-on-destroyed.js b/test/async-hooks/test-embedder.api.async-event.before-on-destroyed.js index 4cd98b2561..3466e63777 100644 --- a/test/async-hooks/test-embedder.api.async-event.before-on-destroyed.js +++ b/test/async-hooks/test-embedder.api.async-event.before-on-destroyed.js @@ -3,7 +3,7 @@ const common = require('../common'); const assert = require('assert'); const async_hooks = require('async_hooks'); -const { AsyncEvent } = async_hooks; +const { AsyncResource } = async_hooks; const { spawn } = require('child_process'); const corruptedMsg = /async hook stack has become corrupted/; const heartbeatMsg = /heartbeat: still alive/; @@ -17,13 +17,13 @@ if (process.argv[2] === 'child') { // once 'destroy' has been emitted, we can no longer emit 'before' // Emitting 'before', 'after' and then 'destroy' - const event1 = new AsyncEvent('event1', async_hooks.currentId()); + const event1 = new AsyncResource('event1', async_hooks.currentId()); event1.emitBefore(); event1.emitAfter(); event1.emitDestroy(); // Emitting 'before' after 'destroy' - const event2 = new AsyncEvent('event2', async_hooks.currentId()); + const event2 = new AsyncResource('event2', async_hooks.currentId()); event2.emitDestroy(); console.log('heartbeat: still alive'); diff --git a/test/async-hooks/test-embedder.api.async-event.improper-order.js b/test/async-hooks/test-embedder.api.async-event.improper-order.js index 841ca1d136..1d3b8c6b89 100644 --- a/test/async-hooks/test-embedder.api.async-event.improper-order.js +++ b/test/async-hooks/test-embedder.api.async-event.improper-order.js @@ -3,7 +3,7 @@ const common = require('../common'); const assert = require('assert'); const async_hooks = require('async_hooks'); -const { AsyncEvent } = async_hooks; +const { AsyncResource } = async_hooks; const { spawn } = require('child_process'); const corruptedMsg = /async hook stack has become corrupted/; const heartbeatMsg = /heartbeat: still alive/; @@ -17,13 +17,13 @@ if (process.argv[2] === 'child') { // async hooks enforce proper order of 'before' and 'after' invocations // Proper ordering - const event1 = new AsyncEvent('event1', async_hooks.currentId()); + const event1 = new AsyncResource('event1', async_hooks.currentId()); event1.emitBefore(); event1.emitAfter(); // Improper ordering // Emitting 'after' without 'before' which is illegal - const event2 = new AsyncEvent('event2', async_hooks.currentId()); + const event2 = new AsyncResource('event2', async_hooks.currentId()); console.log('heartbeat: still alive'); event2.emitAfter(); diff --git a/test/async-hooks/test-embedder.api.async-event.improper-unwind.js b/test/async-hooks/test-embedder.api.async-event.improper-unwind.js index fe58185c79..1e50cea424 100644 --- a/test/async-hooks/test-embedder.api.async-event.improper-unwind.js +++ b/test/async-hooks/test-embedder.api.async-event.improper-unwind.js @@ -3,7 +3,7 @@ const common = require('../common'); const assert = require('assert'); const async_hooks = require('async_hooks'); -const { AsyncEvent } = async_hooks; +const { AsyncResource } = async_hooks; const { spawn } = require('child_process'); const corruptedMsg = /async hook stack has become corrupted/; const heartbeatMsg = /heartbeat: still alive/; @@ -21,8 +21,8 @@ if (process.argv[2] === 'child') { // The first test of the two below follows that rule, // the second one doesnt. - const event1 = new AsyncEvent('event1', async_hooks.currentId()); - const event2 = new AsyncEvent('event2', async_hooks.currentId()); + const event1 = new AsyncResource('event1', async_hooks.currentId()); + const event2 = new AsyncResource('event2', async_hooks.currentId()); // Proper unwind event1.emitBefore(); diff --git a/test/async-hooks/test-embedder.api.async-event.js b/test/async-hooks/test-embedder.api.async-event.js index dd9a8a8191..ea9cd8bbb8 100644 --- a/test/async-hooks/test-embedder.api.async-event.js +++ b/test/async-hooks/test-embedder.api.async-event.js @@ -4,7 +4,7 @@ const common = require('../common'); const assert = require('assert'); const tick = require('./tick'); const async_hooks = require('async_hooks'); -const { AsyncEvent } = async_hooks; +const { AsyncResource } = async_hooks; const initHooks = require('./init-hooks'); const { checkInvocations } = require('./hook-checks'); @@ -15,7 +15,7 @@ hooks.enable(); // create first custom event 'alcazares' with triggerId derived // from async_hooks currentId const alcaTriggerId = async_hooks.currentId(); -const alcaEvent = new AsyncEvent('alcazares', alcaTriggerId); +const alcaEvent = new AsyncResource('alcazares', alcaTriggerId); const alcazaresActivities = hooks.activitiesOfTypes([ 'alcazares' ]); // alcazares event was constructed and thus only has an `init` call @@ -49,7 +49,7 @@ function tick1() { // The below shows that we can pass any number as a trigger id const pobTriggerId = 111; - const pobEvent = new AsyncEvent('poblado', pobTriggerId); + const pobEvent = new AsyncResource('poblado', pobTriggerId); const pobladoActivities = hooks.activitiesOfTypes([ 'poblado' ]); const poblado = pobladoActivities[0]; assert.strictEqual(poblado.type, 'poblado', 'poblado');