summaryrefslogtreecommitdiff
path: root/lib/_http_outgoing.js
diff options
context:
space:
mode:
authorRobert Nagy <ronagy@icloud.com>2019-08-06 13:56:52 +0200
committerRich Trott <rtrott@gmail.com>2019-08-17 06:21:59 -0700
commit0daec61b9bdefbde1026f0dacb7ee38eb6a91771 (patch)
tree6597c5eb520cad876ded3c31c15c05d34df79a1b /lib/_http_outgoing.js
parent6f613d8abb05619e35c828b665a76215861bbf04 (diff)
downloadandroid-node-v8-0daec61b9bdefbde1026f0dacb7ee38eb6a91771.tar.gz
android-node-v8-0daec61b9bdefbde1026f0dacb7ee38eb6a91771.tar.bz2
android-node-v8-0daec61b9bdefbde1026f0dacb7ee38eb6a91771.zip
http: replace superfluous connection property with getter/setter
PR-URL: https://github.com/nodejs/node/pull/29015 Reviewed-By: Anna Henningsen <anna@addaleax.net> Reviewed-By: James M Snell <jasnell@gmail.com> Reviewed-By: Trivikram Kamat <trivikr.dev@gmail.com> Reviewed-By: Luigi Pinca <luigipinca@gmail.com> Reviewed-By: Rich Trott <rtrott@gmail.com>
Diffstat (limited to 'lib/_http_outgoing.js')
-rw-r--r--lib/_http_outgoing.js30
1 files changed, 19 insertions, 11 deletions
diff --git a/lib/_http_outgoing.js b/lib/_http_outgoing.js
index 2d2bbaa0e7..c56c6e4798 100644
--- a/lib/_http_outgoing.js
+++ b/lib/_http_outgoing.js
@@ -102,7 +102,6 @@ function OutgoingMessage() {
this[kIsCorked] = false;
this.socket = null;
- this.connection = null;
this._header = null;
this[kOutHeaders] = null;
@@ -157,6 +156,15 @@ Object.defineProperty(OutgoingMessage.prototype, '_headers', {
}, 'OutgoingMessage.prototype._headers is deprecated', 'DEP0066')
});
+Object.defineProperty(OutgoingMessage.prototype, 'connection', {
+ get: function() {
+ return this.socket;
+ },
+ set: function(val) {
+ this.socket = val;
+ }
+});
+
Object.defineProperty(OutgoingMessage.prototype, '_headerNames', {
get: internalUtil.deprecate(function() {
const headers = this[kOutHeaders];
@@ -273,7 +281,7 @@ OutgoingMessage.prototype._send = function _send(data, encoding, callback) {
OutgoingMessage.prototype._writeRaw = _writeRaw;
function _writeRaw(data, encoding, callback) {
- const conn = this.connection;
+ const conn = this.socket;
if (conn && conn.destroyed) {
// The socket was destroyed. If we're still trying to write to it,
// then we haven't gotten the 'close' event yet.
@@ -615,10 +623,10 @@ function write_(msg, chunk, encoding, callback, fromEnd) {
['string', 'Buffer'], chunk);
}
- if (!fromEnd && msg.connection && !msg[kIsCorked]) {
- msg.connection.cork();
+ if (!fromEnd && msg.socket && !msg[kIsCorked]) {
+ msg.socket.cork();
msg[kIsCorked] = true;
- process.nextTick(connectionCorkNT, msg, msg.connection);
+ process.nextTick(connectionCorkNT, msg, msg.socket);
}
var len, ret;
@@ -706,8 +714,8 @@ OutgoingMessage.prototype.end = function end(chunk, encoding, callback) {
else
this._contentLength = chunk.length;
}
- if (this.connection) {
- this.connection.cork();
+ if (this.socket) {
+ this.socket.cork();
uncork = true;
}
write_(this, chunk, encoding, null, true);
@@ -729,7 +737,7 @@ OutgoingMessage.prototype.end = function end(chunk, encoding, callback) {
}
if (uncork)
- this.connection.uncork();
+ this.socket.uncork();
this.finished = true;
@@ -737,8 +745,8 @@ OutgoingMessage.prototype.end = function end(chunk, encoding, callback) {
// everything to the socket.
debug('outgoing message end.');
if (this.outputData.length === 0 &&
- this.connection &&
- this.connection._httpMessage === this) {
+ this.socket &&
+ this.socket._httpMessage === this) {
this._finish();
}
@@ -747,7 +755,7 @@ OutgoingMessage.prototype.end = function end(chunk, encoding, callback) {
OutgoingMessage.prototype._finish = function _finish() {
- assert(this.connection);
+ assert(this.socket);
this.emit('prefinish');
};