mirror of
https://github.com/Xahau/xahau.js.git
synced 2025-11-21 12:45:50 +00:00
JS: Fixes for load and add announcing load.
This commit is contained in:
committed by
Stefan Thomas
parent
1930baa9ca
commit
2604670cc2
@@ -219,7 +219,7 @@ var Remote = function (opts, trace) {
|
|||||||
this.retry = undefined;
|
this.retry = undefined;
|
||||||
|
|
||||||
this._load_base = 256;
|
this._load_base = 256;
|
||||||
this._load_fee = 256;
|
this._load_factor = 1.0;
|
||||||
this._fee_ref = undefined;
|
this._fee_ref = undefined;
|
||||||
this._fee_base = undefined;
|
this._fee_base = undefined;
|
||||||
this._reserve_base = undefined;
|
this._reserve_base = undefined;
|
||||||
@@ -574,6 +574,16 @@ Remote.prototype._connect_message = function (ws, json) {
|
|||||||
Remote.online_states.indexOf(message.server_status) !== -1
|
Remote.online_states.indexOf(message.server_status) !== -1
|
||||||
? 'online'
|
? 'online'
|
||||||
: 'offline');
|
: 'offline');
|
||||||
|
|
||||||
|
if ('load_base' in message
|
||||||
|
&& 'load_factor' in message
|
||||||
|
&& (message.load_base !== self._load_base || message.load_factor != self._load_factor))
|
||||||
|
{
|
||||||
|
self._load_base = message.load_base;
|
||||||
|
self._load_factor = message.load_factor;
|
||||||
|
|
||||||
|
this.emit('load', { 'load_base' : self._load_base, 'load_factor' : self.load_factor });
|
||||||
|
}
|
||||||
break;
|
break;
|
||||||
|
|
||||||
// All other messages
|
// All other messages
|
||||||
@@ -917,7 +927,7 @@ Remote.prototype._server_subscribe = function () {
|
|||||||
|
|
||||||
// FIXME Use this to estimate fee.
|
// FIXME Use this to estimate fee.
|
||||||
self._load_base = message.load_base || 256;
|
self._load_base = message.load_base || 256;
|
||||||
self._load_fee = message.load_fee || 256;
|
self._load_factor = message.load_factor || 1.0;
|
||||||
self._fee_ref = message.fee_ref;
|
self._fee_ref = message.fee_ref;
|
||||||
self._fee_base = message.fee_base;
|
self._fee_base = message.fee_base;
|
||||||
self._reserve_base = message.reverse_base;
|
self._reserve_base = message.reverse_base;
|
||||||
|
|||||||
Reference in New Issue
Block a user