| /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 …]
|