removed latest filter
This commit is contained in:
parent
ef17dec195
commit
2ac7cba9f4
50
lib/node.js
50
lib/node.js
@ -40,7 +40,7 @@ var socket = new Socket(process.env.WS_SERVER || 'ws://localhost:3000');
|
|||||||
var WS_SECRET = process.env.WS_SECRET || "eth-net-stats-has-a-secret";
|
var WS_SECRET = process.env.WS_SECRET || "eth-net-stats-has-a-secret";
|
||||||
|
|
||||||
var PENDING_WORKS = true;
|
var PENDING_WORKS = true;
|
||||||
var MAX_BLOCKS_HISTORY = 36;
|
var MAX_BLOCKS_HISTORY = 40;
|
||||||
var UPDATE_INTERVAL = 5000;
|
var UPDATE_INTERVAL = 5000;
|
||||||
var PING_INTERVAL = 2000;
|
var PING_INTERVAL = 2000;
|
||||||
var MINERS_LIMIT = 5;
|
var MINERS_LIMIT = 5;
|
||||||
@ -514,32 +514,32 @@ Node.prototype.setWatches = function()
|
|||||||
console.error(err);
|
console.error(err);
|
||||||
}
|
}
|
||||||
|
|
||||||
try {
|
// try {
|
||||||
this.chainFilter = web3.eth.filter('latest');
|
// this.chainFilter = web3.eth.filter('latest');
|
||||||
this.chainFilter.watch(function(log)
|
// this.chainFilter.watch(function(log)
|
||||||
{
|
// {
|
||||||
var now = (new Date()).getTime();
|
// var now = (new Date()).getTime();
|
||||||
var time = now - self._lastLatestLog;
|
// var time = now - self._lastLatestLog;
|
||||||
|
|
||||||
if(time > 50)
|
// if(time > 50)
|
||||||
{
|
// {
|
||||||
self.update();
|
// self.update();
|
||||||
}
|
// }
|
||||||
else
|
// else
|
||||||
{
|
// {
|
||||||
debounce(function() {
|
// debounce(function() {
|
||||||
self.update();
|
// self.update();
|
||||||
}, 50);
|
// }, 50);
|
||||||
}
|
// }
|
||||||
|
|
||||||
self._lastLatestLog = now;
|
// self._lastLatestLog = now;
|
||||||
});
|
// });
|
||||||
}
|
// }
|
||||||
catch (err)
|
// catch (err)
|
||||||
{
|
// {
|
||||||
console.error("Couldn't set up chain filter");
|
// console.error("Couldn't set up chain filter");
|
||||||
console.error(err);
|
// console.error(err);
|
||||||
}
|
// }
|
||||||
|
|
||||||
this.updateInterval = setInterval(function(){
|
this.updateInterval = setInterval(function(){
|
||||||
self.update();
|
self.update();
|
||||||
|
Loading…
Reference in New Issue
Block a user