async_wrap: clear destroy_ids vector

After processing all the callbacks in the destroy_ids vector make sure to clear() it otherwise the DestroyIdsCb() won't run again. PR-URL: #10400 Fixes: b49b496 "async_wrap: call destroy() callback in uv_idle_t" Reviewed-By: Ben Noordhuis <info@bnoordhuis.nl> Reviewed-By: Anna Henningsen <anna@addaleax.net>

Author: trevnorris

src/async-wrap.cc

@@ -199,7 +199,9 @@ void AsyncWrap::DestroyIdsCb(uv_idle_t* handle) {
 
  TryCatch try_catch(env->isolate());
 
- for (auto current_id : *env->destroy_ids_list()) {
+ std::vector<int64_t> destroy_ids_list;
+ destroy_ids_list.swap(*env->destroy_ids_list());
+ for (auto current_id : destroy_ids_list) {
  // Want each callback to be cleaned up after itself, instead of cleaning
  // them all up after the while() loop completes.
  HandleScope scope(env->isolate());
@@ -212,6 +214,8 @@ void AsyncWrap::DestroyIdsCb(uv_idle_t* handle) {
  FatalException(env->isolate(), try_catch);
  }
  }
+
+ env->destroy_ids_list()->clear();
 }
 
 

test/parallel/test-async-wrap-uid.js

@@ -5,15 +5,22 @@ const fs = require('fs');
 const assert = require('assert');
 const async_wrap = process.binding('async_wrap');
 
+// Give the event loop time to clear out the final uv_close().
+var si_cntr = 3;
+process.on('beforeExit', () => {
+ if (--si_cntr > 0) setImmediate(() => {});
+});
+
 const storage = new Map();
-async_wrap.setupHooks({ init, pre, post });
+async_wrap.setupHooks({ init, pre, post, destroy });
 async_wrap.enable();
 
 function init(uid) {
  storage.set(uid, {
  init: true,
  pre: false,
  post: false,
+ destroy: false,
  });
 }
 
@@ -25,6 +32,10 @@ function post(uid) {
  storage.get(uid).post = true;
 }
 
+function destroy(uid) {
+ storage.get(uid).destroy = true;
+}
+
 fs.access(__filename, function(err) {
  assert.ifError(err);
 });
@@ -46,6 +57,7 @@ process.once('exit', function() {
  init: true,
  pre: true,
  post: true,
+ destroy: true,
  });
  }
 });