| /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 | 130 StringPool::Iterator::Iterator(const StringPool* pool) : pool_(pool) {} in Iterator()
133 if (block_index_ < pool_->blocks_.size()) { in operator ++()
135 const auto& block = pool_->blocks_[block_index_]; in operator ++()
155 PERFETTO_DCHECK(large_strings_index_ < pool_->large_strings_.size()); in operator ++()
161 return block_index_ < pool_->blocks_.size() || in operator bool()
162 large_strings_index_ < pool_->large_strings_.size(); in operator bool()
166 return pool_->Get(StringId()); in StringView()
170 if (block_index_ < pool_->blocks_.size()) { in StringId()
171 PERFETTO_DCHECK(block_offset_ < pool_->blocks_[block_index_].pos()); in StringId()
178 PERFETTO_DCHECK(large_strings_index_ < pool_->large_strings_.size()); in StringId()
|
| /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 | 63 pool_.reset(new Eigen::ThreadPool(num_threads)); in EigenThreadPoolWrapper()
69 if (pool_) { in Schedule()
70 pool_->Schedule(std::move(fn)); in Schedule()
75 int NumThreads() const override { return pool_ ? pool_->NumThreads() : 1; } in NumThreads()
77 return pool_ ? pool_->CurrentThreadId() : 0; in CurrentThreadId()
82 std::unique_ptr<Eigen::ThreadPool> pool_; member in tflite::eigen_support::__anon20e3d0b80111::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/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()
144 while (pool_.size() >= pool_size_limit_) { in DeallocateRaw()
151 pool_.insert(std::make_pair(cp->num_bytes, pr)); in DeallocateRaw()
158 for (auto iter : pool_) { in Clear()
163 pool_.clear(); in Clear()
208 auto iter = pool_.find(prec->num_bytes); in EvictOne()
211 DCHECK(iter != pool_.end()); in EvictOne()
213 pool_.erase(iter); in EvictOne()
|
| D | kernel_benchmark_testlib.cc | 69 pool_ = in Benchmark()
73 pool_->Schedule(closure); in Benchmark()
116 delete pool_; in ~Benchmark()
149 pool_->Schedule(closure); in RunWithRendezvousArgs()
|
| /external/tensorflow/tensorflow/compiler/xla/python/ |
| D | event_pool.cc | 24 if (pool_ && event_) { in ~Handle()
25 absl::MutexLock lock(&pool_->mu_); in ~Handle()
26 pool_->free_events_.push(std::move(event_)); in ~Handle()
37 event.pool_ = this; in ThenAllocateAndRecordEvent()
|
| /external/eigen/unsupported/Eigen/CXX11/src/Tensor/ |
| D | TensorDeviceThreadPool.h | 109 …ThreadPoolDevice(ThreadPoolInterface* pool, int num_cores) : pool_(pool), num_threads_(num_cores) … in ThreadPoolDevice()
154 …pool_->Schedule(std::bind(&FunctionWrapperWithNotification<Function, Args...>::run, n, f, args...)… in enqueue()
162 pool_->Schedule(std::bind( in enqueue_with_barrier()
168 pool_->Schedule(std::bind(f, args...)); in enqueueNoNotification()
174 return pool_->CurrentThreadId(); in currentThreadId()
258 pool_->Schedule([=, &handleRange]() { handleRange(mid, last); }); in parallelFor()
259 pool_->Schedule([=, &handleRange]() { handleRange(first, mid); }); in parallelFor()
272 ThreadPoolInterface* pool_;
|
| /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/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()
34 device_->GetVkDevice(), pool_->GetVkCommandPool(), 1, &command_); in ~CommandBuffer()
41 command_info.commandPool = pool_->GetVkCommandPool(); in Initialize()
|
| /external/webrtc/webrtc/base/ |
| D | socketpool.cc | 27 StreamCache::StreamCache(StreamPool* pool) : pool_(pool) { in StreamCache()
57 if (StreamInterface* stream = pool_->RequestConnectedStream(remote, err)) { in RequestConnectedStream()
74 pool_->ReturnConnectedStream(it->second); in ReturnConnectedStream()
101 pool_->ReturnConnectedStream(it->second); in OnStreamEvent()
239 : pool_(pool), level_(level), label_(label), binary_mode_(binary_mode) { in LoggingPoolAdapter()
251 if (StreamInterface* stream = pool_->RequestConnectedStream(remote, err)) { in RequestConnectedStream()
274 pool_->ReturnConnectedStream(logging->Detach()); in ReturnConnectedStream()
|
| D | scoped_autorelease_pool.mm | 18 pool_ = [[NSAutoreleasePool alloc] init];
22 [pool_ drain];
|
| /external/libgav1/libgav1/src/utils/ |
| D | threadpool.cc | 145 ThreadPool* pool_; member in libgav1::ThreadPool::WorkerThread
153 ThreadPool::WorkerThread::WorkerThread(ThreadPool* pool) : pool_(pool) {} in WorkerThread()
201 if (pool_->name_prefix_[0] != '\0') { in SetupName()
209 int rv = snprintf(name, sizeof(name), "%s/%" PRId64, pool_->name_prefix_, in SetupName()
220 int rv = snprintf(name, sizeof(name), "%s/%" PRId64, pool_->name_prefix_, in SetupName()
234 pool_->WorkerFunction(); in Run()
|
| /external/perfetto/src/trace_processor/importers/proto/ |
| D | args_table_utils.cc | 37 return pool_.AddFromFileDescriptorSet(proto_descriptor_array, in AddProtoFileDescriptor()
47 auto idx = pool_.FindDescriptorIdx(type); in InternProtoFieldsIntoArgsTable()
52 auto descriptor = pool_.descriptors()[*idx]; in InternProtoFieldsIntoArgsTable()
98 auto opt_proto_descriptor_idx = pool_.FindDescriptorIdx(type); in InternProtoIntoArgsTableInternal()
102 auto proto_descriptor = pool_.descriptors()[*opt_proto_descriptor_idx]; in InternProtoIntoArgsTableInternal()
221 pool_.FindDescriptorIdx(descriptor.resolved_type_name()); in ConvertProtoTypeToVariadic()
227 pool_.descriptors()[*opt_enum_descriptor_idx].FindEnumString( in ConvertProtoTypeToVariadic()
|
| /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/kernels/data/ |
| D | unbounded_thread_pool.cc | 53 explicit LogicalThreadFactory(UnboundedThreadPool* pool) : pool_(pool) {} in LogicalThreadFactory()
58 pool_->ScheduleOnWorkQueue(std::move(fn), done); in StartThread()
63 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::__anon1db7f52a0111::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/v8/src/heap/cppgc/ |
| D | page-memory.cc | 156 pool_[bucket].push_back(std::make_pair(pmr, writeable_base)); in Add()
162 if (pool_[bucket].empty()) return {nullptr, nullptr}; in Take()
163 std::pair<NormalPageMemoryRegion*, Address> pair = pool_[bucket].back(); in Take()
164 pool_[bucket].pop_back(); in Take()
|
| /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()
|
| /external/v8/src/codegen/ |
| D | constant-pool.cc | 441 : pool_(&assm->constpool_) { in BlockScope()
442 pool_->assm_->EmitConstPoolWithJumpIfNeeded(margin); in BlockScope()
443 pool_->StartBlock(); in BlockScope()
447 : pool_(&assm->constpool_) { in BlockScope()
449 pool_->StartBlock(); in BlockScope()
452 ConstantPool::BlockScope::~BlockScope() { pool_->EndBlock(); } in ~BlockScope()
|