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

Merge pull request #123 from mnaamani/fix-pool-broadcast-item

Browse Source 
pool: fix BroadcastItem multiple reject methods
This commit is contained in:
Christopher Jeffrey (JJ) 2017-01-25 13:35:31 -08:00 committed by GitHub
commit 2552b3fca3
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
lib/net/pool.js
View File

@ -763,7 +763,7 @@ Pool.prototype.getBroadcasted = function getBroadcasted(peer, item) {
item.hasWitness() ? 'witness' : 'normal', item.hasWitness() ? 'witness' : 'normal',
peer.hostname()); peer.hostname());
entry.ack(peer); entry.handleAck(peer);
return entry.msg; return entry.msg;
}; };
@ -2180,7 +2180,7 @@ Pool.prototype.handleReject = co(function* handleReject(peer, packet) {
if (!entry) if (!entry)
return; return;
entry.reject(peer); entry.handleReject(peer);
}); });
/** /**
@ -3879,7 +3879,7 @@ BroadcastItem.prototype.resolve = function resolve() {
* @param {Peer} peer * @param {Peer} peer
*/ */
BroadcastItem.prototype.ack = function ack(peer) { BroadcastItem.prototype.handleAck = function handleAck(peer) {
var self = this; var self = this;
var i, job; var i, job;
@ -3900,7 +3900,7 @@ BroadcastItem.prototype.ack = function ack(peer) {
* @param {Peer} peer * @param {Peer} peer
*/ */
BroadcastItem.prototype.reject = function reject(peer) { BroadcastItem.prototype.handleReject = function handleReject(peer) {
var i, job; var i, job;
this.emit('reject', peer); this.emit('reject', peer);