Commit 2ddbbfd
http: cork/uncork before flushing pipelined res
Make sure that the pipelined response data will be written as less TCP
packets as possible.
PR-URL: #3172
Reviewed-By: Brian White <mscdex@mscdex.net>
Reviewed-By: Trevor Norris <trev.norris@gmail.com>1 parent 660f759 commit 2ddbbfd
1 file changed
Lines changed: 4 additions & 0 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -157,10 +157,12 @@ OutgoingMessage.prototype._writeRaw = function(data, encoding, callback) { | |||
| 157 | 157 | var output = this.output; | |
| 158 | 158 | var outputEncodings = this.outputEncodings; | |
| 159 | 159 | var outputCallbacks = this.outputCallbacks; | |
| 160 | + connection.cork(); | ||
| 160 | 161 | for (var i = 0; i < outputLength; i++) { | |
| 161 | 162 | connection.write(output[i], outputEncodings[i], | |
| 162 | 163 | outputCallbacks[i]); | |
| 163 | 164 | } | |
| 165 | + connection.uncork(); | ||
| 164 | 166 | ||
| 165 | 167 | this.output = []; | |
| 166 | 168 | this.outputEncodings = []; | |
@@ -637,10 +639,12 @@ OutgoingMessage.prototype._flush = function() { | |||
| 637 | 639 | var output = this.output; | |
| 638 | 640 | var outputEncodings = this.outputEncodings; | |
| 639 | 641 | var outputCallbacks = this.outputCallbacks; | |
| 642 | + socket.cork(); | ||
| 640 | 643 | for (var i = 0; i < outputLength; i++) { | |
| 641 | 644 | ret = socket.write(output[i], outputEncodings[i], | |
| 642 | 645 | outputCallbacks[i]); | |
| 643 | 646 | } | |
| 647 | + socket.uncork(); | ||
| 644 | 648 | ||
| 645 | 649 | this.output = []; | |
| 646 | 650 | this.outputEncodings = []; | |
0 commit comments