summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2021-01-29 10:00:23 +0100
committerChristian Grothoff <christian@grothoff.org>2021-01-29 10:00:23 +0100
commitfee5d3b7160ad4d7388783ad999a7e55000c8a47 (patch)
treeb5bb82ee24b019107365ffd22eac68cf41308cdd
parent7d0d8d9f1c641409f900afcff68acddec913def1 (diff)
downloadexchange-fee5d3b7160ad4d7388783ad999a7e55000c8a47.tar.gz
exchange-fee5d3b7160ad4d7388783ad999a7e55000c8a47.tar.bz2
exchange-fee5d3b7160ad4d7388783ad999a7e55000c8a47.zip
not not break
-rw-r--r--src/util/taler-exchange-secmod-eddsa.c13
-rw-r--r--src/util/taler-exchange-secmod-rsa.c14
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++)