RanchiMall/fcoin
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

prevent buffered _writes from binding thousands of events.

Browse Source
This commit is contained in:
Christopher Jeffrey 2015-12-19 02:52:51 -08:00
parent a96f27682f
commit cb2bcc21c6
1 changed files with 14 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
lib/bcoin/peer.js
View File

@ -244,13 +244,24 @@ Peer.prototype.destroy = function destroy() {
// Private APIs // Private APIs
Peer.prototype._write = function write(chunk) { Peer.prototype._write = function write(chunk) {
var self = this;
if (this.destroyed) if (this.destroyed)
return; return;
if (!this.socket) { if (!this.socket) {
return this.once('socket', function() { if (!this._bchunks) {
this._write(chunk); this._bchunks = [];
}); this.once('socket', function() {
var chunks = self._bchunks;
delete self._bchunks;
chunks.forEach(function(chunk) {
self._write(chunk);
});
});
}
this._bchunks.push(chunk);
return;
} }
if (NodeBuffer) if (NodeBuffer)