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

pool: when proxying peer->pool events. pass peer as the 2nd arg.

Browse Source 
Signed-off-by: Fedor Indutny <fedor@indutny.com>
This commit is contained in:
Christopher Jeffrey 2014-05-18 03:59:09 -05:00 committed by Fedor Indutny
parent 01409b34af
commit 2ab9334b4b
1 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
lib/bcoin/pool.js
View File

@ -289,13 +289,13 @@ Pool.prototype._addPeer = function _addPeer(backoff) {
self._response(block); self._response(block);
self.chain.add(block); self.chain.add(block);
self.emit('chain-progress', self.chain.fillPercent()); self.emit('chain-progress', self.chain.fillPercent(), peer);
self.emit('block', block); self.emit('block', block, peer);
}); });
// Just FYI // Just FYI
peer.on('reject', function(payload) { peer.on('reject', function(payload) {
self.emit('reject', payload); self.emit('reject', payload, peer);
}); });
peer.on('notfound', function(items) { peer.on('notfound', function(items) {
@ -308,19 +308,19 @@ Pool.prototype._addPeer = function _addPeer(backoff) {
peer.on('tx', function(tx) { peer.on('tx', function(tx) {
self._response(tx); self._response(tx);
self.emit('tx', tx); self.emit('tx', tx, peer);
}); });
peer.on('addr', function(addr) { peer.on('addr', function(addr) {
self.emit('addr', addr); self.emit('addr', addr, peer);
}); });
peer.on('blocks', function(blocks) { peer.on('blocks', function(blocks) {
self.emit('blocks', blocks); self.emit('blocks', blocks, peer);
}); });
peer.on('txs', function(txs) { peer.on('txs', function(txs) {
self.emit('txs', txs); self.emit('txs', txs, peer);
}); });
}; };