| /external/skia/tests/ |
| D | SkBlockAllocatorTest.cpp | 24 static size_t ScratchBlockSize(SkSBlockAllocator<N>& pool) { in ScratchBlockSize() argument
25 return (size_t) pool->scratchBlockSize(); in ScratchBlockSize()
31 static int block_count(const SkSBlockAllocator<N>& pool) { in block_count() argument
33 for (const Block* b : pool->blocks()) { in block_count()
41 static Block* get_block(SkSBlockAllocator<N>& pool, int blockIndex) { in get_block() argument
44 for (Block* b: pool->blocks()) { in get_block()
60 static size_t total_size(SkSBlockAllocator<N>& pool) { in total_size() argument
61 return pool->totalSize() - BlockAllocatorTestAccess::ScratchBlockSize(pool); in total_size()
65 static size_t add_block(SkSBlockAllocator<N>& pool) { in add_block() argument
66 size_t currentSize = total_size(pool); in add_block()
[all …]
|
| /external/mesa3d/src/gallium/drivers/r600/ |
| D | compute_memory_pool.c | 48 static void compute_memory_shadow(struct compute_memory_pool* pool,
51 static void compute_memory_defrag(struct compute_memory_pool *pool,
55 static int compute_memory_promote_item(struct compute_memory_pool *pool,
59 static void compute_memory_move_item(struct compute_memory_pool *pool,
64 static void compute_memory_transfer(struct compute_memory_pool* pool,
70 * Creates a new pool.
75 struct compute_memory_pool* pool = (struct compute_memory_pool*) in compute_memory_pool_new() local
77 if (!pool) in compute_memory_pool_new()
82 pool->screen = rscreen; in compute_memory_pool_new()
83 pool->item_list = (struct list_head *) in compute_memory_pool_new()
[all …]
|
| /external/tensorflow/tensorflow/core/common_runtime/gpu/ |
| D | pool_allocator_test.cc | 31 PoolAllocator pool( in TEST() local
37 new NoopRounder, "pool"); in TEST()
39 EXPECT_EQ(nullptr, pool.AllocateRaw(4 /*alignment*/, 0 /*num_bytes*/)); in TEST()
40 pool.DeallocateRaw(nullptr); // Should not crash. in TEST()
41 EXPECT_EQ(0, pool.get_from_pool_count()); in TEST()
42 EXPECT_EQ(0, pool.put_count()); in TEST()
43 EXPECT_EQ(0, pool.allocated_count()); in TEST()
44 EXPECT_EQ(0, pool.evicted_count()); in TEST()
51 PoolAllocator pool( in TEST() local
57 new NoopRounder, "pool"); in TEST()
[all …]
|
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/ |
| D | ConnectionPoolTest.java | 48 ConnectionPool pool = new ConnectionPool(Integer.MAX_VALUE, 100L, TimeUnit.NANOSECONDS); in connectionsEvictedWhenIdleLongEnough() local
49 pool.setCleanupRunnableForTest(emptyRunnable); in connectionsEvictedWhenIdleLongEnough()
51 RealConnection c1 = newConnection(pool, routeA1, 50L); in connectionsEvictedWhenIdleLongEnough()
53 // Running at time 50, the pool returns that nothing can be evicted until time 150. in connectionsEvictedWhenIdleLongEnough()
54 assertEquals(100L, pool.cleanup(50L)); in connectionsEvictedWhenIdleLongEnough()
55 assertEquals(1, pool.getConnectionCount()); in connectionsEvictedWhenIdleLongEnough()
58 // Running at time 60, the pool returns that nothing can be evicted until time 150. in connectionsEvictedWhenIdleLongEnough()
59 assertEquals(90L, pool.cleanup(60L)); in connectionsEvictedWhenIdleLongEnough()
60 assertEquals(1, pool.getConnectionCount()); in connectionsEvictedWhenIdleLongEnough()
63 // Running at time 149, the pool returns that nothing can be evicted until time 150. in connectionsEvictedWhenIdleLongEnough()
[all …]
|
| /external/mesa3d/src/gallium/frontends/nine/ |
| D | threadpool.c | 44 struct threadpool *pool = data; in threadpool_worker() local
46 pthread_mutex_lock(&pool->m); in threadpool_worker()
48 while (!pool->shutdown) { in threadpool_worker()
52 while (!pool->workqueue && !pool->shutdown) in threadpool_worker()
53 pthread_cond_wait(&pool->new_work, &pool->m); in threadpool_worker()
55 if (pool->shutdown) in threadpool_worker()
62 task = pool->workqueue; in threadpool_worker()
63 pool->workqueue = task->next; in threadpool_worker()
66 pthread_mutex_unlock(&pool->m); in threadpool_worker()
68 pthread_mutex_lock(&pool->m); in threadpool_worker()
[all …]
|
| /external/wayland/src/ |
| D | wayland-shm.c | 75 struct wl_shm_pool *pool; member
85 shm_pool_finish_resize(struct wl_shm_pool *pool) in shm_pool_finish_resize() argument
89 if (pool->size == pool->new_size) in shm_pool_finish_resize()
92 data = mremap(pool->data, pool->size, pool->new_size, MREMAP_MAYMOVE); in shm_pool_finish_resize()
94 wl_resource_post_error(pool->resource, in shm_pool_finish_resize()
100 pool->data = data; in shm_pool_finish_resize()
101 pool->size = pool->new_size; in shm_pool_finish_resize()
105 shm_pool_unref(struct wl_shm_pool *pool, bool external) in shm_pool_unref() argument
108 pool->external_refcount--; in shm_pool_unref()
109 if (pool->external_refcount == 0) in shm_pool_unref()
[all …]
|
| /external/deqp/framework/delibs/depool/ |
| D | deMemPool.c | 2 * drawElements Memory Pool Library
21 * \brief Memory pool management.
48 * Represent a page of memory allocate by a memory pool.
69 * \brief Memory pool.
71 * A pool of memory from which individual memory allocations can be made.
73 * but rather all of the memory allocated from a pool is freed when the pool
76 * The pools can be arranged into a hierarchy. If a pool with children is
78 * the pool itself.
82 * creating the root pool with the deMemPool_createFailingRoot() function.
92 deMemPool* firstChild; /*!< Pointer to first child pool in linked list. */
[all …]
|
| /external/autotest/site_utils/ |
| D | balance_pools.py | 6 """Adjust pool balances to cover DUT shortfalls.
8 This command takes all broken DUTs in a specific pool for specific
9 models and swaps them with working DUTs taken from a selected pool
12 pool sizes, or to create or remove pools.
14 usage: balance_pool.py [ options ] POOL MODEL [ MODEL ... ]
17 POOL Name of the pool to balance
23 Set the number of DUTs in the pool to the specified
26 Add the specified number of DUTs to the pool for every
29 Remove the specified number of DUTs from the pool for
31 -s POOL, --spare POOL
[all …]
|
| /external/libiio/src/iiod/ |
| D | thread-pool.c | 18 #include "thread-pool.h"
46 struct thread_pool *pool; member
51 static void thread_pool_thread_started(struct thread_pool *pool) in thread_pool_thread_started() argument
53 pthread_mutex_lock(&pool->thread_count_lock); in thread_pool_thread_started()
54 pool->thread_count++; in thread_pool_thread_started()
55 pthread_mutex_unlock(&pool->thread_count_lock); in thread_pool_thread_started()
58 static void thread_pool_thread_stopped(struct thread_pool *pool) in thread_pool_thread_stopped() argument
60 pthread_mutex_lock(&pool->thread_count_lock); in thread_pool_thread_stopped()
61 pool->thread_count--; in thread_pool_thread_stopped()
62 pthread_cond_signal(&pool->thread_count_cond); in thread_pool_thread_stopped()
[all …]
|
| /external/linux-kselftest/tools/testing/selftests/drivers/net/mlxsw/ |
| D | sharedbuffer_configuration.py | 16 objects, pool, tcbind and portpool. Provide an interface to get random
18 1. Pool:
22 - random pool number
30 for pool in pools:
31 self._pools.append(pool)
47 def _get_th(self, pool): argument
50 if pool["thtype"] == "dynamic":
58 for pool in self._pools:
59 if pool["type"] == "ingress":
60 ing_pools.append(pool)
[all …]
|
| /external/cronet/third_party/boringssl/src/crypto/pool/ |
| D | pool.c | 15 #include <openssl/pool.h>
31 return (uint32_t)SIPHASH_24(buf->pool->hash_key, buf->data, buf->len); in CRYPTO_BUFFER_hash()
35 // Only |CRYPTO_BUFFER|s from the same pool have compatible hashes. in CRYPTO_BUFFER_cmp()
36 assert(a->pool != NULL); in CRYPTO_BUFFER_cmp()
37 assert(a->pool == b->pool); in CRYPTO_BUFFER_cmp()
45 CRYPTO_BUFFER_POOL *pool = OPENSSL_malloc(sizeof(CRYPTO_BUFFER_POOL)); in CRYPTO_BUFFER_POOL_new() local
46 if (pool == NULL) { in CRYPTO_BUFFER_POOL_new()
50 OPENSSL_memset(pool, 0, sizeof(CRYPTO_BUFFER_POOL)); in CRYPTO_BUFFER_POOL_new()
51 pool->bufs = lh_CRYPTO_BUFFER_new(CRYPTO_BUFFER_hash, CRYPTO_BUFFER_cmp); in CRYPTO_BUFFER_POOL_new()
52 if (pool->bufs == NULL) { in CRYPTO_BUFFER_POOL_new()
[all …]
|
| /external/boringssl/src/crypto/pool/ |
| D | pool.c | 15 #include <openssl/pool.h>
31 return (uint32_t)SIPHASH_24(buf->pool->hash_key, buf->data, buf->len); in CRYPTO_BUFFER_hash()
35 // Only |CRYPTO_BUFFER|s from the same pool have compatible hashes. in CRYPTO_BUFFER_cmp()
36 assert(a->pool != NULL); in CRYPTO_BUFFER_cmp()
37 assert(a->pool == b->pool); in CRYPTO_BUFFER_cmp()
45 CRYPTO_BUFFER_POOL *pool = OPENSSL_malloc(sizeof(CRYPTO_BUFFER_POOL)); in CRYPTO_BUFFER_POOL_new() local
46 if (pool == NULL) { in CRYPTO_BUFFER_POOL_new()
50 OPENSSL_memset(pool, 0, sizeof(CRYPTO_BUFFER_POOL)); in CRYPTO_BUFFER_POOL_new()
51 pool->bufs = lh_CRYPTO_BUFFER_new(CRYPTO_BUFFER_hash, CRYPTO_BUFFER_cmp); in CRYPTO_BUFFER_POOL_new()
52 if (pool->bufs == NULL) { in CRYPTO_BUFFER_POOL_new()
[all …]
|
| /external/mesa3d/src/util/ |
| D | slab.c | 48 * - a pointer to the child pool to which this element belongs, or
62 /* Next page in the same child pool. */
83 * pool has been destroyed). Mark the element as freed and free the whole page
99 * Create a parent pool for the allocation of same-sized objects.
122 * Create a child pool linked to the given parent.
124 void slab_create_child(struct slab_child_pool *pool, in slab_create_child() argument
127 pool->parent = parent; in slab_create_child()
128 pool->pages = NULL; in slab_create_child()
129 pool->free = NULL; in slab_create_child()
130 pool->migrated = NULL; in slab_create_child()
[all …]
|
| /external/virglrenderer/src/venus/ |
| D | vkr_cs.c | 194 struct vkr_cs_decoder_temp_pool *pool = &dec->temp_pool; in vkr_cs_decoder_fini() local
195 for (uint32_t i = 0; i < pool->buffer_count; i++) in vkr_cs_decoder_fini()
196 free(pool->buffers[i]); in vkr_cs_decoder_fini()
197 if (pool->buffers) in vkr_cs_decoder_fini()
198 free(pool->buffers); in vkr_cs_decoder_fini()
204 const struct vkr_cs_decoder_temp_pool *pool = &dec->temp_pool; in vkr_cs_decoder_sanity_check() local
205 assert(pool->buffer_count <= pool->buffer_max); in vkr_cs_decoder_sanity_check()
206 if (pool->buffer_count) { in vkr_cs_decoder_sanity_check()
207 assert(pool->buffers[pool->buffer_count - 1] <= pool->reset_to); in vkr_cs_decoder_sanity_check()
208 assert(pool->reset_to <= pool->cur); in vkr_cs_decoder_sanity_check()
[all …]
|
| /external/iproute2/man/man8/ |
| D | devlink-sb.8 | 33 .B pool
37 .BI "devlink sb pool set " DEV "
41 .BI pool " POOL_INDEX "
53 .B pool
57 .BI "devlink sb port pool set " DEV/PORT_INDEX "
61 .BI pool " POOL_INDEX "
85 .BI pool " POOL_INDEX "
124 .SS devlink sb pool show - display available pools and their attributes
131 .SS devlink sb pool set - set attributes of pool
135 - specifies the devlink device to set pool.
[all …]
|
| /external/mesa3d/src/gallium/drivers/llvmpipe/ |
| D | lp_cs_tpool.c | 27 * compute shader thread pool.
38 struct lp_cs_tpool *pool = data; in lp_cs_tpool_worker() local
42 mtx_lock(&pool->m); in lp_cs_tpool_worker()
44 while (!pool->shutdown) { in lp_cs_tpool_worker()
47 while (list_is_empty(&pool->workqueue) && !pool->shutdown) in lp_cs_tpool_worker()
48 cnd_wait(&pool->new_work, &pool->m); in lp_cs_tpool_worker()
50 if (pool->shutdown) in lp_cs_tpool_worker()
53 task = list_first_entry(&pool->workqueue, struct lp_cs_tpool_task, in lp_cs_tpool_worker()
60 mtx_unlock(&pool->m); in lp_cs_tpool_worker()
62 mtx_lock(&pool->m); in lp_cs_tpool_worker()
[all …]
|
| /external/mesa3d/src/intel/vulkan/ |
| D | anv_allocator.c | 84 * At the next level we can use various sub-allocators. The state pool is a
85 * pool of smaller, fixed size objects, which operates much like the block
86 * pool. It uses a free list for freeing objects, but when it runs out of
87 * space it just allocates a new block from the block pool. This allocator is
189 /* Assert that we only ever grow the pool */ in anv_state_table_expand_range()
202 /* Just leak the old map until we destroy the pool. We can't munmap it in anv_state_table_expand_range()
233 /* The block pool is always initialized to a nonzero size and this function in anv_state_table_grow()
294 /* We allocated the first block outside the pool so we have to grow in anv_state_table_add()
295 * the pool. pool_state->next acts a mutex: threads who try to in anv_state_table_add()
361 anv_block_pool_expand_range(struct anv_block_pool *pool,
[all …]
|
| /external/mesa3d/src/freedreno/vulkan/ |
| D | tu_query.c | 100 * pool. */
101 #define query_iova(type, pool, query, field) \ argument
102 pool->bo.iova + pool->stride * (query) + offsetof(type, field)
104 #define occlusion_query_iova(pool, query, field) \ argument
105 query_iova(struct occlusion_query_slot, pool, query, field)
107 #define pipeline_stat_query_iova(pool, query, field) \ argument
108 pool->bo.iova + pool->stride * query + \
111 #define primitive_query_iova(pool, query, field, i) \ argument
112 query_iova(struct primitive_query_slot, pool, query, field) + \
115 #define query_available_iova(pool, query) \ argument
[all …]
|
| /external/cronet/third_party/protobuf/python/google/protobuf/internal/ |
| D | descriptor_pool_test.py | 68 file_desc1 = self.pool.FindFileByName(name1)
75 file_desc2 = self.pool.FindFileByName(name2)
83 self.pool.FindFileByName('Does not exist')
86 file_desc1 = self.pool.FindFileContainingSymbol(
94 file_desc2 = self.pool.FindFileContainingSymbol(
103 file_desc3 = self.pool.FindFileContainingSymbol(
110 file_desc4 = self.pool.FindFileContainingSymbol(
116 file_desc5 = self.pool.FindFileContainingSymbol(
121 # Tests the generated pool.
130 file_desc6 = self.pool.FindFileContainingSymbol(
[all …]
|
| /external/protobuf/python/google/protobuf/internal/ |
| D | descriptor_pool_test.py | 68 file_desc1 = self.pool.FindFileByName(name1)
75 file_desc2 = self.pool.FindFileByName(name2)
83 self.pool.FindFileByName('Does not exist')
86 file_desc1 = self.pool.FindFileContainingSymbol(
94 file_desc2 = self.pool.FindFileContainingSymbol(
103 file_desc3 = self.pool.FindFileContainingSymbol(
110 file_desc4 = self.pool.FindFileContainingSymbol(
116 file_desc5 = self.pool.FindFileContainingSymbol(
121 # Tests the generated pool.
130 file_desc6 = self.pool.FindFileContainingSymbol(
[all …]
|
| /external/python/cpython2/Doc/includes/ |
| D | mp_pool.py | 2 # A test of `multiprocessing.Pool` class
52 # Create pool
56 print 'Creating pool with %d processes\n' % PROCESSES
57 pool = multiprocessing.Pool(PROCESSES)
58 print 'pool = %s' % pool
68 results = [pool.apply_async(calculate, t) for t in TASKS]
69 imap_it = pool.imap(calculatestar, TASKS)
70 imap_unordered_it = pool.imap_unordered(calculatestar, TASKS)
72 print 'Ordered results using pool.apply_async():'
77 print 'Ordered results using pool.imap():'
[all …]
|
| /external/rust/crates/vulkano/src/descriptor_set/pool/ |
| D | standard.rs | 11 use crate::descriptor_set::pool::DescriptorPool;
12 use crate::descriptor_set::pool::DescriptorPoolAlloc;
13 use crate::descriptor_set::pool::DescriptorPoolAllocError;
14 use crate::descriptor_set::pool::DescriptorsCount;
15 use crate::descriptor_set::pool::UnsafeDescriptorPool;
23 /// Standard implementation of a descriptor pool.
28 /// Whenever a set is allocated, this implementation will try to find a pool that has some space
29 /// for it. If there is one, allocate from it. If there is none, create a new pool whose capacity
33 pools: Mutex<Vec<Arc<Mutex<Pool>>>>,
36 struct Pool { struct
[all …]
|
| /external/mesa3d/src/broadcom/vulkan/ |
| D | v3dv_query.c | 41 struct v3dv_query_pool *pool = in v3dv_CreateQueryPool() local
42 vk_alloc2(&device->alloc, pAllocator, sizeof(*pool), 8, in v3dv_CreateQueryPool()
44 if (pool == NULL) in v3dv_CreateQueryPool()
47 pool->query_type = pCreateInfo->queryType; in v3dv_CreateQueryPool()
48 pool->query_count = pCreateInfo->queryCount; in v3dv_CreateQueryPool()
52 const uint32_t pool_bytes = sizeof(struct v3dv_query) * pool->query_count; in v3dv_CreateQueryPool()
53 pool->queries = vk_alloc2(&device->alloc, pAllocator, pool_bytes, 8, in v3dv_CreateQueryPool()
55 if (pool->queries == NULL) { in v3dv_CreateQueryPool()
61 for (i = 0; i < pool->query_count; i++) { in v3dv_CreateQueryPool()
62 pool->queries[i].maybe_available = false; in v3dv_CreateQueryPool()
[all …]
|
| /external/rust/crates/quiche/deps/boringssl/src/crypto/pool/ |
| D | pool.c | 15 #include <openssl/pool.h>
43 CRYPTO_BUFFER_POOL *pool = OPENSSL_malloc(sizeof(CRYPTO_BUFFER_POOL)); in CRYPTO_BUFFER_POOL_new() local
44 if (pool == NULL) { in CRYPTO_BUFFER_POOL_new()
48 OPENSSL_memset(pool, 0, sizeof(CRYPTO_BUFFER_POOL)); in CRYPTO_BUFFER_POOL_new()
49 pool->bufs = lh_CRYPTO_BUFFER_new(CRYPTO_BUFFER_hash, CRYPTO_BUFFER_cmp); in CRYPTO_BUFFER_POOL_new()
50 if (pool->bufs == NULL) { in CRYPTO_BUFFER_POOL_new()
51 OPENSSL_free(pool); in CRYPTO_BUFFER_POOL_new()
55 CRYPTO_MUTEX_init(&pool->lock); in CRYPTO_BUFFER_POOL_new()
57 return pool; in CRYPTO_BUFFER_POOL_new()
60 void CRYPTO_BUFFER_POOL_free(CRYPTO_BUFFER_POOL *pool) { in CRYPTO_BUFFER_POOL_free() argument
[all …]
|
| /external/armnn/src/backends/tosaReference/ |
| D | TosaRefMemoryManager.cpp | 20 TosaRefMemoryManager::Pool* TosaRefMemoryManager::Manage(unsigned int numBytes) in Manage()
24 Pool* res = m_FreePools.back(); in Manage()
31 m_Pools.push_front(Pool(numBytes)); in Manage()
36 void TosaRefMemoryManager::Allocate(TosaRefMemoryManager::Pool* pool) in Allocate() argument
38 ARMNN_ASSERT(pool); in Allocate()
39 m_FreePools.push_back(pool); in Allocate()
42 void* TosaRefMemoryManager::GetPointer(TosaRefMemoryManager::Pool* pool) in GetPointer() argument
44 return pool->GetPointer(); in GetPointer()
49 for (Pool &pool: m_Pools) in Acquire()
51 pool.Acquire(); in Acquire()
[all …]
|