| /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 | 43 scoped_refptr<base::PosixDynamicThreadPool> pool_; member in base::__anon49dd465c0111::WorkerPoolImpl
47 : pool_(new base::PosixDynamicThreadPool("WorkerPool", in WorkerPoolImpl()
51 pool_->Terminate(); in ~WorkerPoolImpl()
57 pool_->PostTask(from_here, task); in PostTask()
67 : name_prefix_(name_prefix), pool_(pool) {} in WorkerThread()
73 scoped_refptr<base::PosixDynamicThreadPool> pool_; member in base::__anon49dd465c0111::WorkerThread
86 PendingTask pending_task = pool_->WaitForTask(); in ThreadMain()
|
| D | sequenced_worker_pool.cc | 115 const scoped_refptr<SequencedWorkerPool> pool_; member in base::__anon0f9738860111::SequencedWorkerPoolTaskRunner
125 : pool_(std::move(pool)), shutdown_behavior_(shutdown_behavior) {} in SequencedWorkerPoolTaskRunner()
135 return pool_->PostWorkerTaskWithShutdownBehavior( in PostDelayedTask()
138 return pool_->PostDelayedWorkerTask(from_here, task, delay); in PostDelayedTask()
142 return pool_->RunsTasksOnCurrentThread(); in RunsTasksOnCurrentThread()
171 const scoped_refptr<SequencedWorkerPool> pool_; member in base::__anon0f9738860111::SequencedWorkerPoolSequencedTaskRunner
184 : pool_(std::move(pool)), in SequencedWorkerPoolSequencedTaskRunner()
197 return pool_->PostSequencedWorkerTaskWithShutdownBehavior( in PostDelayedTask()
200 return pool_->PostDelayedSequencedWorkerTask(token_, from_here, task, delay); in PostDelayedTask()
204 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 | dynamic_message.h | 121 const DescriptorPool* pool_;
|
| 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::__anonca93acd90111::DescriptorPoolDatabaseTestCase
|
| D | dynamic_message.cc | 614 : pool_(NULL), delegate_to_generated_factory_(false), in DynamicMessageFactory()
619 : pool_(pool), delegate_to_generated_factory_(false), in DynamicMessageFactory()
655 type_info->pool = (pool_ == NULL) ? type->file()->pool() : pool_; in GetPrototypeNoLock()
|
| D | descriptor.cc | 2779 const DescriptorPool* pool_; member in google::protobuf::DescriptorBuilder
3226 : pool_(pool), in DescriptorBuilder()
3321 MutexLockMaybe lock((pool == pool_) ? NULL : pool->mutex_); in FindSymbolNotEnforcingDepsHelper()
3344 return FindSymbolNotEnforcingDepsHelper(pool_, name); in FindSymbolNotEnforcingDeps()
3352 if (!pool_->enforce_dependencies_) { in FindSymbol()
3465 if (result.IsNull() && pool_->allow_unknown_) { in LookupSymbol()
3573 placeholder->pool_ = pool_; in NewPlaceholderFile()
3771 if (pool_->fallback_database_ == NULL) { in AddImportError()
3835 if (pool_->fallback_database_ != NULL) { in BuildFile()
3839 (pool_->underlay_ == NULL || in BuildFile()
[all …]
|
| D | extension_set_heavy.cc | 83 : pool_(pool), factory_(factory), containing_type_(containing_type) {} in DescriptorPoolExtensionFinder()
89 const DescriptorPool* pool_; member in google::protobuf::internal::DescriptorPoolExtensionFinder
266 pool_->FindExtensionByNumber(containing_type_, number); in Find()
|
| /external/libchrome/base/test/ |
| D | sequenced_worker_pool_owner.cc | 17 pool_(new SequencedWorkerPool(max_threads, thread_name_prefix, this)), in SequencedWorkerPoolOwner()
21 pool_->Shutdown(); in ~SequencedWorkerPoolOwner()
22 pool_ = NULL; in ~SequencedWorkerPoolOwner()
29 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/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/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/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::__anonea569a9d0111::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::__anon5bfb7a640111::DescriptorPoolTypeResolver
|
| /external/libchrome/testing/ |
| D | platform_test.h | 30 NSAutoreleasePool* pool_;
|