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

reserve long polling longer, add withdrawOnly to bench1

Browse Source
This commit is contained in:
Boss Marco 2022-06-07 13:42:34 +02:00
parent 72c6643969
commit f8c814cf95
No known key found for this signature in database
GPG Key ID: 89A3EC33C625C3DF
2 changed files with 18 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
packages/taler-wallet-cli/src/bench1.ts
View File

@ -52,6 +52,7 @@ export async function runBench1(configJson: any): Promise<void> {
const numDeposits = b1conf.deposits ?? 5; const numDeposits = b1conf.deposits ?? 5;
const restartWallet = b1conf.restartAfter ?? 20; const restartWallet = b1conf.restartAfter ?? 20;
const withdrawOnly = b1conf.withdrawOnly ?? false;
const withdrawAmount = (numDeposits + 1) * 10; const withdrawAmount = (numDeposits + 1) * 10;
logger.info( logger.info(
@ -110,20 +111,22 @@ export async function runBench1(configJson: any): Promise<void> {
`Finished withdrawal amount=${withdrawAmount} time=${Date.now() - start}`, `Finished withdrawal amount=${withdrawAmount} time=${Date.now() - start}`,
); );
for (let i = 0; i < numDeposits; i++) { if (!withdrawOnly) {
logger.trace(`Starting deposit amount=10`); for (let i = 0; i < numDeposits; i++) {
start = Date.now(); logger.trace(`Starting deposit amount=10`);
start = Date.now();
await wallet.client.call(WalletApiOperation.CreateDepositGroup, { await wallet.client.call(WalletApiOperation.CreateDepositGroup, {
amount: b1conf.currency + ":10", amount: b1conf.currency + ":10",
depositPaytoUri: b1conf.payto, depositPaytoUri: b1conf.payto,
}); });
await wallet.runTaskLoop({ await wallet.runTaskLoop({
stopWhenDone: true, stopWhenDone: true,
}); });
logger.info(`Finished deposit amount=10 time=${Date.now() - start}`); logger.info(`Finished deposit amount=10 time=${Date.now() - start}`);
}
} }
} }
@ -165,6 +168,8 @@ interface Bench1Config {
* Defaults to 20. * Defaults to 20.
*/ */
restartAfter?: number; restartAfter?: number;
withdrawOnly?: boolean;
} }
/** /**
@ -179,4 +184,5 @@ const codecForBench1Config = () =>
.property("deposits", codecOptional(codecForNumber())) .property("deposits", codecOptional(codecForNumber()))
.property("currency", codecForString()) .property("currency", codecForString())
.property("restartAfter", codecOptional(codecForNumber())) .property("restartAfter", codecOptional(codecForNumber()))
.property("withdrawOnly", codecOptional(codecForBoolean())
.build("Bench1Config"); .build("Bench1Config");

2
packages/taler-wallet-core/src/operations/reserves.ts
View File

@ -538,7 +538,7 @@ async function updateReserve(
} }
const reserveUrl = new URL(`reserves/${reservePub}`, reserve.exchangeBaseUrl); const reserveUrl = new URL(`reserves/${reservePub}`, reserve.exchangeBaseUrl);
reserveUrl.searchParams.set("timeout_ms", "1000"); reserveUrl.searchParams.set("timeout_ms", "30000");
const resp = await ws.http.get(reserveUrl.href, { const resp = await ws.http.get(reserveUrl.href, {
timeout: getReserveRequestTimeout(reserve), timeout: getReserveRequestTimeout(reserve),