| /external/libchrome/base/threading/ |
| D | worker_pool_posix_unittest.cc | 24 : pool_(pool) {} in PosixDynamicThreadPoolPeer()
26 Lock* lock() { return &pool_->lock_; } in lock()
28 return &pool_->pending_tasks_available_cv_; in pending_tasks_available_cv()
31 return pool_->pending_tasks_; in pending_tasks()
33 int num_idle_threads() const { return pool_->num_idle_threads_; } in num_idle_threads()
35 return pool_->num_idle_threads_cv_.get(); in num_idle_threads_cv()
38 pool_->num_idle_threads_cv_.reset(cv); in set_num_idle_threads_cv()
42 PosixDynamicThreadPool* pool_; member in base::PosixDynamicThreadPool::PosixDynamicThreadPoolPeer
94 : pool_(new base::PosixDynamicThreadPool("dynamic_pool", 60 * 60)), in PosixDynamicThreadPoolTest()
95 peer_(pool_.get()), in PosixDynamicThreadPoolTest()
[all …]
|
| D | worker_pool_posix.cc | 56 scoped_refptr<base::PosixDynamicThreadPool> pool_; member in base::__anon5a8b849a0111::WorkerPoolImpl
60 : pool_(new base::PosixDynamicThreadPool("WorkerPool", in WorkerPoolImpl()
66 pool_->PostTask(from_here, std::move(task)); in PostTask()
76 : name_prefix_(name_prefix), pool_(pool) {} in WorkerThread()
82 scoped_refptr<base::PosixDynamicThreadPool> pool_; member in base::__anon5a8b849a0111::WorkerThread
95 PendingTask pending_task = pool_->WaitForTask(); in ThreadMain()
|
| D | sequenced_worker_pool.cc | 157 const scoped_refptr<SequencedWorkerPool> pool_; member in base::__anon2d9665c40111::SequencedWorkerPoolTaskRunner
167 : pool_(std::move(pool)), shutdown_behavior_(shutdown_behavior) {} in SequencedWorkerPoolTaskRunner()
177 return pool_->PostWorkerTaskWithShutdownBehavior(from_here, std::move(task), in PostDelayedTask()
180 return pool_->PostDelayedWorkerTask(from_here, std::move(task), delay); in PostDelayedTask()
184 return pool_->RunsTasksOnCurrentThread(); in RunsTasksOnCurrentThread()
216 const scoped_refptr<SequencedWorkerPool> pool_; member in base::SequencedWorkerPool::PoolSequencedTaskRunner
230 : pool_(std::move(pool)), in PoolSequencedTaskRunner()
242 return pool_->PostSequencedWorkerTaskWithShutdownBehavior( in PostDelayedTask()
245 return pool_->PostDelayedSequencedWorkerTask(token_, from_here, in PostDelayedTask()
251 return pool_->IsRunningSequenceOnCurrentThread(token_); in RunsTasksOnCurrentThread()
|
| /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()
|
| D | descriptor_database_unittest.cc | 147 DescriptorPoolDatabaseTestCase() : database_(pool_) {} in DescriptorPoolDatabaseTestCase()
154 return pool_.BuildFile(file); in AddToDatabase()
158 DescriptorPool pool_; member in google::protobuf::__anon6d8d57570111::DescriptorPoolDatabaseTestCase
|
| /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 | kernel_benchmark_testlib.cc | 60 pool_ = new thread::ThreadPool(options->env, "blocking", in Benchmark()
64 pool_->Schedule(closure); in Benchmark()
106 delete pool_; in ~Benchmark()
150 pool_->Schedule(closure); in RunWithArgs()
|
| /external/tensorflow/tensorflow/core/common_runtime/gpu/ |
| 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()
150 while (pool_.size() >= pool_size_limit_) { in DeallocateRaw()
157 pool_.insert(std::make_pair(cp->num_bytes, pr)); in DeallocateRaw()
164 for (auto iter : pool_) { in Clear()
172 pool_.clear(); in Clear()
217 auto iter = pool_.find(prec->num_bytes); in EvictOne()
220 DCHECK(iter != pool_.end()); in EvictOne()
222 pool_.erase(iter); in EvictOne()
|
| /external/libchrome/base/test/ |
| D | sequenced_worker_pool_owner.cc | 17 pool_(new SequencedWorkerPool(max_threads, in SequencedWorkerPoolOwner()
24 pool_->Shutdown(); in ~SequencedWorkerPoolOwner()
25 pool_ = NULL; in ~SequencedWorkerPoolOwner()
33 return pool_; in pool()
|
| D | sequenced_worker_pool_owner.h | 60 scoped_refptr<SequencedWorkerPool> pool_; variable
|
| /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/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/contrib/lite/kernels/internal/optimized/ |
| D | multithreaded_conv.h | 40 explicit EigenThreadPoolWrapper(Eigen::ThreadPool* pool) : pool_(pool) {} in EigenThreadPoolWrapper()
44 pool_->Schedule(std::move(fn)); in Schedule()
46 int NumThreads() const override { return pool_->NumThreads(); } in NumThreads()
47 int CurrentThreadId() const override { return pool_->CurrentThreadId(); } in CurrentThreadId()
50 Eigen::ThreadPool* pool_ = nullptr;
|
| /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::__anon3dd2b61b0111::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::__anon5e831e220111::DescriptorPoolTypeResolver
|
| /external/libchrome/testing/ |
| D | platform_test.h | 30 NSAutoreleasePool* pool_;
|