taler/exchange
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

fix #6745

Browse Source
This commit is contained in:
Sebastian 2021-02-07 20:11:24 -03:00
parent 07a5f6fb82
commit 93347b3904
No known key found for this signature in database
GPG Key ID: BE4FF68352439FC1
2 changed files with 20 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
src/util/taler-exchange-secmod-eddsa.c
View File

@ -1427,13 +1427,16 @@ do_shutdown (void *cls)
done_task = NULL; done_task = NULL;
} }
/* shut down worker threads */ /* shut down worker threads */
GNUNET_assert (0 == pthread_mutex_lock (&work_lock)); if (NULL != workers)
in_shutdown = true; {
GNUNET_assert (0 == pthread_cond_broadcast (&work_cond)); GNUNET_assert (0 == pthread_mutex_lock (&work_lock));
GNUNET_assert (0 == pthread_mutex_unlock (&work_lock)); in_shutdown = true;
for (unsigned int i = 0; i<num_workers; i++) GNUNET_assert (0 == pthread_cond_broadcast (&work_cond));
GNUNET_assert (0 == pthread_join (workers[i], GNUNET_assert (0 == pthread_mutex_unlock (&work_lock));
NULL)); for (unsigned int i = 0; i<num_workers; i++)
GNUNET_assert (0 == pthread_join (workers[i],
NULL));
}
if (NULL != done_signal) if (NULL != done_signal)
{ {
GNUNET_break (GNUNET_OK == GNUNET_break (GNUNET_OK ==

17
src/util/taler-exchange-secmod-rsa.c
View File

@ -1798,13 +1798,16 @@ do_shutdown (void *cls)
done_task = NULL; done_task = NULL;
} }
/* shut down worker threads */ /* shut down worker threads */
GNUNET_assert (0 == pthread_mutex_lock (&work_lock)); if (NULL != workers)
in_shutdown = true; {
GNUNET_assert (0 == pthread_cond_broadcast (&work_cond)); GNUNET_assert (0 == pthread_mutex_lock (&work_lock));
GNUNET_assert (0 == pthread_mutex_unlock (&work_lock)); in_shutdown = true;
for (unsigned int i = 0; i<num_workers; i++) GNUNET_assert (0 == pthread_cond_broadcast (&work_cond));
GNUNET_assert (0 == pthread_join (workers[i], GNUNET_assert (0 == pthread_mutex_unlock (&work_lock));
NULL)); for (unsigned int i = 0; i<num_workers; i++)
GNUNET_assert (0 == pthread_join (workers[i],
NULL));
}
if (NULL != done_signal) if (NULL != done_signal)
{ {
GNUNET_break (GNUNET_OK == GNUNET_break (GNUNET_OK ==