| /external/perfetto/src/trace_processor/ |
| D | string_pool.cc | 88 StringPool::Iterator::Iterator(const StringPool* pool) : pool_(pool) {} in Iterator()
91 PERFETTO_DCHECK(block_id_ < pool_->blocks_.size()); in operator ++()
94 const auto& block = pool_->blocks_[block_id_]; in operator ++()
110 return block_id_ < pool_->blocks_.size(); in operator bool()
114 PERFETTO_DCHECK(block_id_ < pool_->blocks_.size()); in StringView()
115 PERFETTO_DCHECK(block_offset_ < pool_->blocks_[block_id_].pos()); in StringView()
120 return GetFromPtr(pool_->blocks_[block_id_].Get(block_offset_)); in StringView()
124 PERFETTO_DCHECK(block_id_ < pool_->blocks_.size()); in StringId()
125 PERFETTO_DCHECK(block_offset_ < pool_->blocks_[block_id_].pos()); in StringId()
130 return pool_->PtrToId(pool_->blocks_[block_id_].Get(block_offset_)); 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/protobuf/src/google/protobuf/ |
| D | dynamic_message_unittest.cc | 66 DescriptorPool pool_; member in google::protobuf::DynamicMessageTest
79 DynamicMessageTest(): factory_(&pool_) {} in DynamicMessageTest()
99 ASSERT_TRUE(pool_.BuildFile(unittest_import_public_file) != NULL); in SetUp()
100 ASSERT_TRUE(pool_.BuildFile(unittest_import_file) != NULL); in SetUp()
101 ASSERT_TRUE(pool_.BuildFile(unittest_file) != NULL); in SetUp()
102 ASSERT_TRUE(pool_.BuildFile(unittest_no_field_presence_file) != NULL); in SetUp()
104 descriptor_ = pool_.FindMessageTypeByName("protobuf_unittest.TestAllTypes"); in SetUp()
109 pool_.FindMessageTypeByName("protobuf_unittest.TestAllExtensions"); in SetUp()
114 pool_.FindMessageTypeByName("protobuf_unittest.TestPackedTypes"); in SetUp()
119 pool_.FindMessageTypeByName("protobuf_unittest.TestOneof2"); in SetUp()
[all …]
|
| D | descriptor_unittest.cc | 286 foo_file_ = pool_.BuildFile(foo_file); in SetUp()
289 bar_file_ = pool_.BuildFile(bar_file); in SetUp()
292 baz_file_ = pool_.BuildFile(baz_file); in SetUp()
318 DescriptorPool pool_; member in google::protobuf::descriptor_unittest::FileDescriptorTest
415 EXPECT_EQ(foo_extension_, pool_.FindExtensionByNumber(foo_message_, 1)); in TEST_F()
416 EXPECT_EQ(bar_extension_, pool_.FindExtensionByNumber(bar_message_, 1)); in TEST_F()
418 EXPECT_TRUE(pool_.FindExtensionByNumber(foo_message_, 2) == NULL); in TEST_F()
426 EXPECT_EQ(foo_file_, pool_.BuildFile(file)); in TEST_F()
430 EXPECT_TRUE(pool_.BuildFile(file) == NULL); in TEST_F()
440 const FileDescriptor* proto2_descriptor = pool_.BuildFile(proto_syntax2); in TEST_F()
[all …]
|
| D | descriptor_database.cc | 393 : pool_(pool) {} in DescriptorPoolDatabase()
399 const FileDescriptor* file = pool_.FindFileByName(filename); in FindFileByName()
409 const FileDescriptor* file = pool_.FindFileContainingSymbol(symbol_name); in FindFileContainingSymbol()
420 const Descriptor* extendee = pool_.FindMessageTypeByName(containing_type); in FindFileContainingExtension()
424 pool_.FindExtensionByNumber(extendee, field_number); in FindFileContainingExtension()
435 const Descriptor* extendee = pool_.FindMessageTypeByName(extendee_type); in FindAllExtensionNumbers()
439 pool_.FindAllExtensions(extendee, &extensions); in FindAllExtensionNumbers()
|
| /external/tensorflow/tensorflow/core/common_runtime/ |
| D | eigen_thread_pool.h | 26 explicit EigenThreadPoolWrapper(thread::ThreadPool* pool) : pool_(pool) {} in EigenThreadPoolWrapper()
30 pool_->Schedule(std::move(fn)); in Schedule()
32 int NumThreads() const override { return pool_->NumThreads(); } in NumThreads()
33 int CurrentThreadId() const override { return pool_->CurrentThreadId(); } in CurrentThreadId()
36 thread::ThreadPool* pool_ = nullptr;
|
| 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 | 62 pool_ = new thread::ThreadPool(options->env, "blocking", in Benchmark()
66 pool_->Schedule(closure); in Benchmark()
111 delete pool_; in ~Benchmark()
155 pool_->Schedule(closure); in RunWithArgs()
|
| /external/tensorflow/tensorflow/lite/kernels/ |
| D | eigen_support.cc | 57 explicit EigenThreadPoolWrapper(Eigen::ThreadPool* pool) : pool_(pool) {} in EigenThreadPoolWrapper()
61 pool_->Schedule(std::move(fn)); in Schedule()
63 int NumThreads() const override { return pool_->NumThreads(); } in NumThreads()
64 int CurrentThreadId() const override { return pool_->CurrentThreadId(); } in CurrentThreadId()
67 std::unique_ptr<Eigen::ThreadPool> pool_; member in tflite::eigen_support::__anon64c280760111::EigenThreadPoolWrapper
|
| /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/tensorflow/tensorflow/core/grappler/optimizers/ |
| D | evaluation_utils.cc | 32 explicit EigenThreadPoolWrapper(thread::ThreadPool* pool) : pool_(pool) {} in EigenThreadPoolWrapper()
42 pool_->Schedule(std::move(wrapped)); in Schedule()
44 int NumThreads() const override { return pool_->NumThreads(); } in NumThreads()
45 int CurrentThreadId() const override { return pool_->CurrentThreadId(); } in CurrentThreadId()
48 thread::ThreadPool* pool_ = nullptr; member in tensorflow::grappler::__anondc970a030111::EigenThreadPoolWrapper
|
| /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];
|
| D | socketpool.h | 63 StreamPool* pool_; variable
131 StreamPool* pool_;
|
| D | httpclient.h | 67 void set_pool(StreamPool* pool) { pool_ = pool; } in set_pool()
166 StreamPool* pool_; variable
|
| D | scoped_autorelease_pool.h | 51 NSAutoreleasePool* pool_; variable
|
| /external/gemmlowp/meta/ |
| D | multi_thread_common.h | 36 : max_num_threads_(max_num_threads), pool_(pool) {} in SimpleContext()
38 WorkersPool* workers_pool() { return pool_; } in workers_pool()
44 WorkersPool* pool_; variable
|
| /external/tensorflow/tensorflow/compiler/xla/service/ |
| D | backend.cc | 74 : pool_(pool) {} in EigenThreadPoolWrapper()
78 pool_->Schedule(std::move(fn)); in Schedule()
80 int NumThreads() const override { return pool_->NumThreads(); } in NumThreads()
81 int CurrentThreadId() const override { return pool_->CurrentThreadId(); } in CurrentThreadId()
84 tensorflow::thread::ThreadPool* pool_ = nullptr; member in xla::__anonf38de3580111::EigenThreadPoolWrapper
|
| /external/tensorflow/tensorflow/core/kernels/data/ |
| D | unbounded_thread_pool.cc | 29 explicit LogicalThreadFactory(UnboundedThreadPool* pool) : pool_(pool) {} in LogicalThreadFactory()
33 return pool_->RunOnPooledThread(std::move(fn)); in StartThread()
37 UnboundedThreadPool* const pool_; // Not owned. member in tensorflow::data::UnboundedThreadPool::LogicalThreadFactory
|
| /external/protobuf/src/google/protobuf/compiler/ |
| D | importer.cc | 206 pool_(&database_, database_.GetValidationErrorCollector()) { in Importer()
207 pool_.EnforceWeakDependencies(true); in Importer()
214 return pool_.FindFileByName(filename); in Import()
218 pool_.AddUnusedImportTrackFile(file_name); in AddUnusedImportTrackFile()
222 pool_.ClearUnusedImportTrackFiles(); in ClearUnusedImportTrackFiles()
|
| D | importer.h | 172 return &pool_; in pool()
180 DescriptorPool pool_; variable
|
| D | parser_unittest.cc | 173 EXPECT_TRUE(pool_.BuildFileCollectingErrors( in ExpectHasValidationErrors()
179 DescriptorPool pool_; member in google::protobuf::compiler::__anone5943b270111::ParserTest
1472 EXPECT_TRUE(pool_.BuildFile(other_file) != NULL); in TEST_F()
1626 EXPECT_TRUE(pool_.BuildFile(other_file) != NULL); in TEST_F()
1647 ASSERT_TRUE(pool_.BuildFile(descriptor_proto) != NULL); in TEST_F()
1676 EXPECT_TRUE(pool_.BuildFile(other_file) != NULL); in TEST_F()
1783 ASSERT_TRUE(pool_.BuildFile(public_import_proto) != NULL); in TEST_F()
1788 ASSERT_TRUE(pool_.BuildFile(import_proto) != NULL); in TEST_F()
1789 const FileDescriptor* actual = pool_.BuildFile(parsed); in TEST_F()
1832 ASSERT_TRUE(pool_.BuildFile(import_proto) != NULL); in TEST_F()
[all …]
|
| /external/protobuf/src/google/protobuf/util/ |
| D | type_resolver_util.cc | 72 : url_prefix_(url_prefix), pool_(pool) {} in DescriptorPoolTypeResolver()
86 const Descriptor* descriptor = pool_->FindMessageTypeByName(message_name); in ResolveMessageType()
107 const EnumDescriptor* descriptor = pool_->FindEnumTypeByName(type_name); in ResolveEnumType()
247 const DescriptorPool* pool_; member in google::protobuf::util::__anon8a6231ae0111::DescriptorPoolTypeResolver
|
| /external/tensorflow/tensorflow/core/common_runtime/data/ |
| D | standalone.cc | 118 pool_(pool) { in Dataset()
119 runner_ = [this](std::function<void()> c) { pool_->Schedule(std::move(c)); }; in Dataset()
|
| /external/libchrome/testing/ |
| D | platform_test.h | 29 id pool_;
|