| /dports/databases/pecl-mongodb/mongodb-1.9.1/src/libmongoc/src/libmongoc/src/mongoc/ |
| H A D | mongoc-client-pool.c | 118 pool = (mongoc_client_pool_t *) bson_malloc0 (sizeof *pool); in mongoc_client_pool_new()
125 pool->size = 0; in mongoc_client_pool_new()
170 RETURN (pool); in mongoc_client_pool_new()
181 if (!pool) { in mongoc_client_pool_destroy()
206 bson_free (pool); in mongoc_client_pool_destroy()
241 client, &pool->apm_callbacks, pool->apm_context); in _initialize_new_client()
273 if (pool->size < pool->max_pool_size) { in mongoc_client_pool_pop()
282 &pool->cond, &pool->mutex, expire_at_ms - now_ms); in mongoc_client_pool_pop()
290 mongoc_cond_wait (&pool->cond, &pool->mutex); in mongoc_client_pool_pop()
316 if (pool->size < pool->max_pool_size) { in mongoc_client_pool_try_pop()
[all …]
|
| /dports/devel/poco/poco-1.10.1-all/Data/testsuite/src/ |
| H A D | SessionPoolTest.cpp | 66 assertTrue (pool.allocated() == pool.used() + pool.idle()); in testSessionPool()
83 assertTrue (pool.allocated() == pool.used() + pool.idle()); in testSessionPool()
94 assertTrue (pool.allocated() == pool.used() + pool.idle()); in testSessionPool()
106 assertTrue (pool.allocated() == pool.used() + pool.idle()); in testSessionPool()
114 assertTrue (pool.allocated() == pool.used() + pool.idle()); in testSessionPool()
125 assertTrue (pool.allocated() == pool.used() + pool.idle()); in testSessionPool()
134 assertTrue (pool.allocated() == pool.used() + pool.idle()); in testSessionPool()
149 assertTrue (pool.allocated() == pool.used() + pool.idle()); in testSessionPool()
164 assertTrue (pool.allocated() == pool.used() + pool.idle()); in testSessionPool()
173 assertTrue (pool.allocated() == pool.used() + pool.idle()); in testSessionPool()
[all …]
|
| /dports/devel/mongo-c-driver/mongo-c-driver-1.8.1/src/mongoc/ |
| H A D | mongoc-client-pool.c | 59 BSON_ASSERT (pool); in mongoc_client_pool_set_ssl_opts()
65 memset (&pool->ssl_opts, 0, sizeof pool->ssl_opts); in mongoc_client_pool_set_ssl_opts()
103 pool = (mongoc_client_pool_t *) bson_malloc0 (sizeof *pool); in mongoc_client_pool_new()
109 pool->size = 0; in mongoc_client_pool_new()
147 RETURN (pool); in mongoc_client_pool_new()
175 bson_free (pool); in mongoc_client_pool_destroy()
211 if (pool->size < pool->max_pool_size) { in mongoc_client_pool_pop()
222 client, &pool->apm_callbacks, pool->apm_context); in mongoc_client_pool_pop()
230 mongoc_cond_wait (&pool->cond, &pool->mutex); in mongoc_client_pool_pop()
254 if (pool->size < pool->max_pool_size) { in mongoc_client_pool_try_pop()
[all …]
|
| /dports/net/kea/kea-2.0.1/src/lib/http/tests/ |
| H A D | http_thread_pool_unittests.cc | 46 HttpThreadPoolPtr pool; in TEST_F() local
55 HttpThreadPoolPtr pool; in TEST_F() local
64 ASSERT_TRUE(pool->isStopped()); in TEST_F()
76 HttpThreadPoolPtr pool; in TEST_F() local
85 ASSERT_TRUE(pool->isRunning()); in TEST_F()
97 HttpThreadPoolPtr pool; in TEST_F() local
127 HttpThreadPoolPtr pool; in TEST_F() local
157 HttpThreadPoolPtr pool; in TEST_F() local
187 HttpThreadPoolPtr pool; in TEST_F() local
212 HttpThreadPoolPtr pool; in TEST_F() local
[all …]
|
| /dports/multimedia/gstreamer1-vaapi/gstreamer-vaapi-1.16.2/gst-libs/gst/vaapi/ |
| H A D | gstvaapivideopool.c | 50 return GST_VAAPI_VIDEO_POOL_GET_CLASS (pool)->alloc_object (pool); in gst_vaapi_video_pool_alloc_object()
60 pool->used_count = 0; in gst_vaapi_video_pool_init()
61 pool->capacity = 0; in gst_vaapi_video_pool_init()
136 return pool->display; in gst_vaapi_video_pool_get_display()
172 if (pool->capacity && pool->used_count >= pool->capacity) in gst_vaapi_video_pool_get_object_unlocked()
184 ++pool->used_count; in gst_vaapi_video_pool_get_object_unlocked()
185 pool->used_objects = g_list_prepend (pool->used_objects, object); in gst_vaapi_video_pool_get_object_unlocked()
223 --pool->used_count; in gst_vaapi_video_pool_put_object_unlocked()
224 pool->used_objects = g_list_delete_link (pool->used_objects, elem); in gst_vaapi_video_pool_put_object_unlocked()
348 num_allocated = gst_vaapi_video_pool_get_size (pool) + pool->used_count; in gst_vaapi_video_pool_reserve_unlocked()
[all …]
|
| /dports/misc/libsolv/libsolv-0.7.19/src/ |
| H A D | pool.c | 45 Pool *pool; in pool_create() local
48 pool = (Pool *)solv_calloc(1, sizeof(*pool)); in pool_create()
98 return pool; in pool_create()
140 pool->repos = solv_free(pool->repos); in pool_freeallrepos()
388 pool->whatprovides[id] = pool->whatprovides[i]; in pool_shrink_whatprovides()
464 if (pool->ss.stringhashmask || pool->relhashmask) in pool_createwhatprovides()
1214 p = pool->nscallback(pool, pool->nscallbackdata, name, evr); in pool_addrelproviders()
1577 pool->debugcallback(pool, pool->debugcallbackdata, type, buf); in pool_debug()
1592 pool->errstr = solv_malloc(pool->errstra); in pool_error()
1605 pool->errstr = solv_realloc(pool->errstr, pool->errstra); in pool_error()
[all …]
|
| /dports/archivers/rpm4/rpm-4.16.1.3/rpmio/ |
| H A D | rpmstrpool.c | 238 pool->hash = poolHashFree(pool->hash); in rpmstrPoolRehash()
250 pool->offs = xcalloc(pool->offs_alloced, sizeof(*pool->offs)); in rpmstrPoolCreate()
253 pool->chunks = xcalloc(pool->chunks_allocated, sizeof(*pool->chunks)); in rpmstrPoolCreate()
256 pool->chunks[pool->chunks_size] = xcalloc(1, pool->chunk_allocated); in rpmstrPoolCreate()
257 pool->offs[1] = pool->chunks[pool->chunks_size]; in rpmstrPoolCreate()
310 pool->offs = xrealloc(pool->offs, in rpmstrPoolFreeze()
337 pool->offs = xrealloc(pool->offs, in rpmstrPoolPut()
347 pool->chunks = xrealloc(pool->chunks, in rpmstrPoolPut()
356 pool->chunks[pool->chunks_size] = xcalloc(1, pool->chunk_allocated); in rpmstrPoolPut()
361 t = memcpy(pool->chunks[pool->chunks_size] + pool->chunk_used, s, slen); in rpmstrPoolPut()
[all …]
|
| /dports/security/medusa/medusa-2.2/src/ |
| H A D | medusa-thread-pool.c | 113 pool->pool_nthreads < pool->pool_maximum && in worker_cleanup()
123 if (pool->pool_head == NULL && pool->pool_active == NULL) { in notify_waiters()
188 if (pool->pool_nthreads <= pool->pool_minimum) { in worker_thread()
234 if (timedout && pool->pool_nthreads > pool->pool_minimum) { in worker_thread()
295 if ((pool = malloc(sizeof (*pool))) == NULL) { in thr_pool_create()
325 pool->pool_forw = pool; in thr_pool_create()
326 pool->pool_back = pool; in thr_pool_create()
362 else if (pool->pool_nthreads < pool->pool_maximum && in thr_pool_queue()
422 pool->pool_back->pool_forw = pool->pool_forw; in thr_pool_destroy()
423 pool->pool_forw->pool_back = pool->pool_back; in thr_pool_destroy()
[all …]
|
| /dports/net/samba412/samba-4.12.15/lib/pthreadpool/ |
| H A D | pthreadpool.c | 150 free(pool); in pthreadpool_init()
154 pool->head = pool->num_jobs = 0; in pthreadpool_init()
159 free(pool); in pthreadpool_init()
167 free(pool); in pthreadpool_init()
176 free(pool); in pthreadpool_init()
308 pool = pool->next; in pthreadpool_prepare()
319 pool = DLIST_PREV(pool)) { in pthreadpool_parent()
339 pool = DLIST_PREV(pool)) { in pthreadpool_child()
592 while ((pool->num_jobs == 0) && !pool->stopped) { in pthreadpool_server()
596 &pool->condvar, &pool->mutex, &ts); in pthreadpool_server()
[all …]
|
| /dports/multimedia/libv4l/linux-5.13-rc2/net/xdp/ |
| H A D | xsk_buff_pool.c | 37 if (!pool) in xp_destroy()
41 kvfree(pool); in xp_destroy()
53 if (!pool) in xp_create_and_assign_umem()
82 xskb->pool = pool; in xp_create_and_assign_umem()
87 return pool; in xp_create_and_assign_umem()
167 bpf.xsk.pool = pool; in xp_assign_dev()
200 if (!pool->fq || !pool->cq) in xp_assign_dev_shared()
216 xsk_clear_pool_at_qid(pool->netdev, pool->queue_id); in xp_clear_dev()
251 if (!pool) in xp_put_pool()
430 *addr + pool->chunk_size > pool->addrs_cnt || in xp_check_unaligned()
[all …]
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/net/xdp/ |
| H A D | xsk_buff_pool.c | 37 if (!pool) in xp_destroy()
41 kvfree(pool); in xp_destroy()
53 if (!pool) in xp_create_and_assign_umem()
82 xskb->pool = pool; in xp_create_and_assign_umem()
87 return pool; in xp_create_and_assign_umem()
167 bpf.xsk.pool = pool; in xp_assign_dev()
200 if (!pool->fq || !pool->cq) in xp_assign_dev_shared()
216 xsk_clear_pool_at_qid(pool->netdev, pool->queue_id); in xp_clear_dev()
251 if (!pool) in xp_put_pool()
430 *addr + pool->chunk_size > pool->addrs_cnt || in xp_check_unaligned()
[all …]
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/net/xdp/ |
| H A D | xsk_buff_pool.c | 37 if (!pool) in xp_destroy()
41 kvfree(pool); in xp_destroy()
53 if (!pool) in xp_create_and_assign_umem()
82 xskb->pool = pool; in xp_create_and_assign_umem()
87 return pool; in xp_create_and_assign_umem()
167 bpf.xsk.pool = pool; in xp_assign_dev()
200 if (!pool->fq || !pool->cq) in xp_assign_dev_shared()
216 xsk_clear_pool_at_qid(pool->netdev, pool->queue_id); in xp_clear_dev()
251 if (!pool) in xp_put_pool()
430 *addr + pool->chunk_size > pool->addrs_cnt || in xp_check_unaligned()
[all …]
|
| /dports/math/pspp/pspp-1.4.1/src/libpspp/ |
| H A D | pool.c | 62 struct pool *pool; member
155 struct pool *pool; in pool_create() local
178 struct pool *pool; in pool_create_at_offset() local
192 pool_destroy (struct pool *pool) in pool_destroy() argument
220 pool_clear (struct pool *pool) in pool_clear() argument
250 pool_alloc (struct pool *pool, size_t amt) in pool_alloc() argument
682 pool_free (struct pool *pool, void *p) in pool_free() argument
701 pool_create_subpool (struct pool *pool) in pool_create_subpool() argument
726 pool_add_subpool (struct pool *pool, struct pool *subpool) in pool_add_subpool() argument
956 gizmo->pool = pool; in add_gizmo()
[all …]
|
| /dports/games/taisei/taisei-1.3.2/src/ |
| H A D | objectpool.c | 54 objpool_register_objects(pool, pool->objects); in objpool_alloc()
57 pool->tag, in objpool_alloc()
62 return pool; in objpool_alloc()
66 pool->extents = realloc(pool->extents, (++pool->num_extents) * sizeof(*pool->extents)); in objpool_add_extent()
67 …char *extent = pool->extents[pool->num_extents - 1] = calloc(pool->max_objects, pool->size_of_obje… in objpool_add_extent()
88 pool->max_objects * (1 + pool->num_extents), in objpool_fmt_size()
104 if(++pool->usage > pool->peak_usage) { in objpool_acquire()
105 pool->peak_usage = pool->usage; in objpool_acquire()
114 pool->tag, in objpool_acquire()
148 free(pool); in objpool_free()
[all …]
|
| /dports/emulators/qemu-guest-agent/qemu-5.0.1/util/ |
| H A D | thread-pool.c | 37 ThreadPool *pool; member
209 ThreadPool *pool = elem->pool; in thread_pool_cancel() local
234 ThreadPool *pool = elem->pool; in thread_pool_get_aio_context() local
254 req->pool = pool; in thread_pool_submit_aio()
261 if (pool->idle_threads == 0 && pool->cur_threads < pool->max_threads) { in thread_pool_submit_aio()
304 memset(pool, 0, sizeof(*pool)); in thread_pool_init_one()
321 return pool; in thread_pool_new()
326 if (!pool) { in thread_pool_free()
336 pool->cur_threads -= pool->new_threads; in thread_pool_free()
343 qemu_cond_wait(&pool->worker_stopped, &pool->lock); in thread_pool_free()
[all …]
|
| /dports/emulators/qemu42/qemu-4.2.1/util/ |
| H A D | thread-pool.c | 37 ThreadPool *pool; member
209 ThreadPool *pool = elem->pool; in thread_pool_cancel() local
234 ThreadPool *pool = elem->pool; in thread_pool_get_aio_context() local
254 req->pool = pool; in thread_pool_submit_aio()
261 if (pool->idle_threads == 0 && pool->cur_threads < pool->max_threads) { in thread_pool_submit_aio()
304 memset(pool, 0, sizeof(*pool)); in thread_pool_init_one()
321 return pool; in thread_pool_new()
326 if (!pool) { in thread_pool_free()
336 pool->cur_threads -= pool->new_threads; in thread_pool_free()
343 qemu_cond_wait(&pool->worker_stopped, &pool->lock); in thread_pool_free()
[all …]
|
| /dports/emulators/qemu-powernv/qemu-powernv-3.0.50/util/ |
| H A D | thread-pool.c | 38 ThreadPool *pool; member
210 ThreadPool *pool = elem->pool; in thread_pool_cancel() local
235 ThreadPool *pool = elem->pool; in thread_pool_get_aio_context() local
255 req->pool = pool; in thread_pool_submit_aio()
262 if (pool->idle_threads == 0 && pool->cur_threads < pool->max_threads) { in thread_pool_submit_aio()
305 memset(pool, 0, sizeof(*pool)); in thread_pool_init_one()
322 return pool; in thread_pool_new()
327 if (!pool) { in thread_pool_free()
337 pool->cur_threads -= pool->new_threads; in thread_pool_free()
344 qemu_cond_wait(&pool->worker_stopped, &pool->lock); in thread_pool_free()
[all …]
|
| /dports/emulators/qemu-utils/qemu-4.2.1/util/ |
| H A D | thread-pool.c | 37 ThreadPool *pool; member
209 ThreadPool *pool = elem->pool; in thread_pool_cancel() local
234 ThreadPool *pool = elem->pool; in thread_pool_get_aio_context() local
254 req->pool = pool; in thread_pool_submit_aio()
261 if (pool->idle_threads == 0 && pool->cur_threads < pool->max_threads) { in thread_pool_submit_aio()
304 memset(pool, 0, sizeof(*pool)); in thread_pool_init_one()
321 return pool; in thread_pool_new()
326 if (!pool) { in thread_pool_free()
336 pool->cur_threads -= pool->new_threads; in thread_pool_free()
343 qemu_cond_wait(&pool->worker_stopped, &pool->lock); in thread_pool_free()
[all …]
|
| /dports/emulators/qemu-cheri/qemu-0a323821042c36e21ea80e58b9545dfc3b0cb8ef/util/ |
| H A D | thread-pool.c | 37 ThreadPool *pool; member
209 ThreadPool *pool = elem->pool; in thread_pool_cancel() local
234 ThreadPool *pool = elem->pool; in thread_pool_get_aio_context() local
254 req->pool = pool; in thread_pool_submit_aio()
261 if (pool->idle_threads == 0 && pool->cur_threads < pool->max_threads) { in thread_pool_submit_aio()
304 memset(pool, 0, sizeof(*pool)); in thread_pool_init_one()
321 return pool; in thread_pool_new()
326 if (!pool) { in thread_pool_free()
336 pool->cur_threads -= pool->new_threads; in thread_pool_free()
343 qemu_cond_wait(&pool->worker_stopped, &pool->lock); in thread_pool_free()
[all …]
|
| /dports/devel/p5-IO-AIO/IO-AIO-4.76/libeio/ |
| H A D | etp.c | 67 # define ETP_WANT_POLL(pool) pool->want_poll_cb (pool->userdata) argument
70 # define ETP_DONE_POLL(pool) pool->done_poll_cb (pool->userdata) argument
123 etp_pool pool; member
299 pool->wrk_first.prev = &pool->wrk_first; in etp_init()
340 etp_pool pool = self->pool; in X_THREAD_PROC() local
371 if (pool->idle <= pool->max_idle) in X_THREAD_PROC()
373 X_COND_WAIT (pool->reqwait, pool->reqlock); in X_THREAD_PROC()
426 wrk->pool = pool; in etp_start_thread()
447 if (ecb_expect_true (etp_nthreads (pool) >= pool->wanted)) in etp_maybe_start_thread()
451 …if (ecb_expect_true (0 <= (int)etp_nthreads (pool) + (int)etp_npending (pool) - (int)etp_nreqs (po… in etp_maybe_start_thread()
[all …]
|
| /dports/emulators/qemu5/qemu-5.2.0/util/ |
| H A D | thread-pool.c | 37 ThreadPool *pool; member
209 ThreadPool *pool = elem->pool; in thread_pool_cancel() local
233 ThreadPool *pool = elem->pool; in thread_pool_get_aio_context() local
253 req->pool = pool; in thread_pool_submit_aio()
260 if (pool->idle_threads == 0 && pool->cur_threads < pool->max_threads) { in thread_pool_submit_aio()
303 memset(pool, 0, sizeof(*pool)); in thread_pool_init_one()
320 return pool; in thread_pool_new()
325 if (!pool) { in thread_pool_free()
335 pool->cur_threads -= pool->new_threads; in thread_pool_free()
342 qemu_cond_wait(&pool->worker_stopped, &pool->lock); in thread_pool_free()
[all …]
|
| /dports/emulators/qemu-devel/qemu-de8ed1055c2ce18c95f597eb10df360dcb534f99/util/ |
| H A D | thread-pool.c | 37 ThreadPool *pool; member
209 ThreadPool *pool = elem->pool; in thread_pool_cancel() local
233 ThreadPool *pool = elem->pool; in thread_pool_get_aio_context() local
253 req->pool = pool; in thread_pool_submit_aio()
260 if (pool->idle_threads == 0 && pool->cur_threads < pool->max_threads) { in thread_pool_submit_aio()
303 memset(pool, 0, sizeof(*pool)); in thread_pool_init_one()
320 return pool; in thread_pool_new()
325 if (!pool) { in thread_pool_free()
335 pool->cur_threads -= pool->new_threads; in thread_pool_free()
342 qemu_cond_wait(&pool->worker_stopped, &pool->lock); in thread_pool_free()
[all …]
|
| /dports/emulators/qemu/qemu-6.2.0/util/ |
| H A D | thread-pool.c | 37 ThreadPool *pool; member
209 ThreadPool *pool = elem->pool; in thread_pool_cancel() local
233 ThreadPool *pool = elem->pool; in thread_pool_get_aio_context() local
253 req->pool = pool; in thread_pool_submit_aio()
260 if (pool->idle_threads == 0 && pool->cur_threads < pool->max_threads) { in thread_pool_submit_aio()
303 memset(pool, 0, sizeof(*pool)); in thread_pool_init_one()
320 return pool; in thread_pool_new()
325 if (!pool) { in thread_pool_free()
335 pool->cur_threads -= pool->new_threads; in thread_pool_free()
342 qemu_cond_wait(&pool->worker_stopped, &pool->lock); in thread_pool_free()
[all …]
|
| /dports/emulators/qemu60/qemu-6.0.0/util/ |
| H A D | thread-pool.c | 37 ThreadPool *pool; member
209 ThreadPool *pool = elem->pool; in thread_pool_cancel() local
233 ThreadPool *pool = elem->pool; in thread_pool_get_aio_context() local
253 req->pool = pool; in thread_pool_submit_aio()
260 if (pool->idle_threads == 0 && pool->cur_threads < pool->max_threads) { in thread_pool_submit_aio()
303 memset(pool, 0, sizeof(*pool)); in thread_pool_init_one()
320 return pool; in thread_pool_new()
325 if (!pool) { in thread_pool_free()
335 pool->cur_threads -= pool->new_threads; in thread_pool_free()
342 qemu_cond_wait(&pool->worker_stopped, &pool->lock); in thread_pool_free()
[all …]
|
| /dports/devel/entt/entt-3.8.1/test/entt/entity/ |
| H A D | storage.cpp | 63 ASSERT_EQ(std::as_const(pool).begin(), std::as_const(pool).end()); in TEST()
64 ASSERT_EQ(pool.begin(), pool.end()); in TEST()
68 pool.reserve(0); in TEST()
77 ASSERT_NE(std::as_const(pool).begin(), std::as_const(pool).end()); in TEST()
78 ASSERT_NE(pool.begin(), pool.end()); in TEST()
88 ASSERT_EQ(pool.begin(), pool.end()); in TEST()
96 pool.clear(); in TEST()
101 ASSERT_EQ(pool.begin(), pool.end()); in TEST()
311 pool.clear(); in TEST()
453 pool.clear(); in TEST()
[all …]
|