| /dports/security/vault/vault-1.8.2/vendor/github.com/gocql/gocql/ |
| H A D | connectionpool.go | 134 return pool
237 pool.fill()
302 return pool
386 if pool.closed || pool.filling {
408 if pool.closed || pool.filling || fillCount <= 0 {
436 go pool.session.handleNodeDown(pool.host.ConnectAddress(), pool.port)
441 go pool.session.handleNodeUp(pool.host.ConnectAddress(), pool.port)
456 go pool.session.handleNodeUp(pool.host.ConnectAddress(), pool.port)
525 conn, err = pool.session.connect(pool.session.ctx, pool.host, pool)
564 pool.conns = append(pool.conns, conn)
[all …]
|
| /dports/lang/gcc6-aux/gcc-6-20180516/libcilkrts/runtime/ |
| H A D | cilk_fiber.cpp | 66 if ((NULL != pool) && pool->total > 0) { in cilk_fiber_pool_sanity_check()
76 pool, pool->max_size, pool->total, pool->high_water); in cilk_fiber_pool_sanity_check()
86 if (pool->high_water < pool->total) in increment_pool_total()
87 pool->high_water = pool->total; in increment_pool_total()
203 pool->fibers[--pool->size]; in cilk_fiber_pool_move_fibers_to_parent_pool()
258 for (pool->size = 0; pool->size < pre_allocate_count; pool->size++) { in cilk_fiber_pool_init()
259 pool->fibers[pool->size] = cilk_fiber::allocate_from_heap(pool->stack_size); in cilk_fiber_pool_init()
738 ret = pool->fibers[--pool->size]; in allocate()
756 if (pool->total < pool->alloc_max) { in allocate()
990 if (pool->size < pool->max_size) in deallocate_self()
[all …]
|
| /dports/devel/arm-none-eabi-gcc492/gcc-4.9.2/libcilkrts/runtime/ |
| H A D | cilk_fiber.cpp | 66 if ((NULL != pool) && pool->total > 0) { in cilk_fiber_pool_sanity_check()
76 pool, pool->max_size, pool->total, pool->high_water); in cilk_fiber_pool_sanity_check()
86 if (pool->high_water < pool->total) in increment_pool_total()
87 pool->high_water = pool->total; in increment_pool_total()
203 pool->fibers[--pool->size]; in cilk_fiber_pool_move_fibers_to_parent_pool()
258 for (pool->size = 0; pool->size < pre_allocate_count; pool->size++) { in cilk_fiber_pool_init()
259 pool->fibers[pool->size] = cilk_fiber::allocate_from_heap(pool->stack_size); in cilk_fiber_pool_init()
738 ret = pool->fibers[--pool->size]; in allocate()
756 if (pool->total < pool->alloc_max) { in allocate()
990 if (pool->size < pool->max_size) in deallocate_self()
[all …]
|
| /dports/lang/gnat_util/gcc-6-20180516/libcilkrts/runtime/ |
| H A D | cilk_fiber.cpp | 66 if ((NULL != pool) && pool->total > 0) { in cilk_fiber_pool_sanity_check()
76 pool, pool->max_size, pool->total, pool->high_water); in cilk_fiber_pool_sanity_check()
86 if (pool->high_water < pool->total) in increment_pool_total()
87 pool->high_water = pool->total; in increment_pool_total()
203 pool->fibers[--pool->size]; in cilk_fiber_pool_move_fibers_to_parent_pool()
258 for (pool->size = 0; pool->size < pre_allocate_count; pool->size++) { in cilk_fiber_pool_init()
259 pool->fibers[pool->size] = cilk_fiber::allocate_from_heap(pool->stack_size); in cilk_fiber_pool_init()
738 ret = pool->fibers[--pool->size]; in allocate()
756 if (pool->total < pool->alloc_max) { in allocate()
990 if (pool->size < pool->max_size) in deallocate_self()
[all …]
|
| /dports/net/freerdp/freerdp-2.5.0/winpr/libwinpr/utils/test/ |
| H A D | TestStreamPool.c | 11 wStreamPool* pool; in TestStreamPool() local
19 printf("StreamPool: aSize: %d uSize: %d\n", pool->aSize, pool->uSize); in TestStreamPool()
25 printf("StreamPool: aSize: %d uSize: %d\n", pool->aSize, pool->uSize); in TestStreamPool()
30 printf("StreamPool: aSize: %d uSize: %d\n", pool->aSize, pool->uSize); in TestStreamPool()
35 printf("StreamPool: aSize: %d uSize: %d\n", pool->aSize, pool->uSize); in TestStreamPool()
41 printf("StreamPool: aSize: %d uSize: %d\n", pool->aSize, pool->uSize); in TestStreamPool()
64 printf("StreamPool: aSize: %d uSize: %d\n", pool->aSize, pool->uSize); in TestStreamPool()
70 printf("StreamPool: aSize: %d uSize: %d\n", pool->aSize, pool->uSize); in TestStreamPool()
81 printf("StreamPool: aSize: %d uSize: %d\n", pool->aSize, pool->uSize); in TestStreamPool()
95 printf("StreamPool: aSize: %d uSize: %d\n", pool->aSize, pool->uSize); in TestStreamPool()
[all …]
|
| /dports/databases/percona56-client/percona-server-5.6.51-91.0/storage/tokudb/PerconaFT/util/ |
| H A D | threadpool.cc | 91 thread->pool = pool; in toku_thread_create()
122 struct toku_thread_pool *pool = thread->pool; in toku_thread_destroy() local
139 struct toku_thread_pool *pool = thread->pool; in toku_thread_run_internal() local
166 if (pool == nullptr) { in toku_thread_pool_create()
175 *pool_return = pool; in toku_thread_pool_create()
219 toku_free(pool); in toku_thread_pool_destroy()
240 pool->gets++; in toku_thread_pool_get_one()
244 if (pool->max_threads == 0 || pool->cur_threads < pool->max_threads) in toku_thread_pool_get_one()
250 pool->get_blocks++; in toku_thread_pool_get_one()
251 toku_cond_wait(&pool->wait_free, &pool->lock); in toku_thread_pool_get_one()
[all …]
|
| /dports/databases/percona56-server/percona-server-5.6.51-91.0/storage/tokudb/PerconaFT/util/ |
| H A D | threadpool.cc | 91 thread->pool = pool; in toku_thread_create()
122 struct toku_thread_pool *pool = thread->pool; in toku_thread_destroy() local
139 struct toku_thread_pool *pool = thread->pool; in toku_thread_run_internal() local
166 if (pool == nullptr) { in toku_thread_pool_create()
175 *pool_return = pool; in toku_thread_pool_create()
219 toku_free(pool); in toku_thread_pool_destroy()
240 pool->gets++; in toku_thread_pool_get_one()
244 if (pool->max_threads == 0 || pool->cur_threads < pool->max_threads) in toku_thread_pool_get_one()
250 pool->get_blocks++; in toku_thread_pool_get_one()
251 toku_cond_wait(&pool->wait_free, &pool->lock); in toku_thread_pool_get_one()
[all …]
|
| /dports/databases/percona-pam-for-mysql/percona-server-5.6.51-91.0/storage/tokudb/PerconaFT/util/ |
| H A D | threadpool.cc | 91 thread->pool = pool; in toku_thread_create()
122 struct toku_thread_pool *pool = thread->pool; in toku_thread_destroy() local
139 struct toku_thread_pool *pool = thread->pool; in toku_thread_run_internal() local
166 if (pool == nullptr) { in toku_thread_pool_create()
175 *pool_return = pool; in toku_thread_pool_create()
219 toku_free(pool); in toku_thread_pool_destroy()
240 pool->gets++; in toku_thread_pool_get_one()
244 if (pool->max_threads == 0 || pool->cur_threads < pool->max_threads) in toku_thread_pool_get_one()
250 pool->get_blocks++; in toku_thread_pool_get_one()
251 toku_cond_wait(&pool->wait_free, &pool->lock); in toku_thread_pool_get_one()
[all …]
|
| /dports/databases/percona57-client/percona-server-5.7.36-39/storage/tokudb/PerconaFT/util/ |
| H A D | threadpool.cc | 91 thread->pool = pool; in toku_thread_create()
122 struct toku_thread_pool *pool = thread->pool; in toku_thread_destroy() local
139 struct toku_thread_pool *pool = thread->pool; in toku_thread_run_internal() local
166 if (pool == nullptr) { in toku_thread_pool_create()
175 *pool_return = pool; in toku_thread_pool_create()
219 toku_free(pool); in toku_thread_pool_destroy()
240 pool->gets++; in toku_thread_pool_get_one()
244 if (pool->max_threads == 0 || pool->cur_threads < pool->max_threads) in toku_thread_pool_get_one()
250 pool->get_blocks++; in toku_thread_pool_get_one()
251 toku_cond_wait(&pool->wait_free, &pool->lock); in toku_thread_pool_get_one()
[all …]
|
| /dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/storage/tokudb/PerconaFT/util/ |
| H A D | threadpool.cc | 91 thread->pool = pool; in toku_thread_create()
122 struct toku_thread_pool *pool = thread->pool; in toku_thread_destroy() local
139 struct toku_thread_pool *pool = thread->pool; in toku_thread_run_internal() local
166 if (pool == nullptr) { in toku_thread_pool_create()
175 *pool_return = pool; in toku_thread_pool_create()
219 toku_free(pool); in toku_thread_pool_destroy()
240 pool->gets++; in toku_thread_pool_get_one()
244 if (pool->max_threads == 0 || pool->cur_threads < pool->max_threads) in toku_thread_pool_get_one()
250 pool->get_blocks++; in toku_thread_pool_get_one()
251 toku_cond_wait(&pool->wait_free, &pool->lock); in toku_thread_pool_get_one()
[all …]
|
| /dports/databases/percona57-server/percona-server-5.7.36-39/storage/tokudb/PerconaFT/util/ |
| H A D | threadpool.cc | 91 thread->pool = pool; in toku_thread_create()
122 struct toku_thread_pool *pool = thread->pool; in toku_thread_destroy() local
139 struct toku_thread_pool *pool = thread->pool; in toku_thread_run_internal() local
166 if (pool == nullptr) { in toku_thread_pool_create()
175 *pool_return = pool; in toku_thread_pool_create()
219 toku_free(pool); in toku_thread_pool_destroy()
240 pool->gets++; in toku_thread_pool_get_one()
244 if (pool->max_threads == 0 || pool->cur_threads < pool->max_threads) in toku_thread_pool_get_one()
250 pool->get_blocks++; in toku_thread_pool_get_one()
251 toku_cond_wait(&pool->wait_free, &pool->lock); in toku_thread_pool_get_one()
[all …]
|
| /dports/databases/mariadb104-server/mariadb-10.4.24/storage/tokudb/PerconaFT/util/ |
| H A D | threadpool.cc | 91 thread->pool = pool; in toku_thread_create()
122 struct toku_thread_pool *pool = thread->pool; in toku_thread_destroy() local
139 struct toku_thread_pool *pool = thread->pool; in toku_thread_run_internal() local
166 if (pool == nullptr) { in toku_thread_pool_create()
175 *pool_return = pool; in toku_thread_pool_create()
219 toku_free(pool); in toku_thread_pool_destroy()
240 pool->gets++; in toku_thread_pool_get_one()
244 if (pool->max_threads == 0 || pool->cur_threads < pool->max_threads) in toku_thread_pool_get_one()
250 pool->get_blocks++; in toku_thread_pool_get_one()
251 toku_cond_wait(&pool->wait_free, &pool->lock); in toku_thread_pool_get_one()
[all …]
|
| /dports/databases/mariadb104-client/mariadb-10.4.24/storage/tokudb/PerconaFT/util/ |
| H A D | threadpool.cc | 91 thread->pool = pool; in toku_thread_create()
122 struct toku_thread_pool *pool = thread->pool; in toku_thread_destroy() local
139 struct toku_thread_pool *pool = thread->pool; in toku_thread_run_internal() local
166 if (pool == nullptr) { in toku_thread_pool_create()
175 *pool_return = pool; in toku_thread_pool_create()
219 toku_free(pool); in toku_thread_pool_destroy()
240 pool->gets++; in toku_thread_pool_get_one()
244 if (pool->max_threads == 0 || pool->cur_threads < pool->max_threads) in toku_thread_pool_get_one()
250 pool->get_blocks++; in toku_thread_pool_get_one()
251 toku_cond_wait(&pool->wait_free, &pool->lock); in toku_thread_pool_get_one()
[all …]
|
| /dports/databases/mariadb105-client/mariadb-10.5.15/storage/tokudb/PerconaFT/util/ |
| H A D | threadpool.cc | 91 thread->pool = pool; in toku_thread_create()
122 struct toku_thread_pool *pool = thread->pool; in toku_thread_destroy() local
139 struct toku_thread_pool *pool = thread->pool; in toku_thread_run_internal() local
166 if (pool == nullptr) { in toku_thread_pool_create()
175 *pool_return = pool; in toku_thread_pool_create()
219 toku_free(pool); in toku_thread_pool_destroy()
240 pool->gets++; in toku_thread_pool_get_one()
244 if (pool->max_threads == 0 || pool->cur_threads < pool->max_threads) in toku_thread_pool_get_one()
250 pool->get_blocks++; in toku_thread_pool_get_one()
251 toku_cond_wait(&pool->wait_free, &pool->lock); in toku_thread_pool_get_one()
[all …]
|
| /dports/databases/mariadb103-client/mariadb-10.3.34/storage/tokudb/PerconaFT/util/ |
| H A D | threadpool.cc | 91 thread->pool = pool; in toku_thread_create()
122 struct toku_thread_pool *pool = thread->pool; in toku_thread_destroy() local
139 struct toku_thread_pool *pool = thread->pool; in toku_thread_run_internal() local
166 if (pool == nullptr) { in toku_thread_pool_create()
175 *pool_return = pool; in toku_thread_pool_create()
219 toku_free(pool); in toku_thread_pool_destroy()
240 pool->gets++; in toku_thread_pool_get_one()
244 if (pool->max_threads == 0 || pool->cur_threads < pool->max_threads) in toku_thread_pool_get_one()
250 pool->get_blocks++; in toku_thread_pool_get_one()
251 toku_cond_wait(&pool->wait_free, &pool->lock); in toku_thread_pool_get_one()
[all …]
|
| /dports/databases/mariadb103-server/mariadb-10.3.34/storage/tokudb/PerconaFT/util/ |
| H A D | threadpool.cc | 91 thread->pool = pool; in toku_thread_create()
122 struct toku_thread_pool *pool = thread->pool; in toku_thread_destroy() local
139 struct toku_thread_pool *pool = thread->pool; in toku_thread_run_internal() local
166 if (pool == nullptr) { in toku_thread_pool_create()
175 *pool_return = pool; in toku_thread_pool_create()
219 toku_free(pool); in toku_thread_pool_destroy()
240 pool->gets++; in toku_thread_pool_get_one()
244 if (pool->max_threads == 0 || pool->cur_threads < pool->max_threads) in toku_thread_pool_get_one()
250 pool->get_blocks++; in toku_thread_pool_get_one()
251 toku_cond_wait(&pool->wait_free, &pool->lock); in toku_thread_pool_get_one()
[all …]
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/storage/tokudb/PerconaFT/util/ |
| H A D | threadpool.cc | 91 thread->pool = pool; in toku_thread_create()
122 struct toku_thread_pool *pool = thread->pool; in toku_thread_destroy() local
139 struct toku_thread_pool *pool = thread->pool; in toku_thread_run_internal() local
166 if (pool == nullptr) { in toku_thread_pool_create()
175 *pool_return = pool; in toku_thread_pool_create()
219 toku_free(pool); in toku_thread_pool_destroy()
240 pool->gets++; in toku_thread_pool_get_one()
244 if (pool->max_threads == 0 || pool->cur_threads < pool->max_threads) in toku_thread_pool_get_one()
250 pool->get_blocks++; in toku_thread_pool_get_one()
251 toku_cond_wait(&pool->wait_free, &pool->lock); in toku_thread_pool_get_one()
[all …]
|
| /dports/mail/dovecot/dovecot-2.3.17/src/lib/ |
| H A D | mempool.h | 47 struct pool { struct
107 return pool->v->malloc(pool, size); in p_malloc()
118 return pool->v->malloc(pool, new_size); in p_realloc()
120 return pool->v->realloc(pool, mem, old_size, new_size); in p_realloc()
130 #define p_free_and_null(pool, mem) p_free(pool, mem) argument
135 pool->v->free(pool, mem); in p_free_internal()
140 pool->v->clear(pool); in p_clear()
145 return pool->v->get_max_easy_alloc_size(pool); in p_get_max_easy_alloc_size()
150 return pool->v->get_name(pool); in pool_get_name()
155 pool->v->ref(pool); in pool_ref()
[all …]
|
| /dports/security/libgcrypt/libgcrypt-1.9.4/src/ |
| H A D | secmem.c | 460 pool->mem = mmap (0, pool->size, in init_pool()
479 pool->mem = malloc (pool->size); in init_pool()
679 for (pool = pool->next; pool; pool = pool->next) in _gcry_secmem_malloc_internal()
692 pool = calloc (1, sizeof *pool); in _gcry_secmem_malloc_internal()
696 pool->mem = malloc (pool->size); in _gcry_secmem_malloc_internal()
757 for (pool = &mainpool; pool; pool = pool->next) in _gcry_secmem_free_internal()
758 if (pool->okay && ptr_into_pool_p (pool, a)) in _gcry_secmem_free_internal()
862 for (pool = &mainpool; pool; pool = pool->next) in _gcry_private_is_secure()
883 for (pool = &mainpool; pool; pool = next) in _gcry_secmem_term()
897 munmap (pool->mem, pool->size); in _gcry_secmem_term()
[all …]
|
| /dports/mail/thunderbird/thunderbird-91.8.0/comm/third_party/libgcrypt/src/ |
| H A D | secmem.c | 460 pool->mem = mmap (0, pool->size, in init_pool()
479 pool->mem = malloc (pool->size); in init_pool()
679 for (pool = pool->next; pool; pool = pool->next) in _gcry_secmem_malloc_internal()
692 pool = calloc (1, sizeof *pool); in _gcry_secmem_malloc_internal()
696 pool->mem = malloc (pool->size); in _gcry_secmem_malloc_internal()
757 for (pool = &mainpool; pool; pool = pool->next) in _gcry_secmem_free_internal()
758 if (pool->okay && ptr_into_pool_p (pool, a)) in _gcry_secmem_free_internal()
862 for (pool = &mainpool; pool; pool = pool->next) in _gcry_private_is_secure()
883 for (pool = &mainpool; pool; pool = next) in _gcry_secmem_term()
897 munmap (pool->mem, pool->size); in _gcry_secmem_term()
[all …]
|
| /dports/java/java-subversion/subversion-1.14.1/subversion/tests/libsvn_ra/ |
| H A D | ra-test.c | 62 pool, pool)); in make_and_open_repos()
310 apr_pool_t *pool; member
340 b.pool = pool; in location_segments_test()
554 baton.pool = pool; in lock_test()
936 pool, pool); in ra_revision_errors()
955 pool, pool); in ra_revision_errors()
974 pool, pool); in ra_revision_errors()
1336 pool, pool), in ra_revision_errors()
1605 pool, pool)); in tunnel_run_checkout()
1731 opts, pool, pool)); in commit_locked_file()
[all …]
|
| /dports/devel/py-subversion/subversion-1.14.1/subversion/tests/libsvn_ra/ |
| H A D | ra-test.c | 62 pool, pool)); in make_and_open_repos()
310 apr_pool_t *pool; member
340 b.pool = pool; in location_segments_test()
554 baton.pool = pool; in lock_test()
936 pool, pool); in ra_revision_errors()
955 pool, pool); in ra_revision_errors()
974 pool, pool); in ra_revision_errors()
1336 pool, pool), in ra_revision_errors()
1605 pool, pool)); in tunnel_run_checkout()
1731 opts, pool, pool)); in commit_locked_file()
[all …]
|
| /dports/security/subversion-gnome-keyring/subversion-1.14.1/subversion/tests/libsvn_ra/ |
| H A D | ra-test.c | 62 pool, pool)); in make_and_open_repos()
310 apr_pool_t *pool; member
340 b.pool = pool; in location_segments_test()
554 baton.pool = pool; in lock_test()
936 pool, pool); in ra_revision_errors()
955 pool, pool); in ra_revision_errors()
974 pool, pool); in ra_revision_errors()
1336 pool, pool), in ra_revision_errors()
1605 pool, pool)); in tunnel_run_checkout()
1731 opts, pool, pool)); in commit_locked_file()
[all …]
|
| /dports/devel/p5-subversion/subversion-1.14.1/subversion/tests/libsvn_ra/ |
| H A D | ra-test.c | 62 pool, pool)); in make_and_open_repos()
310 apr_pool_t *pool; member
340 b.pool = pool; in location_segments_test()
554 baton.pool = pool; in lock_test()
936 pool, pool); in ra_revision_errors()
955 pool, pool); in ra_revision_errors()
974 pool, pool); in ra_revision_errors()
1336 pool, pool), in ra_revision_errors()
1605 pool, pool)); in tunnel_run_checkout()
1731 opts, pool, pool)); in commit_locked_file()
[all …]
|
| /dports/math/mpsolve/mpsolve-3.2.1/src/libmps/system/ |
| H A D | threading.c | 192 mps_thread_pool * pool = thread->pool; in mps_thread_mainloop() local
263 pool = s->pool; in mps_thread_pool_set_concurrency_limit()
302 if (!pool) in mps_thread_pool_assign()
303 pool = s->pool; in mps_thread_pool_assign()
305 if (pool->n == 1 && !pool->strict_async) in mps_thread_pool_assign()
321 pool->queue->first = pool->queue->last = item; in mps_thread_pool_assign()
364 pool = s->pool; in mps_thread_new()
375 thread->pool = pool; in mps_thread_new()
413 pool = s->pool; in mps_thread_pool_insert_new_thread()
471 pool->queue->first = pool->queue->last = NULL; in mps_thread_pool_new()
[all …]
|