fix benchmark tool output and time measurement

This commit is contained in:
Christian Grothoff 2018-08-09 20:25:30 +02:00
parent a05859ad13
commit d9474aab0f
No known key found for this signature in database
GPG Key ID: 939E6BE1E29FC3CC
4 changed files with 22 additions and 15 deletions

View File

@ -1,5 +1,5 @@
{ {
"url": "payto://x-taler-bank/localhost:8082/2", "url": "payto://x-taler-bank/localhost:8082/2",
"salt": "NYZ2WR8CPT5PB58X10EZDJDY3MSWHAHTD0M99JJH54Z0A916NTX4P4AF5Y3KPGRYEVX3TV7J2ZG6PKZSKFYMSKMHCN83ZT3V2216YP8", "salt": "KZCTEHKD39TDK9CR9DYHNA5C6RYK1QYCBE1Z0198PBXKK1XTJ3D06CE3Q2QD4ZCED5H16RB9V79QBP5VQ7QRCST36CC4H9P2WAYBMGR",
"master_sig": "0RF7GBGKGJQ0ZQVP0HJ516CC882RV6HVJZABN5S1YMF6WD94QJJRZSTFB669QTNW63DPRP0YYJ0RGCNXA3AHQ1HGYDGAMZX0S983020" "master_sig": "55PBWD75WS0S9CKMGKXQPX9R22YM7CS3AARYXZ2GNZJ76EXB63DX9JY3NWWB4PHAZWRKS54VCHYT8HAYNSX294C0CC7XPQF1Y3Y1628"
} }

View File

@ -120,11 +120,6 @@ static struct GNUNET_TIME_Relative duration;
*/ */
static unsigned int result; static unsigned int result;
/**
* How many refreshes got executed.
*/
static unsigned int howmany_refreshes;
/** /**
* How many coins we want to create. * How many coins we want to create.
*/ */
@ -401,7 +396,6 @@ run (void *cls,
char *melt_label; char *melt_label;
char *reveal_label; char *reveal_label;
howmany_refreshes++;
GNUNET_asprintf (&melt_label, GNUNET_asprintf (&melt_label,
"refresh-melt-%u", "refresh-melt-%u",
i); i);
@ -435,7 +429,6 @@ run (void *cls,
unit); unit);
} }
all_commands[1 + howmany_coins] = TALER_TESTING_cmd_end (); all_commands[1 + howmany_coins] = TALER_TESTING_cmd_end ();
start_time = GNUNET_TIME_absolute_get ();
TALER_TESTING_run (is, TALER_TESTING_run (is,
all_commands); all_commands);
result = 1; result = 1;
@ -536,7 +529,7 @@ parallel_benchmark (TALER_TESTING_Main main_cb,
if (0 == fakebank) if (0 == fakebank)
{ {
GNUNET_SCHEDULER_run (&launch_fakebank, GNUNET_SCHEDULER_run (&launch_fakebank,
NULL); exchange_bank_account.bank_base_url);
exit (0); exit (0);
} }
if (-1 == fakebank) if (-1 == fakebank)
@ -546,9 +539,11 @@ parallel_benchmark (TALER_TESTING_Main main_cb,
result = GNUNET_SYSERR; result = GNUNET_SYSERR;
return 77; return 77;
} }
sleep (1); /* make sure fakebank process is ready before continuing */
/* FIXME: start wirewatch */ /* FIXME: start wirewatch */
start_time = GNUNET_TIME_absolute_get ();
result = GNUNET_OK; result = GNUNET_OK;
for (unsigned int i=0;i<howmany_clients;i++) for (unsigned int i=0;i<howmany_clients;i++)
{ {
@ -748,12 +743,19 @@ main (int argc,
duration = GNUNET_TIME_absolute_get_duration (start_time); duration = GNUNET_TIME_absolute_get_duration (start_time);
fprintf (stdout, fprintf (stdout,
"Executed W=%u, D=%u, R=%u, operations in %s\n", "Executed (W=%u, D=%u, R~=%5.2f) * P=%u, operations in %s\n",
howmany_coins, howmany_coins,
howmany_coins, howmany_coins,
howmany_refreshes, (float) howmany_coins * REFRESH_PROBABILITY,
howmany_clients,
GNUNET_STRINGS_relative_time_to_string GNUNET_STRINGS_relative_time_to_string
(duration, (duration,
GNUNET_NO)); GNUNET_NO));
fprintf (stdout,
"(approximately %s/coin)\n",
GNUNET_STRINGS_relative_time_to_string
(GNUNET_TIME_relative_divide (duration,
howmany_coins * howmany_clients),
GNUNET_YES));
return (GNUNET_OK == result) ? 0 : result; return (GNUNET_OK == result) ? 0 : result;
} }

View File

@ -152,6 +152,10 @@ add_incoming_cb (void *cls,
if (MHD_HTTP_OK != http_status) if (MHD_HTTP_OK != http_status)
{ {
GNUNET_break (0); GNUNET_break (0);
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
"Fakebank returned HTTP status %u/%d\n",
http_status,
(int) ec);
TALER_TESTING_interpreter_fail (is); TALER_TESTING_interpreter_fail (is);
return; return;
} }
@ -211,13 +215,13 @@ fakebank_transfer_run (void *cls,
{ {
if (NULL != fts->instance) if (NULL != fts->instance)
{ {
GNUNET_assert (NULL != fts->config_filename);
char *section; char *section;
char *keys; char *keys;
struct GNUNET_CRYPTO_EddsaPrivateKey *priv; struct GNUNET_CRYPTO_EddsaPrivateKey *priv;
struct GNUNET_CONFIGURATION_Handle *cfg; struct GNUNET_CONFIGURATION_Handle *cfg;
cfg = GNUNET_CONFIGURATION_create ();
GNUNET_assert (NULL != fts->config_filename);
cfg = GNUNET_CONFIGURATION_create ();
if (GNUNET_OK != if (GNUNET_OK !=
GNUNET_CONFIGURATION_load (cfg, GNUNET_CONFIGURATION_load (cfg,
fts->config_filename)) fts->config_filename))

View File

@ -944,10 +944,11 @@ main (int argc,
} }
mhd mhd
= MHD_start_daemon (MHD_USE_SELECT_INTERNALLY | MHD_USE_PIPE_FOR_SHUTDOWN | MHD_USE_DEBUG | MHD_USE_DUAL_STACK, = MHD_start_daemon (MHD_USE_SELECT_INTERNALLY | MHD_USE_PIPE_FOR_SHUTDOWN | MHD_USE_DEBUG | MHD_USE_DUAL_STACK, // | MHD_USE_INTERNAL_POLLING_THREAD,
(-1 == fh) ? serve_port : 0, (-1 == fh) ? serve_port : 0,
NULL, NULL, NULL, NULL,
&handle_mhd_request, NULL, &handle_mhd_request, NULL,
/* MHD_OPTION_THREAD_POOL_SIZE, (unsigned int) 8, */
MHD_OPTION_LISTEN_SOCKET, fh, MHD_OPTION_LISTEN_SOCKET, fh,
MHD_OPTION_EXTERNAL_LOGGER, &handle_mhd_logs, NULL, MHD_OPTION_EXTERNAL_LOGGER, &handle_mhd_logs, NULL,
MHD_OPTION_NOTIFY_COMPLETED, &handle_mhd_completion_callback, NULL, MHD_OPTION_NOTIFY_COMPLETED, &handle_mhd_completion_callback, NULL,