diff options
author | Christian Grothoff <christian@grothoff.org> | 2021-01-29 10:00:23 +0100 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2021-01-29 10:00:23 +0100 |
commit | fee5d3b7160ad4d7388783ad999a7e55000c8a47 (patch) | |
tree | b5bb82ee24b019107365ffd22eac68cf41308cdd /src/util/taler-exchange-secmod-rsa.c | |
parent | 7d0d8d9f1c641409f900afcff68acddec913def1 (diff) | |
download | exchange-fee5d3b7160ad4d7388783ad999a7e55000c8a47.tar.xz |
not not break
Diffstat (limited to 'src/util/taler-exchange-secmod-rsa.c')
-rw-r--r-- | src/util/taler-exchange-secmod-rsa.c | 14 |
1 files changed, 12 insertions, 2 deletions
diff --git a/src/util/taler-exchange-secmod-rsa.c b/src/util/taler-exchange-secmod-rsa.c index dd37dd7a8..2f1cae2c9 100644 --- a/src/util/taler-exchange-secmod-rsa.c +++ b/src/util/taler-exchange-secmod-rsa.c @@ -410,6 +410,8 @@ static void * sign_worker (void *cls) { (void) cls; + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "Crypto worker launching\n"); GNUNET_assert (0 == pthread_mutex_lock (&work_lock)); while (! in_shutdown) { @@ -423,6 +425,9 @@ sign_worker (void *cls) wi); work_counter--; GNUNET_assert (0 == pthread_mutex_unlock (&work_lock)); + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "Processing sign request %p\n", + wi); wi->rsa_signature = GNUNET_CRYPTO_rsa_sign_blinded (wi->dk->denom_priv.rsa_private_key, wi->blinded_msg, @@ -446,10 +451,10 @@ sign_worker (void *cls) } GNUNET_assert (0 == pthread_mutex_lock (&work_lock)); } - if (! in_shutdown) + if (in_shutdown) break; /* queue is empty, wait for work */ - GNUNET_log (GNUNET_ERROR_TYPE_INFO, + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Crypto worker waiting for work...\n"); GNUNET_assert (0 == pthread_cond_wait (&work_cond, @@ -457,6 +462,8 @@ sign_worker (void *cls) } GNUNET_assert (0 == pthread_mutex_unlock (&work_lock)); + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "Crypto worker exiting\n"); return NULL; } @@ -2024,6 +2031,9 @@ run (void *cls, num_workers = sysconf (_SC_NPROCESSORS_CONF); if (0 == num_workers) num_workers = 1; + GNUNET_log (GNUNET_ERROR_TYPE_INFO, + "Starting %u crypto workers\n", + num_workers); workers = GNUNET_new_array (num_workers, pthread_t); for (unsigned int i = 0; i<num_workers; i++) |