machankura/mempool
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge pull request #5178 from mempool/mononaut/fix-reorg-health-check

Browse Source 
Recover from esplora failover after a reorg to lower height
This commit is contained in:
wiz 2024-06-23 18:35:19 +09:00 committed by GitHub
commit 172fb0bf41
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
backend/src/api/bitcoin/esplora-api.ts
View File

@ -94,12 +94,12 @@ class FailoverRouter {
); );
if (result) { if (result) {
const height = result.data; const height = result.data;
this.maxHeight = Math.max(height || 0, ...this.hosts.map(host => (!(host.unreachable || host.timedOut || host.outOfSync) ? host.latestHeight || 0 : 0))); host.latestHeight = height;
this.maxHeight = Math.max(height || 0, ...this.hosts.map(h => (!(h.unreachable || h.timedOut || h.outOfSync) ? h.latestHeight || 0 : 0)));
const rtt = result.config['meta'].rtt; const rtt = result.config['meta'].rtt;
host.rtts.unshift(rtt); host.rtts.unshift(rtt);
host.rtts.slice(0, 5); host.rtts.slice(0, 5);
host.rtt = host.rtts.reduce((acc, l) => acc + l, 0) / host.rtts.length; host.rtt = host.rtts.reduce((acc, l) => acc + l, 0) / host.rtts.length;
host.latestHeight = height;
if (height == null || isNaN(height) || (this.maxHeight - height > this.maxSlippage)) { if (height == null || isNaN(height) || (this.maxHeight - height > this.maxSlippage)) {
host.outOfSync = true; host.outOfSync = true;
} else { } else {
@ -127,7 +127,6 @@ class FailoverRouter {
host.checked = true; host.checked = true;
host.lastChecked = Date.now(); host.lastChecked = Date.now();
// switch if the current host is out of sync or significantly slower than the next best alternative
const rankOrder = this.sortHosts(); const rankOrder = this.sortHosts();
// switch if the current host is out of sync or significantly slower than the next best alternative // switch if the current host is out of sync or significantly slower than the next best alternative
if (this.activeHost.outOfSync || this.activeHost.unreachable || (this.activeHost !== rankOrder[0] && rankOrder[0].preferred) || (!this.activeHost.preferred && this.activeHost.rtt > (rankOrder[0].rtt * 2) + 50)) { if (this.activeHost.outOfSync || this.activeHost.unreachable || (this.activeHost !== rankOrder[0] && rankOrder[0].preferred) || (!this.activeHost.preferred && this.activeHost.rtt > (rankOrder[0].rtt * 2) + 50)) {
@ -185,7 +184,6 @@ class FailoverRouter {
// depose the active host and choose the next best replacement // depose the active host and choose the next best replacement
private electHost(): void { private electHost(): void {
this.activeHost.outOfSync = true;
this.activeHost.failures = 0; this.activeHost.failures = 0;
const rankOrder = this.sortHosts(); const rankOrder = this.sortHosts();
this.activeHost = rankOrder[0]; this.activeHost = rankOrder[0];
@ -196,6 +194,7 @@ class FailoverRouter {
host.failures++; host.failures++;
if (host.failures > 5 && this.multihost) { if (host.failures > 5 && this.multihost) {
logger.warn(`🚨🚨🚨 Too many esplora failures on ${this.activeHost.host}, falling back to next best alternative 🚨🚨🚨`); logger.warn(`🚨🚨🚨 Too many esplora failures on ${this.activeHost.host}, falling back to next best alternative 🚨🚨🚨`);
this.activeHost.unreachable = true;
this.electHost(); this.electHost();
return this.activeHost; return this.activeHost;
} else { } else {