summaryrefslogtreecommitdiff
path: root/src/benchmark/taler-bank-benchmark.c
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2023-07-30 16:28:47 +0200
committerChristian Grothoff <christian@grothoff.org>2023-07-30 16:28:47 +0200
commit09ec056da4ebbbc3437df05344075a4d109ec204 (patch)
tree3df12b85e54f986c676954dcafb0693fe6e47f23 /src/benchmark/taler-bank-benchmark.c
parenta29f04189c8b7457ede0b3ac01222b88853325a8 (diff)
downloadexchange-09ec056da4ebbbc3437df05344075a4d109ec204.tar.gz
exchange-09ec056da4ebbbc3437df05344075a4d109ec204.tar.bz2
exchange-09ec056da4ebbbc3437df05344075a4d109ec204.zip
misc bug fixes in batch insert
Diffstat (limited to 'src/benchmark/taler-bank-benchmark.c')
-rw-r--r--src/benchmark/taler-bank-benchmark.c14
1 files changed, 4 insertions, 10 deletions
diff --git a/src/benchmark/taler-bank-benchmark.c b/src/benchmark/taler-bank-benchmark.c
index 224b6d5d1..cde6217e4 100644
--- a/src/benchmark/taler-bank-benchmark.c
+++ b/src/benchmark/taler-bank-benchmark.c
@@ -38,6 +38,7 @@
#include "taler_testing_lib.h"
#include "taler_error_codes.h"
+#define SHARD_SIZE "1024"
/**
* Credentials to use for the benchmark.
@@ -75,11 +76,6 @@ static unsigned int howmany_reserves = 1;
static unsigned int howmany_clients = 1;
/**
- * How many bank worker threads do we want to create.
- */
-static unsigned int howmany_threads;
-
-/**
* How many wirewatch processes do we want to create.
*/
static unsigned int start_wirewatch;
@@ -339,6 +335,7 @@ parallel_benchmark (void)
"taler-exchange-wirewatch",
"-c", cfg_filename,
"-a", exchange_bank_section,
+ "-S", SHARD_SIZE,
(NULL != loglev) ? "-L" : NULL,
loglev,
NULL);
@@ -376,6 +373,7 @@ parallel_benchmark (void)
"taler-exchange-wirewatch",
"-c", cfg_filename,
"-a", exchange_bank_section,
+ "-S", SHARD_SIZE,
"-t",
(NULL != loglev) ? "-L" : NULL,
loglev,
@@ -405,6 +403,7 @@ parallel_benchmark (void)
"taler-exchange-wirewatch",
"-c", cfg_filename,
"-a", exchange_bank_section,
+ "-S", SHARD_SIZE,
"-t",
(NULL != loglev) ? "-L" : NULL,
loglev,
@@ -451,11 +450,6 @@ main (int argc,
"NPROCS",
"How many client processes we should run",
&howmany_clients),
- GNUNET_GETOPT_option_uint ('P',
- "service-parallelism",
- "NTHREADS",
- "How many service threads we should create",
- &howmany_threads),
GNUNET_GETOPT_option_uint ('r',
"reserves",
"NRESERVES",