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

fixing high cpu usage after some time

Browse Source 
retryinfo was not being updated and not being used by exchangeCheckRefresh pending operation
This commit is contained in:
Sebastian 2022-01-13 01:31:53 -03:00
parent 5eeb00e158
commit f6ec105b72
No known key found for this signature in database
GPG Key ID: BE4FF68352439FC1
2 changed files with 9 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
packages/taler-wallet-core/src/operations/exchanges.ts
View File

@ -123,7 +123,7 @@ async function handleExchangeUpdateError(
): Promise<void> { ): Promise<void> {
await ws.db await ws.db
.mktx((x) => ({ exchanges: x.exchanges })) .mktx((x) => ({ exchanges: x.exchanges }))
.runReadOnly(async (tx) => { .runReadWrite(async (tx) => {
const exchange = await tx.exchanges.get(baseUrl); const exchange = await tx.exchanges.get(baseUrl);
if (!exchange) { if (!exchange) {
return; return;
@ -131,6 +131,7 @@ async function handleExchangeUpdateError(
exchange.retryInfo.retryCounter++; exchange.retryInfo.retryCounter++;
updateRetryInfoTimeout(exchange.retryInfo); updateRetryInfoTimeout(exchange.retryInfo);
exchange.lastError = err; exchange.lastError = err;
await tx.exchanges.put(exchange)
}); });
if (err) { if (err) {
ws.notify({ type: NotificationType.ExchangeOperationError, error: err }); ws.notify({ type: NotificationType.ExchangeOperationError, error: err });
@ -526,11 +527,11 @@ async function updateExchangeFromUrlImpl(
tosFound !== undefined tosFound !== undefined
? tosFound ? tosFound
: await downloadExchangeWithTermsOfService( : await downloadExchangeWithTermsOfService(
baseUrl, baseUrl,
ws.http, ws.http,
timeout, timeout,
"text/plain", "text/plain",
); );
let recoupGroupId: string | undefined = undefined; let recoupGroupId: string | undefined = undefined;

11
packages/taler-wallet-core/src/operations/pending.ts
View File

@ -51,25 +51,18 @@ async function gatherExchangePending(
resp: PendingOperationsResponse, resp: PendingOperationsResponse,
): Promise<void> { ): Promise<void> {
await tx.exchanges.iter().forEachAsync(async (e) => { await tx.exchanges.iter().forEachAsync(async (e) => {
let exchangeUpdateTimestampDue: Timestamp;
if (e.lastError) {
exchangeUpdateTimestampDue = e.retryInfo.nextRetry;
} else {
exchangeUpdateTimestampDue = e.nextUpdate;
}
resp.pendingOperations.push({ resp.pendingOperations.push({
type: PendingTaskType.ExchangeUpdate, type: PendingTaskType.ExchangeUpdate,
givesLifeness: false, givesLifeness: false,
timestampDue: exchangeUpdateTimestampDue, timestampDue: e.lastError ? e.retryInfo.nextRetry : e.nextUpdate,
exchangeBaseUrl: e.baseUrl, exchangeBaseUrl: e.baseUrl,
lastError: e.lastError, lastError: e.lastError,
}); });
resp.pendingOperations.push({ resp.pendingOperations.push({
type: PendingTaskType.ExchangeCheckRefresh, type: PendingTaskType.ExchangeCheckRefresh,
timestampDue: e.nextRefreshCheck, timestampDue: e.lastError ? e.retryInfo.nextRetry : e.nextRefreshCheck,
givesLifeness: false, givesLifeness: false,
exchangeBaseUrl: e.baseUrl, exchangeBaseUrl: e.baseUrl,
}); });