diff options
Diffstat (limited to 'Source/charon/thread_pool.c')
| -rw-r--r-- | Source/charon/thread_pool.c | 14 |
1 files changed, 12 insertions, 2 deletions
diff --git a/Source/charon/thread_pool.c b/Source/charon/thread_pool.c index 6791a1477..31fe448de 100644 --- a/Source/charon/thread_pool.c +++ b/Source/charon/thread_pool.c @@ -23,6 +23,8 @@ #include "thread_pool.h" +#include "job_queue.h" + #include <stdlib.h> #include <freeswan.h> #include <pluto/constants.h> @@ -30,6 +32,9 @@ #include <pthread.h> +extern job_queue_t *job_queue; + + /** * structure with private members for thread_pool */ @@ -49,14 +54,19 @@ typedef struct { } private_thread_pool_t; +pthread_mutex_t muti = PTHREAD_MUTEX_INITIALIZER; +pthread_cond_t condi = PTHREAD_COND_INITIALIZER; void *job_processing(private_thread_pool_t *this) { + for (;;) { - sleep(1); + /*job_t *job; + job_queue->get(job_queue, &job);*/ + sleep(100); /* flag for termination received ? */ pthread_testcancel(); } @@ -77,7 +87,7 @@ static status_t get_pool_size(private_thread_pool_t *this, size_t *size) static status_t destroy(private_thread_pool_t *this) { int current; - + /* flag thread for termination */ for (current = 0; current < this->pool_size; current++) { pthread_cancel(this->threads[current]); |