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

peer address and port.

Browse Source
This commit is contained in:
Christopher Jeffrey 2015-12-22 03:17:49 -08:00
parent 68c16b214a
commit a6e3024e9b
1 changed files with 5 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
lib/bcoin/peer.js
View File

@ -11,6 +11,7 @@ var bcoin = require('../bcoin');
var utils = bcoin.utils; var utils = bcoin.utils;
var assert = utils.assert; var assert = utils.assert;
var constants = bcoin.protocol.constants; var constants = bcoin.protocol.constants;
var network = bcoin.protocol.network;
// Browserify, I'm looking at you // Browserify, I'm looking at you
try { try {
@ -41,6 +42,8 @@ function Peer(pool, createSocket, options) {
this.destroyed = false; this.destroyed = false;
this.ack = false; this.ack = false;
this.ts = this.options.ts || 0; this.ts = this.options.ts || 0;
this.address = '0.0.0.0';
this.port = network.port;
if (this.options.backoff) { if (this.options.backoff) {
setTimeout(function() { setTimeout(function() {
@ -79,15 +82,13 @@ function Peer(pool, createSocket, options) {
inherits(Peer, EventEmitter); inherits(Peer, EventEmitter);
Peer.prototype.__defineGetter__('address', function() {
return this.socket && (this.socket.remoteAddress || '0.0.0.0');
});
Peer.prototype._init = function init() { Peer.prototype._init = function init() {
var self = this; var self = this;
this.socket.once('connect', function() { this.socket.once('connect', function() {
self.ts = Date.now() / 1000 | 0; self.ts = Date.now() / 1000 | 0;
self.address = self.socket.remoteAddress;
self.port = self.socket.remotePort;
}); });
this.socket.once('error', function(err) { this.socket.once('error', function(err) {
@ -115,8 +116,6 @@ Peer.prototype._init = function init() {
self.pool.emit('debug', self.pool.emit('debug',
'Sent version (%s): height=%s', 'Sent version (%s): height=%s',
self.address, this.pool.chain.getStartHeight()); self.address, this.pool.chain.getStartHeight());
// self.pool.emit('debug', 'version (%s): sending locator hashes', ip);
// self.loadBlocks(self.chain.locatorHashes(), 0);
}); });
} }