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 | |
| parent | 7d0d8d9f1c641409f900afcff68acddec913def1 (diff) | |
not not break
| -rw-r--r-- | src/util/taler-exchange-secmod-eddsa.c | 13 | ||||
| -rw-r--r-- | src/util/taler-exchange-secmod-rsa.c | 14 |
2 files changed, 22 insertions, 5 deletions
diff --git a/src/util/taler-exchange-secmod-eddsa.c b/src/util/taler-exchange-secmod-eddsa.c index d06c1e71..89ec2b60 100644 --- a/src/util/taler-exchange-secmod-eddsa.c +++ b/src/util/taler-exchange-secmod-eddsa.c @@ -342,6 +342,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) { @@ -355,7 +357,7 @@ sign_worker (void *cls) wi); work_counter--; GNUNET_assert (0 == pthread_mutex_unlock (&work_lock)); - GNUNET_log (GNUNET_ERROR_TYPE_INFO, + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Processing sign request %p\n", wi); { @@ -386,10 +388,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, @@ -397,6 +399,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; } @@ -1633,6 +1637,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++) diff --git a/src/util/taler-exchange-secmod-rsa.c b/src/util/taler-exchange-secmod-rsa.c index dd37dd7a..2f1cae2c 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++) |