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

pool: fix BroadcastItem multiple reject methods

Browse Source
This commit is contained in:
Mokhtar Naamani 2017-01-25 21:20:16 +02:00
parent b8324e0b09
commit e1147cdf3d
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;
}; };
@ -2177,7 +2177,7 @@ Pool.prototype.handleReject = co(function* handleReject(peer, packet) {
if (!entry) if (!entry)
return; return;
entry.reject(peer); entry.handleReject(peer);
}); });
/** /**
@ -3840,7 +3840,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;
@ -3861,7 +3861,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);