taler/wallet-core
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Activity

truncate back-off

Browse Source
This commit is contained in:
Florian Dold 2016-11-17 15:46:59 +01:00
parent c8576b433d
commit b90d1c0318
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/wallet.ts
View File

@ -731,7 +731,7 @@ export class Wallet {
retryDelayMs = 200): Promise<void> { retryDelayMs = 200): Promise<void> {
if (this.processPreCoinConcurrent >= 4 || this.processPreCoinThrottle[preCoin.exchangeBaseUrl]) { if (this.processPreCoinConcurrent >= 4 || this.processPreCoinThrottle[preCoin.exchangeBaseUrl]) {
console.log("delaying processPreCoin"); console.log("delaying processPreCoin");
setTimeout(() => this.processPreCoin(preCoin, retryDelayMs * 2), setTimeout(() => this.processPreCoin(preCoin, Math.min(retryDelayMs * 2, 5 * 60 * 1000)),
retryDelayMs); retryDelayMs);
return; return;
} }
@ -791,7 +791,7 @@ export class Wallet {
retryDelayMs, retryDelayMs,
"ms", e); "ms", e);
// exponential backoff truncated at one minute // exponential backoff truncated at one minute
let nextRetryDelayMs = Math.min(retryDelayMs * 2, 1000 * 60); let nextRetryDelayMs = Math.min(retryDelayMs * 2, 5 * 60 * 1000);
setTimeout(() => this.processPreCoin(preCoin, nextRetryDelayMs), setTimeout(() => this.processPreCoin(preCoin, nextRetryDelayMs),
retryDelayMs); retryDelayMs);
this.processPreCoinThrottle[preCoin.exchangeBaseUrl] = (this.processPreCoinThrottle[preCoin.exchangeBaseUrl] || 0) + 1; this.processPreCoinThrottle[preCoin.exchangeBaseUrl] = (this.processPreCoinThrottle[preCoin.exchangeBaseUrl] || 0) + 1;