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

pool: minor.

Browse Source
This commit is contained in:
Christopher Jeffrey 2017-01-21 13:20:44 -08:00
parent 545c0004e9
commit dc839062bf
No known key found for this signature in database
GPG Key ID: 8962AB9DE6666BBD
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
lib/net/pool.js
View File

@ -1075,14 +1075,14 @@ Pool.prototype.handlePacket = co(function* handlePacket(peer, packet) {
* @param {Peer} peer * @param {Peer} peer
*/ */
Pool.prototype.handleConnect = function handleConnect(peer) { Pool.prototype.handleConnect = co(function* handleConnect(peer) {
this.logger.info('Connected to %s.', peer.hostname()); this.logger.info('Connected to %s.', peer.hostname());
if (peer.outbound) if (peer.outbound)
this.hosts.markSuccess(peer.hostname()); this.hosts.markSuccess(peer.hostname());
this.emit('peer connect', peer); this.emit('peer connect', peer);
}; });
/** /**
* Handle peer open event. * Handle peer open event.
@ -1090,7 +1090,7 @@ Pool.prototype.handleConnect = function handleConnect(peer) {
* @param {Peer} peer * @param {Peer} peer
*/ */
Pool.prototype.handleOpen = function handleOpen(peer) { Pool.prototype.handleOpen = co(function* handleOpen(peer) {
// Advertise our address. // Advertise our address.
if (!this.address.isNull() if (!this.address.isNull()
&& !this.options.selfish && !this.options.selfish
@ -1141,7 +1141,7 @@ Pool.prototype.handleOpen = function handleOpen(peer) {
} }
this.emit('peer open', peer); this.emit('peer open', peer);
}; });
/** /**
* Handle peer close event. * Handle peer close event.
@ -1178,10 +1178,10 @@ Pool.prototype.handleClose = co(function* handleClose(peer, connected) {
* @param {Peer} peer * @param {Peer} peer
*/ */
Pool.prototype.handleBan = function handleBan(peer) { Pool.prototype.handleBan = co(function* handleBan(peer) {
this.ban(peer.address); this.ban(peer.address);
this.emit('ban', peer); this.emit('ban', peer);
}; });
/** /**
* Handle peer version event. * Handle peer version event.