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

fix: do not throw on destroyed peers.

Browse Source
This commit is contained in:
Christopher Jeffrey 2014-06-06 06:37:47 -05:00
parent 28abd09845
commit 11b56e32d7
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
lib/bcoin/pool.js
View File

@ -285,7 +285,9 @@ Pool.prototype._addPeer = function _addPeer(backoff) {
peer.updateWatch(); peer.updateWatch();
self.tx.list.forEach(function(entry) { self.tx.list.forEach(function(entry) {
peer.broadcast(entry.tx)[0].once('request', function() { var result = peer.broadcast(entry.tx);
if (!result) return;
result[0].once('request', function() {
entry.e.emit('ack'); entry.e.emit('ack');
}); });
}); });
@ -703,7 +705,9 @@ Pool.prototype.sendTX = function sendTX(tx) {
this.tx.list.push(entry); this.tx.list.push(entry);
this.peers.block.forEach(function(peer) { this.peers.block.forEach(function(peer) {
peer.broadcast(tx)[0].once('request', function() { var result = peer.broadcast(tx);
if (!result) return;
result[0].once('request', function() {
e.emit('ack'); e.emit('ack');
}); });
}); });