| /external/perfetto/src/trace_processor/util/ |
| D | protozero_to_text_unittests.cc | 188 auto status = pool_.AddFromFileDescriptorSet( in SetUp()
193 DescriptorPool pool_; member in perfetto::trace_processor::protozero_to_text::__anon55541b560111::ProtozeroToTextTestMessageTest
200 EXPECT_EQ(ProtozeroToText(pool_, ".protozero.test.protos.EveryField", in TEST_F()
209 EXPECT_EQ(ProtozeroToText(pool_, ".protozero.test.protos.EveryField", in TEST_F()
218 EXPECT_EQ(ProtozeroToText(pool_, ".protozero.test.protos.EveryField", in TEST_F()
227 EXPECT_EQ(ProtozeroToText(pool_, ".protozero.test.protos.EveryField", in TEST_F()
236 EXPECT_EQ(ProtozeroToText(pool_, ".protozero.test.protos.EveryField", in TEST_F()
245 EXPECT_EQ(ProtozeroToText(pool_, ".protozero.test.protos.EveryField", in TEST_F()
254 EXPECT_EQ(ProtozeroToText(pool_, ".protozero.test.protos.EveryField", in TEST_F()
263 EXPECT_EQ(ProtozeroToText(pool_, ".protozero.test.protos.EveryField", in TEST_F()
[all …]
|
| D | proto_to_args_parser.cc | 72 ProtoToArgsParser::ProtoToArgsParser(const DescriptorPool& pool) : pool_(pool) { in ProtoToArgsParser()
101 auto idx = pool_.FindDescriptorIdx(type); in ParseMessageInternal()
106 auto& descriptor = pool_.descriptors()[*idx]; in ParseMessageInternal()
265 pool_.FindDescriptorIdx(descriptor.resolved_type_name()); in ParseSimpleField()
271 pool_.descriptors()[*opt_enum_descriptor_idx].FindEnumString( in ParseSimpleField()
|
| /external/perfetto/src/trace_processor/containers/ |
| D | string_pool_unittest.cc | 35 StringPool pool_; member in perfetto::trace_processor::StringPoolTest
41 ASSERT_EQ(pool_.Get(StringPool::Id::Null()).c_str(), nullptr); in TEST_F()
43 auto it = pool_.CreateIterator(); in TEST_F()
51 auto id = pool_.InternString(kString); in TEST_F()
52 ASSERT_STREQ(pool_.Get(id).c_str(), kString); in TEST_F()
53 ASSERT_EQ(pool_.Get(id), kString); in TEST_F()
54 ASSERT_EQ(id, pool_.InternString(kString)); in TEST_F()
58 auto id = pool_.InternString(NullTermStringView()); in TEST_F()
60 ASSERT_EQ(pool_.Get(id).c_str(), nullptr); in TEST_F()
64 auto it = pool_.CreateIterator(); in TEST_F()
[all …]
|
| D | string_pool.cc | 137 StringPool::Iterator::Iterator(const StringPool* pool) : pool_(pool) {} in Iterator()
140 if (block_index_ < pool_->blocks_.size()) { in operator ++()
142 const auto& block = pool_->blocks_[block_index_]; in operator ++()
162 PERFETTO_DCHECK(large_strings_index_ < pool_->large_strings_.size()); in operator ++()
168 return block_index_ < pool_->blocks_.size() || in operator bool()
169 large_strings_index_ < pool_->large_strings_.size(); in operator bool()
173 return pool_->Get(StringId()); in StringView()
177 if (block_index_ < pool_->blocks_.size()) { in StringId()
178 PERFETTO_DCHECK(block_offset_ < pool_->blocks_[block_index_].pos()); in StringId()
185 PERFETTO_DCHECK(large_strings_index_ < pool_->large_strings_.size()); in StringId()
|
| /external/tensorflow/tensorflow/core/common_runtime/gpu/ |
| D | gpu_cudamallocasync_allocator.cc | 69 pool_, CU_MEMPOOL_ATTR_RESERVED_MEM_CURRENT, &mem_reserved_current)) { in PrintAllocatorStatistics()
75 pool_, CU_MEMPOOL_ATTR_USED_MEM_CURRENT, &mem_used_current)) { in PrintAllocatorStatistics()
81 pool_, CU_MEMPOOL_ATTR_RESERVED_MEM_HIGH, &mem_reserved_high)) { in PrintAllocatorStatistics()
86 if (auto result = cuMemPoolGetAttribute(pool_, CU_MEMPOOL_ATTR_USED_MEM_HIGH, in PrintAllocatorStatistics()
109 pool_ = nullptr; in GpuCudaMallocAsyncAllocator()
141 cuDeviceGetDefaultMemPool(&pool_, platform_device_id.value())) in GpuCudaMallocAsyncAllocator()
150 pool_, CU_MEMPOOL_ATTR_RELEASE_THRESHOLD, &pool_size_64)) in GpuCudaMallocAsyncAllocator()
167 pool_, CU_MEMPOOL_ATTR_REUSE_ALLOW_OPPORTUNISTIC, &disable)) { in GpuCudaMallocAsyncAllocator()
172 pool_, CU_MEMPOOL_ATTR_REUSE_ALLOW_INTERNAL_DEPENDENCIES, in GpuCudaMallocAsyncAllocator()
195 pool_ = nullptr; in GpuCudaMallocAsyncAllocator()
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/src/cpp/server/ |
| D | dynamic_thread_pool.cc | 29 : pool_(pool), in DynamicThread()
41 pool_->ThreadFunc(); in ThreadFunc()
43 grpc_core::MutexLock lock(&pool_->mu_); in ThreadFunc()
44 pool_->nthreads_--; in ThreadFunc()
46 pool_->dead_threads_.push_back(this); in ThreadFunc()
48 if ((pool_->shutdown_) && (pool_->nthreads_ == 0)) { in ThreadFunc()
49 pool_->shutdown_cv_.Signal(); in ThreadFunc()
|
| /external/grpc-grpc/src/cpp/server/ |
| D | dynamic_thread_pool.cc | 30 : pool_(pool), in DynamicThread()
41 pool_->ThreadFunc(); in ThreadFunc()
43 std::unique_lock<std::mutex> lock(pool_->mu_); in ThreadFunc()
44 pool_->nthreads_--; in ThreadFunc()
46 pool_->dead_threads_.push_back(this); in ThreadFunc()
48 if ((pool_->shutdown_) && (pool_->nthreads_ == 0)) { in ThreadFunc()
49 pool_->shutdown_cv_.notify_one(); in ThreadFunc()
|
| /external/tensorflow/tensorflow/lite/kernels/ |
| D | eigen_support.cc | 71 pool_.reset(new Eigen::ThreadPool(num_threads)); in EigenThreadPoolWrapper()
77 if (pool_) { in Schedule()
78 pool_->Schedule(std::move(fn)); in Schedule()
83 int NumThreads() const override { return pool_ ? pool_->NumThreads() : 1; } in NumThreads()
85 return pool_ ? pool_->CurrentThreadId() : 0; in CurrentThreadId()
90 std::unique_ptr<Eigen::ThreadPool> pool_; member in tflite::eigen_support::__anon97ef62d90111::EigenThreadPoolWrapper
|
| /external/protobuf/src/google/protobuf/ |
| D | dynamic_message_unittest.cc | 62 DescriptorPool pool_; member in google::protobuf::DynamicMessageTest
75 DynamicMessageTest() : factory_(&pool_) {} in DynamicMessageTest()
95 ASSERT_TRUE(pool_.BuildFile(unittest_import_public_file) != NULL); in SetUp()
96 ASSERT_TRUE(pool_.BuildFile(unittest_import_file) != NULL); in SetUp()
97 ASSERT_TRUE(pool_.BuildFile(unittest_file) != NULL); in SetUp()
98 ASSERT_TRUE(pool_.BuildFile(unittest_no_field_presence_file) != NULL); in SetUp()
100 descriptor_ = pool_.FindMessageTypeByName("protobuf_unittest.TestAllTypes"); in SetUp()
105 pool_.FindMessageTypeByName("protobuf_unittest.TestAllExtensions"); in SetUp()
110 pool_.FindMessageTypeByName("protobuf_unittest.TestPackedTypes"); in SetUp()
115 pool_.FindMessageTypeByName("protobuf_unittest.TestOneof2"); in SetUp()
[all …]
|
| D | descriptor_unittest.cc | 345 foo_file_ = pool_.BuildFile(foo_file); in SetUp()
348 bar_file_ = pool_.BuildFile(bar_file); in SetUp()
351 baz_file_ = pool_.BuildFile(baz_file); in SetUp()
377 DescriptorPool pool_; member in google::protobuf::descriptor_unittest::FileDescriptorTest
474 EXPECT_EQ(foo_extension_, pool_.FindExtensionByNumber(foo_message_, 1)); in TEST_F()
475 EXPECT_EQ(bar_extension_, pool_.FindExtensionByNumber(bar_message_, 1)); in TEST_F()
477 EXPECT_TRUE(pool_.FindExtensionByNumber(foo_message_, 2) == nullptr); in TEST_F()
486 EXPECT_EQ(foo_file_, pool_.BuildFile(file)); in TEST_F()
490 EXPECT_TRUE(pool_.BuildFile(file) == nullptr); in TEST_F()
500 const FileDescriptor* proto2_descriptor = pool_.BuildFile(proto_syntax2); in TEST_F()
[all …]
|
| /external/zstd/contrib/pzstd/utils/ |
| D | ResourcePool.h | 80 ResourcePool *pool_; variable
82 explicit Deleter(ResourcePool &pool) : pool_(&pool) {} in Deleter()
85 std::lock_guard<std::mutex> lock(pool_->mutex_); in operator()
88 pool_->resources_.push_back(resource); in operator()
90 assert(pool_->inUse_ > 0); in operator()
91 --pool_->inUse_; in operator()
|
| /external/tensorflow/tensorflow/core/common_runtime/ |
| D | pool_allocator.cc | 110 auto iter = pool_.find(num_bytes); in AllocateRaw()
111 if (iter == pool_.end()) { in AllocateRaw()
120 pool_.erase(iter); in AllocateRaw()
145 while (pool_.size() >= pool_size_limit_) { in DeallocateRaw()
152 pool_.insert(std::make_pair(cp->num_bytes, pr)); in DeallocateRaw()
159 for (auto iter : pool_) { in Clear()
164 pool_.clear(); in Clear()
209 auto iter = pool_.find(prec->num_bytes); in EvictOne()
212 DCHECK(iter != pool_.end()); in EvictOne()
214 pool_.erase(iter); in EvictOne()
|
| D | kernel_benchmark_testlib.cc | 74 pool_ = in Benchmark()
78 pool_->Schedule(closure); in Benchmark()
94 flib_def_.get(), OptimizerOptions(), pool_, nullptr, nullptr, in Benchmark()
136 delete pool_; in ~Benchmark()
173 pool_->Schedule(closure); in RunWithRendezvousArgs()
|
| /external/eigen/unsupported/Eigen/CXX11/src/Tensor/ |
| D | TensorDeviceThreadPool.h | 56 : pool_(pool), num_threads_(num_cores), allocator_(allocator) { } in pool_() function
132 return pool_->NumThreads(); in numThreadsInPool()
153 pool_->Schedule( in enqueue()
162 pool_->Schedule( in enqueue_with_barrier()
171 pool_->Schedule(std::bind(std::move(f), args...)); in enqueueNoNotification()
173 pool_->Schedule(std::move(f)); in enqueueNoNotification()
180 return pool_->CurrentThreadId(); in currentThreadId()
215 pool_->Schedule([=, &handleRange]() { handleRange(midIdx, lastIdx); }); in parallelFor()
230 pool_->Schedule([=, &handleRange]() { handleRange(0, n); }); in parallelFor()
274 pool_->Schedule( in parallelForAsync()
[all …]
|
| /external/tensorflow/tensorflow/compiler/xla/pjrt/ |
| D | event_pool.cc | 25 if (pool_ && event_) { in ~Handle()
26 absl::MutexLock lock(&pool_->mu_); in ~Handle()
27 pool_->free_events_.push(std::move(event_)); in ~Handle()
39 event.pool_ = this; in AllocateEvent()
|
| /external/deqp-deps/amber/src/vulkan/ |
| D | command_pool.cc | 25 if (pool_ == VK_NULL_HANDLE) in ~CommandPool()
28 device_->GetPtrs()->vkDestroyCommandPool(device_->GetVkDevice(), pool_, in ~CommandPool()
39 device_->GetVkDevice(), &pool_info, nullptr, &pool_) != VK_SUCCESS) { in Initialize()
|
| D | command_pool.h | 34 VkCommandPool GetVkCommandPool() const { return pool_; } in GetVkCommandPool()
38 VkCommandPool pool_ = VK_NULL_HANDLE; variable
|
| D | command_buffer.cc | 26 : device_(device), pool_(pool) {} in CommandBuffer()
36 device_->GetVkDevice(), pool_->GetVkCommandPool(), 1, &command_); in ~CommandBuffer()
43 command_info.commandPool = pool_->GetVkCommandPool(); in Initialize()
|
| /external/gemmlowp/meta/ |
| D | multi_thread_common.h | 42 : max_num_threads_(max_num_threads), pool_(pool) {} in SimpleContext()
44 WorkersPool* workers_pool() { return pool_; } in workers_pool()
50 WorkersPool* pool_; variable
|
| /external/libgav1/libgav1/src/utils/ |
| D | threadpool.cc | 149 ThreadPool* pool_; member in libgav1::ThreadPool::WorkerThread
157 ThreadPool::WorkerThread::WorkerThread(ThreadPool* pool) : pool_(pool) {} in WorkerThread()
205 if (pool_->name_prefix_[0] != '\0') { in SetupName()
213 int rv = snprintf(name, sizeof(name), "%s/%" PRId64, pool_->name_prefix_, in SetupName()
224 int rv = snprintf(name, sizeof(name), "%s/%" PRId64, pool_->name_prefix_, in SetupName()
238 pool_->WorkerFunction(); in Run()
|
| /external/libgav1/libgav1/src/ |
| D | buffer_pool.cc | 51 std::lock_guard<std::mutex> lock(pool_->mutex_); in Realloc()
56 pool_->get_frame_buffer_, pool_->callback_private_data_, in Realloc()
110 void RefCountedBuffer::SetBufferPool(BufferPool* pool) { pool_ = pool; } in SetBufferPool()
113 ptr->pool_->ReturnUnusedBuffer(ptr); in ReturnToBufferPool()
|
| /external/tensorflow/tensorflow/core/data/ |
| D | unbounded_thread_pool.cc | 55 explicit LogicalThreadFactory(UnboundedThreadPool* pool) : pool_(pool) {} in LogicalThreadFactory()
60 pool_->ScheduleOnWorkQueue(std::move(fn), done); in StartThread()
65 UnboundedThreadPool* const pool_; // Not owned. member in tensorflow::data::UnboundedThreadPool::LogicalThreadFactory
|
| /external/perfetto/src/trace_processor/tables/ |
| D | macros_unittest.cc | 61 StringPool pool_; member in perfetto::trace_processor::__anon8d045fab0111::TableMacrosUnittest
63 TestEventTable event_{&pool_, nullptr};
64 TestCounterTable counter_{&pool_, &event_};
65 TestSliceTable slice_{&pool_, &event_};
66 TestCpuSliceTable cpu_slice_{&pool_, &slice_};
111 auto reason = pool_.InternString("R"); in TEST_F()
356 row.end_state = pool_.InternString("R"); in TEST_F()
359 row.end_state = pool_.InternString("D"); in TEST_F()
412 row.end_state = pool_.InternString("D"); in TEST_F()
|
| /external/libgav1/libgav1/examples/ |
| D | gav1_decode_cv_pixel_buffer_pool.cc | 85 CVPixelBufferPoolRelease(pool_); in ~Gav1DecodeCVPixelBufferPool()
183 CVPixelBufferPoolRelease(pool_); in OnCVPixelBufferSizeChanged()
184 pool_ = cv_pool; in OnCVPixelBufferSizeChanged()
221 /*allocator=*/nullptr, pool_, aux_attributes.get(), &pixel_buffer); in GetCVPixelBuffer()
|
| /external/protobuf/src/google/protobuf/compiler/ |
| D | importer.cc | 226 pool_(&database_, database_.GetValidationErrorCollector()) { in Importer()
227 pool_.EnforceWeakDependencies(true); in Importer()
234 return pool_.FindFileByName(filename); in Import()
238 pool_.AddUnusedImportTrackFile(file_name); in AddUnusedImportTrackFile()
242 pool_.ClearUnusedImportTrackFiles(); in ClearUnusedImportTrackFiles()
|