summaryrefslogtreecommitdiff
path: root/lib
diff options
context:
space:
mode:
authorRobert Nagy <ronagy@icloud.com>2020-04-16 20:48:41 +0200
committerRobert Nagy <ronagy@icloud.com>2020-04-18 21:10:40 +0200
commitfd10be4b5456c867dd68bb9b3c16ed53a68c461f (patch)
tree6f1b40f180cdd2317ae02ce10f928194c9570e59 /lib
parent73f3072ffb1256f013ffd75f479060029675b7a3 (diff)
downloadnode-new-fd10be4b5456c867dd68bb9b3c16ed53a68c461f.tar.gz
stream: inline unbuffered _write
PR-URL: https://github.com/nodejs/node/pull/32886 Reviewed-By: Anna Henningsen <anna@addaleax.net> Reviewed-By: Luigi Pinca <luigipinca@gmail.com> Reviewed-By: Zeyu Yang <himself65@outlook.com> Reviewed-By: Ruben Bridgewater <ruben@bridgewater.de>
Diffstat (limited to 'lib')
-rw-r--r--lib/_stream_writable.js7
1 files changed, 6 insertions, 1 deletions
diff --git a/lib/_stream_writable.js b/lib/_stream_writable.js
index 2b36a765e5..eb88a36185 100644
--- a/lib/_stream_writable.js
+++ b/lib/_stream_writable.js
@@ -364,7 +364,12 @@ function writeOrBuffer(stream, state, chunk, encoding, cb) {
}
state.bufferedRequestCount += 1;
} else {
- doWrite(stream, state, false, len, chunk, encoding, cb);
+ state.writelen = len;
+ state.writecb = cb;
+ state.writing = true;
+ state.sync = true;
+ stream._write(chunk, encoding, state.onwrite);
+ state.sync = false;
}
// Return false if errored or destroyed in order to break