diff options
author | cjihrig <cjihrig@gmail.com> | 2019-10-25 21:17:06 -0400 |
---|---|---|
committer | cjihrig <cjihrig@gmail.com> | 2019-10-30 10:32:46 -0400 |
commit | 11276af5dd60354af3db1b578804ca3839044420 (patch) | |
tree | 686a95cea72d99e72d75dda62a568e4db686c85c /lib/_http_incoming.js | |
parent | 8fa4abdf23abb09bd19dfb9a358a70d90672231e (diff) | |
download | android-node-v8-11276af5dd60354af3db1b578804ca3839044420.tar.gz android-node-v8-11276af5dd60354af3db1b578804ca3839044420.tar.bz2 android-node-v8-11276af5dd60354af3db1b578804ca3839044420.zip |
http: support readable hwm in IncomingMessage
This commit causes http.IncomingMessage instances to set their
readableHighWaterMark value the same value used in the underlying
socket.
PR-URL: https://github.com/nodejs/node/pull/30135
Fixes: https://github.com/nodejs/node/issues/30107
Reviewed-By: Anna Henningsen <anna@addaleax.net>
Reviewed-By: Luigi Pinca <luigipinca@gmail.com>
Reviewed-By: Yongsheng Zhang <zyszys98@gmail.com>
Reviewed-By: Trivikram Kamat <trivikr.dev@gmail.com>
Diffstat (limited to 'lib/_http_incoming.js')
-rw-r--r-- | lib/_http_incoming.js | 10 |
1 files changed, 9 insertions, 1 deletions
diff --git a/lib/_http_incoming.js b/lib/_http_incoming.js index ad3699cc44..3e8bd69c04 100644 --- a/lib/_http_incoming.js +++ b/lib/_http_incoming.js @@ -37,7 +37,15 @@ function readStop(socket) { /* Abstract base class for ServerRequest and ClientResponse. */ function IncomingMessage(socket) { - Stream.Readable.call(this); + let streamOptions; + + if (socket) { + streamOptions = { + highWaterMark: socket.readableHighWaterMark + }; + } + + Stream.Readable.call(this, streamOptions); this._readableState.readingMore = true; |