summaryrefslogtreecommitdiff
path: root/lib/_http_outgoing.js
diff options
context:
space:
mode:
authorRobert Nagy <ronagy@icloud.com>2019-08-06 15:46:34 +0200
committerRich Trott <rtrott@gmail.com>2019-08-09 15:55:35 -0700
commitc065773cc56080b48ff4e29822152679f7db5573 (patch)
tree608105d4c6992a1c6eefc9ad63b9adbf5ca3f339 /lib/_http_outgoing.js
parent53e467db24310a09772cd71fb6616239e950dd72 (diff)
downloadandroid-node-v8-c065773cc56080b48ff4e29822152679f7db5573.tar.gz
android-node-v8-c065773cc56080b48ff4e29822152679f7db5573.tar.bz2
android-node-v8-c065773cc56080b48ff4e29822152679f7db5573.zip
http: buffer writes even while no socket assigned
PR-URL: https://github.com/nodejs/node/pull/29019 Reviewed-By: Luigi Pinca <luigipinca@gmail.com> Reviewed-By: Matteo Collina <matteo.collina@gmail.com>
Diffstat (limited to 'lib/_http_outgoing.js')
-rw-r--r--lib/_http_outgoing.js4
1 files changed, 3 insertions, 1 deletions
diff --git a/lib/_http_outgoing.js b/lib/_http_outgoing.js
index ef7c8c6577..e10f068f32 100644
--- a/lib/_http_outgoing.js
+++ b/lib/_http_outgoing.js
@@ -23,6 +23,7 @@
const { Object, ObjectPrototype } = primordials;
+const { getDefaultHighWaterMark } = require('internal/streams/state');
const assert = require('internal/assert');
const Stream = require('stream');
const internalUtil = require('internal/util');
@@ -51,6 +52,7 @@ const {
} = require('internal/errors');
const { validateString } = require('internal/validators');
+const HIGH_WATER_MARK = getDefaultHighWaterMark();
const { CRLF, debug } = common;
const kIsCorked = Symbol('isCorked');
@@ -277,7 +279,7 @@ function _writeRaw(data, encoding, callback) {
this.outputData.push({ data, encoding, callback });
this.outputSize += data.length;
this._onPendingData(data.length);
- return false;
+ return this.outputSize < HIGH_WATER_MARK;
}