Lines Matching refs:pool
106 async_pool *pool; in async_get_pool_job() local
108 pool = (async_pool *)CRYPTO_THREAD_get_local(&poolkey); in async_get_pool_job()
109 if (pool == NULL) { in async_get_pool_job()
116 pool = (async_pool *)CRYPTO_THREAD_get_local(&poolkey); in async_get_pool_job()
119 job = sk_ASYNC_JOB_pop(pool->jobs); in async_get_pool_job()
122 if ((pool->max_size != 0) && (pool->curr_size >= pool->max_size)) in async_get_pool_job()
131 pool->curr_size++; in async_get_pool_job()
138 async_pool *pool; in async_release_job() local
140 pool = (async_pool *)CRYPTO_THREAD_get_local(&poolkey); in async_release_job()
141 if (pool == NULL) { in async_release_job()
147 sk_ASYNC_JOB_push(pool->jobs, job); in async_release_job()
320 static void async_empty_pool(async_pool *pool) in async_empty_pool() argument
324 if (pool == NULL || pool->jobs == NULL) in async_empty_pool()
328 job = sk_ASYNC_JOB_pop(pool->jobs); in async_empty_pool()
354 async_pool *pool; in ASYNC_init_thread() local
368 pool = OPENSSL_zalloc(sizeof(*pool)); in ASYNC_init_thread()
369 if (pool == NULL) { in ASYNC_init_thread()
374 pool->jobs = sk_ASYNC_JOB_new_reserve(NULL, init_size); in ASYNC_init_thread()
375 if (pool->jobs == NULL) { in ASYNC_init_thread()
377 OPENSSL_free(pool); in ASYNC_init_thread()
381 pool->max_size = max_size; in ASYNC_init_thread()
396 sk_ASYNC_JOB_push(pool->jobs, job); /* Cannot fail due to reserve */ in ASYNC_init_thread()
399 pool->curr_size = curr_size; in ASYNC_init_thread()
400 if (!CRYPTO_THREAD_set_local(&poolkey, pool)) { in ASYNC_init_thread()
407 async_empty_pool(pool); in ASYNC_init_thread()
408 sk_ASYNC_JOB_free(pool->jobs); in ASYNC_init_thread()
409 OPENSSL_free(pool); in ASYNC_init_thread()
415 async_pool *pool = (async_pool *)CRYPTO_THREAD_get_local(&poolkey); in async_delete_thread_state() local
417 if (pool != NULL) { in async_delete_thread_state()
418 async_empty_pool(pool); in async_delete_thread_state()
419 sk_ASYNC_JOB_free(pool->jobs); in async_delete_thread_state()
420 OPENSSL_free(pool); in async_delete_thread_state()