/dports/net/freerdp/freerdp-2.5.0/winpr/libwinpr/utils/collections/ |
H A D | BufferPool.c | 41 if (pool->aSize + count > pool->aCapacity) in BufferPool_ShiftAvailable() 71 if (pool->uSize + count > pool->uCapacity) in BufferPool_ShiftUsed() 184 buffer = pool->array[--(pool->size)]; in BufferPool_Take() 269 if (pool->uSize + 1 > pool->uCapacity) in BufferPool_Take() 281 pool->uArray[pool->uSize].buffer = buffer; in BufferPool_Take() 282 pool->uArray[pool->uSize].size = size; in BufferPool_Take() 319 if ((pool->size + 1) >= pool->capacity) in BufferPool_Return() 330 pool->array[(pool->size)++] = buffer; in BufferPool_Return() 367 pool->aArray[pool->aSize].size = size; in BufferPool_Return() 400 _aligned_free(pool->array[pool->size]); in BufferPool_Clear() [all …]
|
H A D | StreamPool.c | 36 if (pool->uSize + count > pool->uCapacity) in StreamPool_ShiftUsed() 71 if ((pool->uSize + 1) >= pool->uCapacity) in StreamPool_AddUsed() 84 pool->uArray[(pool->uSize)++] = s; in StreamPool_AddUsed() 113 if (pool->aSize + count > pool->aCapacity) in StreamPool_ShiftAvailable() 186 s->pool = pool; in StreamPool_Take() 210 if ((pool->aSize + 1) >= pool->aCapacity) in StreamPool_Return() 222 else if ((pool->aSize + 1) * 3 < pool->aCapacity) in StreamPool_Return() 235 pool->aArray[(pool->aSize)++] = s; in StreamPool_Return() 362 Stream_Free(pool->aArray[pool->aSize], TRUE); in StreamPool_Clear() 379 if (pool) in StreamPool_New() [all …]
|
/dports/sysutils/bareos-client/bareos-Release-20.0.3/core/src/droplet/libdroplet/src/ |
H A D | task.c | 48 if (NULL == pool->task_queue) pool->task_last = NULL; in dpl_task_get() 56 if (pool->n_tasks < pool->congestion_threshold) { in dpl_task_get() 59 pool->name, pool->n_tasks, pool->congestion_threshold); in dpl_task_get() 70 if (pool->canceled || pool->n_workers > pool->n_workers_needed) { in dpl_task_get() 77 pthread_cond_wait(&pool->task_cond, &pool->task_lock); in dpl_task_get() 120 pool->task_queue = pool->task_last = task; in dpl_task_pool_put() 158 if (0 == pool->canceled) dpl_task_pool_cancel(pool); in dpl_task_pool_destroy() 165 free(pool); in dpl_task_pool_destroy() 182 pool = malloc(sizeof(*pool)); in dpl_task_pool_create() 185 memset(pool, 0, sizeof(*pool)); in dpl_task_pool_create() [all …]
|
/dports/sysutils/bareos-traymonitor/bareos-Release-20.0.3/core/src/droplet/libdroplet/src/ |
H A D | task.c | 48 if (NULL == pool->task_queue) pool->task_last = NULL; in dpl_task_get() 56 if (pool->n_tasks < pool->congestion_threshold) { in dpl_task_get() 59 pool->name, pool->n_tasks, pool->congestion_threshold); in dpl_task_get() 70 if (pool->canceled || pool->n_workers > pool->n_workers_needed) { in dpl_task_get() 77 pthread_cond_wait(&pool->task_cond, &pool->task_lock); in dpl_task_get() 120 pool->task_queue = pool->task_last = task; in dpl_task_pool_put() 158 if (0 == pool->canceled) dpl_task_pool_cancel(pool); in dpl_task_pool_destroy() 165 free(pool); in dpl_task_pool_destroy() 182 pool = malloc(sizeof(*pool)); in dpl_task_pool_create() 185 memset(pool, 0, sizeof(*pool)); in dpl_task_pool_create() [all …]
|
/dports/sysutils/bareos-server/bareos-Release-20.0.3/core/src/droplet/libdroplet/src/ |
H A D | task.c | 48 if (NULL == pool->task_queue) pool->task_last = NULL; in dpl_task_get() 56 if (pool->n_tasks < pool->congestion_threshold) { in dpl_task_get() 59 pool->name, pool->n_tasks, pool->congestion_threshold); in dpl_task_get() 70 if (pool->canceled || pool->n_workers > pool->n_workers_needed) { in dpl_task_get() 77 pthread_cond_wait(&pool->task_cond, &pool->task_lock); in dpl_task_get() 120 pool->task_queue = pool->task_last = task; in dpl_task_pool_put() 158 if (0 == pool->canceled) dpl_task_pool_cancel(pool); in dpl_task_pool_destroy() 165 free(pool); in dpl_task_pool_destroy() 182 pool = malloc(sizeof(*pool)); in dpl_task_pool_create() 185 memset(pool, 0, sizeof(*pool)); in dpl_task_pool_create() [all …]
|
/dports/www/bareos-webui/bareos-Release-20.0.3/core/src/droplet/libdroplet/src/ |
H A D | task.c | 48 if (NULL == pool->task_queue) pool->task_last = NULL; in dpl_task_get() 56 if (pool->n_tasks < pool->congestion_threshold) { in dpl_task_get() 59 pool->name, pool->n_tasks, pool->congestion_threshold); in dpl_task_get() 70 if (pool->canceled || pool->n_workers > pool->n_workers_needed) { in dpl_task_get() 77 pthread_cond_wait(&pool->task_cond, &pool->task_lock); in dpl_task_get() 120 pool->task_queue = pool->task_last = task; in dpl_task_pool_put() 158 if (0 == pool->canceled) dpl_task_pool_cancel(pool); in dpl_task_pool_destroy() 165 free(pool); in dpl_task_pool_destroy() 182 pool = malloc(sizeof(*pool)); in dpl_task_pool_create() 185 memset(pool, 0, sizeof(*pool)); in dpl_task_pool_create() [all …]
|
/dports/security/vaultwarden/vaultwarden-1.23.1/cargo-crates/openssl-src-300.0.2+3.0.0/openssl/crypto/rand/ |
H A D | rand_pool.c | 37 if (pool->alloc_len > pool->max_len) in ossl_rand_pool_new() 38 pool->alloc_len = pool->max_len; in ossl_rand_pool_new() 85 pool->min_len = pool->max_len = pool->alloc_len = pool->len; in ossl_rand_pool_attach() 185 if (pool->len < pool->min_len) in ossl_rand_pool_entropy_available() 212 if (pool->attached || len > pool->max_len - pool->len) { in rand_pool_grow() 229 memcpy(p, pool->buffer, pool->len); in rand_pool_grow() 264 if (pool->len < pool->min_len && in ossl_rand_pool_bytes_needed() 283 pool->max_len = pool->len = 0; in ossl_rand_pool_bytes_needed() 293 return pool->max_len - pool->len; in ossl_rand_pool_bytes_remaining() 327 if (pool->alloc_len > pool->len && pool->buffer + pool->len == buffer) { in ossl_rand_pool_add() [all …]
|
/dports/security/arti/arti-9d0ede26801cdb182daa85c3eb5f0058dc178eb6/cargo-crates/openssl-src-300.0.2+3.0.0/openssl/crypto/rand/ |
H A D | rand_pool.c | 37 if (pool->alloc_len > pool->max_len) in ossl_rand_pool_new() 38 pool->alloc_len = pool->max_len; in ossl_rand_pool_new() 85 pool->min_len = pool->max_len = pool->alloc_len = pool->len; in ossl_rand_pool_attach() 185 if (pool->len < pool->min_len) in ossl_rand_pool_entropy_available() 212 if (pool->attached || len > pool->max_len - pool->len) { in rand_pool_grow() 229 memcpy(p, pool->buffer, pool->len); in rand_pool_grow() 264 if (pool->len < pool->min_len && in ossl_rand_pool_bytes_needed() 283 pool->max_len = pool->len = 0; in ossl_rand_pool_bytes_needed() 293 return pool->max_len - pool->len; in ossl_rand_pool_bytes_remaining() 327 if (pool->alloc_len > pool->len && pool->buffer + pool->len == buffer) { in ossl_rand_pool_add() [all …]
|
/dports/security/acmed/acmed-0.18.0/cargo-crates/openssl-src-300.0.2+3.0.0/openssl/crypto/rand/ |
H A D | rand_pool.c | 37 if (pool->alloc_len > pool->max_len) in ossl_rand_pool_new() 38 pool->alloc_len = pool->max_len; in ossl_rand_pool_new() 85 pool->min_len = pool->max_len = pool->alloc_len = pool->len; in ossl_rand_pool_attach() 185 if (pool->len < pool->min_len) in ossl_rand_pool_entropy_available() 212 if (pool->attached || len > pool->max_len - pool->len) { in rand_pool_grow() 229 memcpy(p, pool->buffer, pool->len); in rand_pool_grow() 264 if (pool->len < pool->min_len && in ossl_rand_pool_bytes_needed() 283 pool->max_len = pool->len = 0; in ossl_rand_pool_bytes_needed() 293 return pool->max_len - pool->len; in ossl_rand_pool_bytes_remaining() 327 if (pool->alloc_len > pool->len && pool->buffer + pool->len == buffer) { in ossl_rand_pool_add() [all …]
|
/dports/textproc/mdbook-linkcheck/mdbook-linkcheck-0.7.6/cargo-crates/openssl-src-300.0.2+3.0.0/openssl/crypto/rand/ |
H A D | rand_pool.c | 37 if (pool->alloc_len > pool->max_len) in ossl_rand_pool_new() 38 pool->alloc_len = pool->max_len; in ossl_rand_pool_new() 85 pool->min_len = pool->max_len = pool->alloc_len = pool->len; in ossl_rand_pool_attach() 185 if (pool->len < pool->min_len) in ossl_rand_pool_entropy_available() 212 if (pool->attached || len > pool->max_len - pool->len) { in rand_pool_grow() 229 memcpy(p, pool->buffer, pool->len); in rand_pool_grow() 264 if (pool->len < pool->min_len && in ossl_rand_pool_bytes_needed() 283 pool->max_len = pool->len = 0; in ossl_rand_pool_bytes_needed() 293 return pool->max_len - pool->len; in ossl_rand_pool_bytes_remaining() 327 if (pool->alloc_len > pool->len && pool->buffer + pool->len == buffer) { in ossl_rand_pool_add() [all …]
|
/dports/security/openssl-quictls/openssl-7f2ab56a2b842b8e6fefc7b9d20eb5ff9c6ef151/crypto/rand/ |
H A D | rand_pool.c | 37 if (pool->alloc_len > pool->max_len) in ossl_rand_pool_new() 38 pool->alloc_len = pool->max_len; in ossl_rand_pool_new() 85 pool->min_len = pool->max_len = pool->alloc_len = pool->len; in ossl_rand_pool_attach() 185 if (pool->len < pool->min_len) in ossl_rand_pool_entropy_available() 212 if (pool->attached || len > pool->max_len - pool->len) { in rand_pool_grow() 229 memcpy(p, pool->buffer, pool->len); in rand_pool_grow() 264 if (pool->len < pool->min_len && in ossl_rand_pool_bytes_needed() 283 pool->max_len = pool->len = 0; in ossl_rand_pool_bytes_needed() 293 return pool->max_len - pool->len; in ossl_rand_pool_bytes_remaining() 327 if (pool->alloc_len > pool->len && pool->buffer + pool->len == buffer) { in ossl_rand_pool_add() [all …]
|
/dports/security/openssl-devel/openssl-3.0.2/crypto/rand/ |
H A D | rand_pool.c | 37 if (pool->alloc_len > pool->max_len) in ossl_rand_pool_new() 38 pool->alloc_len = pool->max_len; in ossl_rand_pool_new() 85 pool->min_len = pool->max_len = pool->alloc_len = pool->len; in ossl_rand_pool_attach() 185 if (pool->len < pool->min_len) in ossl_rand_pool_entropy_available() 212 if (pool->attached || len > pool->max_len - pool->len) { in rand_pool_grow() 229 memcpy(p, pool->buffer, pool->len); in rand_pool_grow() 264 if (pool->len < pool->min_len && in ossl_rand_pool_bytes_needed() 283 pool->max_len = pool->len = 0; in ossl_rand_pool_bytes_needed() 293 return pool->max_len - pool->len; in ossl_rand_pool_bytes_remaining() 327 if (pool->alloc_len > pool->len && pool->buffer + pool->len == buffer) { in ossl_rand_pool_add() [all …]
|
/dports/math/yices/yices-2.6.2/src/solvers/cdcl/ |
H A D | clause_pool.c | 91 pool->learned <= pool->size && in clause_pool_invariant() 92 pool->size <= pool->capacity && in clause_pool_invariant() 93 pool->available == pool->capacity - pool->size && in clause_pool_invariant() 180 pool->available = pool->capacity; in reset_clause_pool() 224 pool->available = cap - pool->size; in resize_clause_pool() 277 assert(pool->learned == pool->size); in clause_pool_add_problem_clause() 284 pool->learned = pool->size; in clause_pool_add_problem_clause() 378 assert(good_clause_idx(pool, idx) && pool->learned > 0); in clause_pool_delete_clause() 406 assert(good_clause_idx(pool, idx) && pool->learned > 0 && in clause_pool_shrink_clause() 439 while (i < pool->size && is_padding_start(pool, i)) { in next_clause_index() [all …]
|
/dports/dns/yadifa/yadifa-2.5.3-10333/lib/dnscore/src/ |
H A D | pool.c | 67 ptr_vector_init(&pool->pool); in pool_init_ex() 102 pool->name, pool->allocated_count, pool->released_count, in pool_log_stats_ex() 103 pool->pool.offset + 1, pool->max_size, in pool_log_stats_ex() 162 pool->free_method(pool->pool.data[i], pool->allocate_args); in pool_finalize() 163 pool->pool.data[i] = NULL; in pool_finalize() 165 ptr_vector_destroy(&pool->pool); in pool_finalize() 212 if(pool->pool.offset >= 0) in pool_alloc() 214 p = ptr_vector_pop(&pool->pool); in pool_alloc() 241 if(pool->pool.offset < pool->max_size) in pool_release() 243 ptr_vector_append(&pool->pool, p); in pool_release() [all …]
|
/dports/net/libsignal-protocol-c/libsignal-protocol-c-2.3.3/src/ |
H A D | vpool.c | 35 if (pool->v_buf != pool->v_basebuf) { in vpool_shift() 36 memmove(pool->v_basebuf, pool->v_buf, pool->v_off); in vpool_shift() 37 pool->v_buf = pool->v_basebuf; in vpool_shift() 60 if (pool->v_limit - pool->v_off >= in vpool_new_size() 87 memcpy(ret, pool->v_buf, pool->v_off); in vpool_resize() 89 pool->v_basebuf = pool->v_buf = ret; in vpool_resize() 102 pool->v_basebuf = pool->v_buf = NULL; in vpool_init() 103 pool->v_off = pool->v_size = 0; in vpool_init() 121 pool->v_basebuf = pool->v_buf = NULL; in vpool_reset() 122 pool->v_off = pool->v_size = 0; in vpool_reset() [all …]
|
/dports/net-im/dino/dino-0.2.2/plugins/signal-protocol/libsignal-protocol-c/src/ |
H A D | vpool.c | 35 if (pool->v_buf != pool->v_basebuf) { in vpool_shift() 36 memmove(pool->v_basebuf, pool->v_buf, pool->v_off); in vpool_shift() 37 pool->v_buf = pool->v_basebuf; in vpool_shift() 60 if (pool->v_limit - pool->v_off >= in vpool_new_size() 87 memcpy(ret, pool->v_buf, pool->v_off); in vpool_resize() 89 pool->v_basebuf = pool->v_buf = ret; in vpool_resize() 102 pool->v_basebuf = pool->v_buf = NULL; in vpool_init() 103 pool->v_off = pool->v_size = 0; in vpool_init() 121 pool->v_basebuf = pool->v_buf = NULL; in vpool_reset() 122 pool->v_off = pool->v_size = 0; in vpool_reset() [all …]
|
/dports/devel/libvirt/libvirt-7.10.0/src/util/ |
H A D | virthreadpool.c | 93 virThreadPool *pool = data->pool; in virThreadPoolWorker() local 164 (pool->jobFunc)(job->data, pool->jobOpaque); in virThreadPoolWorker() 174 if (pool->nWorkers == 0 && pool->nPrioWorkers == 0) in virThreadPoolWorker() 193 data->pool = pool; in virThreadPoolExpand() 194 data->cond = priority ? &pool->prioCond : &pool->cond; in virThreadPoolExpand() 237 pool->jobList.tail = pool->jobList.head = NULL; in virThreadPoolNewFull() 295 while (pool->nWorkers > 0 || pool->nPrioWorkers > 0) in virThreadPoolDrainLocked() 299 pool->jobList.head = pool->jobList.head->next; in virThreadPoolDrainLocked() 306 if (!pool) in virThreadPoolFree() 406 if (pool->freeWorkers - pool->jobQueueDepth <= 0 && in virThreadPoolSendJob() [all …]
|
/dports/net/freeradius3/freeradius-server-3.0.25/src/main/ |
H A D | connection.c | 364 if ((pool->num + pool->pending) >= pool->max) { in fr_connection_spawn() 498 if (pool->max_pending < pool->max) pool->max_pending++; in fr_connection_spawn() 600 if (pool->num <= pool->min) { in fr_connection_manage() 659 num = pool->num + pool->pending; in fr_connection_pool_check() 660 spare = pool->pending + (pool->num - pool->active); in fr_connection_pool_check() 863 if (pool->num == pool->max) { in fr_connection_get_internal() 886 pool->active, pool->num); in fr_connection_get_internal() 1030 pool->head = pool->tail = NULL; in fr_connection_pool_init() 1098 if (pool->min > pool->max) { in fr_connection_pool_init() 1121 pool->start = pool->min = pool->max = 1; in fr_connection_pool_init() [all …]
|
/dports/dns/knot3-lib/knot-3.1.5/src/contrib/vpool/ |
H A D | vpool.c | 35 if (pool->v_buf != pool->v_basebuf) { in vpool_shift() 36 memmove(pool->v_basebuf, pool->v_buf, pool->v_off); in vpool_shift() 37 pool->v_buf = pool->v_basebuf; in vpool_shift() 61 if (pool->v_limit - pool->v_off >= in vpool_new_size() 95 pool->v_basebuf = pool->v_buf = ret; in vpool_resize() 109 pool->v_basebuf = pool->v_buf = NULL; in vpool_init() 110 pool->v_off = pool->v_size = 0; in vpool_init() 128 pool->v_basebuf = pool->v_buf = NULL; in vpool_reset() 129 pool->v_off = pool->v_size = 0; in vpool_reset() 240 pool->v_basebuf = pool->v_buf = NULL; in vpool_export() [all …]
|
/dports/dns/knot3/knot-3.1.5/src/contrib/vpool/ |
H A D | vpool.c | 35 if (pool->v_buf != pool->v_basebuf) { in vpool_shift() 36 memmove(pool->v_basebuf, pool->v_buf, pool->v_off); in vpool_shift() 37 pool->v_buf = pool->v_basebuf; in vpool_shift() 61 if (pool->v_limit - pool->v_off >= in vpool_new_size() 95 pool->v_basebuf = pool->v_buf = ret; in vpool_resize() 109 pool->v_basebuf = pool->v_buf = NULL; in vpool_init() 110 pool->v_off = pool->v_size = 0; in vpool_init() 128 pool->v_basebuf = pool->v_buf = NULL; in vpool_reset() 129 pool->v_off = pool->v_size = 0; in vpool_reset() 240 pool->v_basebuf = pool->v_buf = NULL; in vpool_export() [all …]
|
/dports/multimedia/libv4l/linux-5.13-rc2/net/core/ |
H A D | page_pool.c | 31 memcpy(&pool->p, params, sizeof(pool->p)); in page_pool_init() 89 if (!pool) in page_pool_create() 136 pool->alloc.cache[pool->alloc.count++] = page; in page_pool_refill_alloc_cache() 151 page = pool->alloc.cache[--pool->alloc.count]; in page_pool_refill_alloc_cache() 165 page = pool->alloc.cache[--pool->alloc.count]; in __page_pool_get_cached() 247 return pool->alloc.cache[--pool->alloc.count]; in __page_pool_alloc_pages_slow() 266 pool->alloc.cache[pool->alloc.count++] = page; in __page_pool_alloc_pages_slow() 275 page = pool->alloc.cache[--pool->alloc.count]; in __page_pool_alloc_pages_slow() 388 pool->alloc.cache[pool->alloc.count++] = page; in page_pool_recycle_in_cache() 512 pool->disconnect(pool); in page_pool_free() [all …]
|
/dports/multimedia/v4l_compat/linux-5.13-rc2/net/core/ |
H A D | page_pool.c | 31 memcpy(&pool->p, params, sizeof(pool->p)); in page_pool_init() 89 if (!pool) in page_pool_create() 136 pool->alloc.cache[pool->alloc.count++] = page; in page_pool_refill_alloc_cache() 151 page = pool->alloc.cache[--pool->alloc.count]; in page_pool_refill_alloc_cache() 165 page = pool->alloc.cache[--pool->alloc.count]; in __page_pool_get_cached() 247 return pool->alloc.cache[--pool->alloc.count]; in __page_pool_alloc_pages_slow() 266 pool->alloc.cache[pool->alloc.count++] = page; in __page_pool_alloc_pages_slow() 275 page = pool->alloc.cache[--pool->alloc.count]; in __page_pool_alloc_pages_slow() 388 pool->alloc.cache[pool->alloc.count++] = page; in page_pool_recycle_in_cache() 512 pool->disconnect(pool); in page_pool_free() [all …]
|
/dports/multimedia/v4l-utils/linux-5.13-rc2/net/core/ |
H A D | page_pool.c | 31 memcpy(&pool->p, params, sizeof(pool->p)); in page_pool_init() 89 if (!pool) in page_pool_create() 136 pool->alloc.cache[pool->alloc.count++] = page; in page_pool_refill_alloc_cache() 151 page = pool->alloc.cache[--pool->alloc.count]; in page_pool_refill_alloc_cache() 165 page = pool->alloc.cache[--pool->alloc.count]; in __page_pool_get_cached() 247 return pool->alloc.cache[--pool->alloc.count]; in __page_pool_alloc_pages_slow() 266 pool->alloc.cache[pool->alloc.count++] = page; in __page_pool_alloc_pages_slow() 275 page = pool->alloc.cache[--pool->alloc.count]; in __page_pool_alloc_pages_slow() 388 pool->alloc.cache[pool->alloc.count++] = page; in page_pool_recycle_in_cache() 512 pool->disconnect(pool); in page_pool_free() [all …]
|
/dports/dns/knot3-lib/knot-3.1.5/src/knot/worker/ |
H A D | pool.c | 70 pthread_cond_wait(&pool->wake, &pool->lock); in worker_main() 115 return pool; in worker_pool_create() 119 free(pool); in worker_pool_create() 125 if (!pool) { in worker_pool_destroy() 136 free(pool); in worker_pool_destroy() 141 if (!pool) { in worker_pool_start() 150 if (!pool) { in worker_pool_stop() 164 if (!pool) { in worker_pool_suspend() 175 if (!pool) { in worker_pool_resume() 203 cb(pool); in worker_pool_wait_cb() [all …]
|
/dports/dns/knot3/knot-3.1.5/src/knot/worker/ |
H A D | pool.c | 70 pthread_cond_wait(&pool->wake, &pool->lock); in worker_main() 115 return pool; in worker_pool_create() 119 free(pool); in worker_pool_create() 125 if (!pool) { in worker_pool_destroy() 136 free(pool); in worker_pool_destroy() 141 if (!pool) { in worker_pool_start() 150 if (!pool) { in worker_pool_stop() 164 if (!pool) { in worker_pool_suspend() 175 if (!pool) { in worker_pool_resume() 203 cb(pool); in worker_pool_wait_cb() [all …]
|