From dbb0d2612c3b6705559817bffbce319b24fdfc51 Mon Sep 17 00:00:00 2001 From: Robert Nagy Date: Tue, 13 Apr 2021 00:54:24 +0200 Subject: [PATCH] stream: fix multiple Writable.destroy() calls Calling Writable.destroy() multiple times in the same tick could cause an assertion error. Fixes: https://github.com/nodejs/node/issues/38189 PR-URL: https://github.com/nodejs/node/pull/38221 Reviewed-By: Matteo Collina Reviewed-By: Luigi Pinca Reviewed-By: Nitzan Uziely Reviewed-By: Rich Trott Backport-PR-URL: https://github.com/nodejs/node/pull/38473 --- lib/internal/streams/writable.js | 1 + test/parallel/test-stream-writable-destroy.js | 11 +++++++++++ 2 files changed, 12 insertions(+) diff --git a/lib/internal/streams/writable.js b/lib/internal/streams/writable.js index e6cfa0dc6629af..421836f34414d7 100644 --- a/lib/internal/streams/writable.js +++ b/lib/internal/streams/writable.js @@ -778,6 +778,7 @@ ObjectDefineProperties(Writable.prototype, { const destroy = destroyImpl.destroy; Writable.prototype.destroy = function(err, cb) { const state = this._writableState; + if (!state.destroyed) { process.nextTick(errorBuffer, state, new ERR_STREAM_DESTROYED('write')); } diff --git a/test/parallel/test-stream-writable-destroy.js b/test/parallel/test-stream-writable-destroy.js index 9f6136923ee176..f3ca402d5b3f94 100644 --- a/test/parallel/test-stream-writable-destroy.js +++ b/test/parallel/test-stream-writable-destroy.js @@ -417,3 +417,14 @@ const assert = require('assert'); })); write.write('asd'); } + +{ + // Destroy twice + const write = new Writable({ + write(chunk, enc, cb) { cb(); } + }); + + write.end(common.mustCall()); + write.destroy(); + write.destroy(); +}