| /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::__anone993f91d0111::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::__anone993f91d0111::WorkerThread
86 PendingTask pending_task = pool_->WaitForTask(); in ThreadMain()
|
| D | sequenced_worker_pool.cc | 113 const scoped_refptr<SequencedWorkerPool> pool_; member in base::__anon3cfb63c70111::SequencedWorkerPoolTaskRunner
123 : pool_(pool), 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::__anon3cfb63c70111::SequencedWorkerPoolSequencedTaskRunner
184 : pool_(pool), in SequencedWorkerPoolSequencedTaskRunner()
198 return pool_->PostSequencedWorkerTaskWithShutdownBehavior( in PostDelayedTask()
201 return pool_->PostDelayedSequencedWorkerTask(token_, from_here, task, delay); in PostDelayedTask()
205 return pool_->IsRunningSequenceOnCurrentThread(token_); in RunsTasksOnCurrentThread()
|
| /external/protobuf/src/google/protobuf/ |
| D | dynamic_message_unittest.cc | 58 DescriptorPool pool_; member in google::protobuf::DynamicMessageTest
69 DynamicMessageTest(): factory_(&pool_) {} in DynamicMessageTest()
86 ASSERT_TRUE(pool_.BuildFile(unittest_import_public_file) != NULL); in SetUp()
87 ASSERT_TRUE(pool_.BuildFile(unittest_import_file) != NULL); in SetUp()
88 ASSERT_TRUE(pool_.BuildFile(unittest_file) != NULL); in SetUp()
90 descriptor_ = pool_.FindMessageTypeByName("protobuf_unittest.TestAllTypes"); in SetUp()
95 pool_.FindMessageTypeByName("protobuf_unittest.TestAllExtensions"); in SetUp()
100 pool_.FindMessageTypeByName("protobuf_unittest.TestPackedTypes"); in SetUp()
105 pool_.FindMessageTypeByName("protobuf_unittest.TestOneof2"); in SetUp()
179 pool_.FindMessageTypeByName("protobuf_unittest.TestOneof2.NestedMessage"); in TEST_F()
[all …]
|
| D | descriptor_unittest.cc | 216 foo_file_ = pool_.BuildFile(foo_file); in SetUp()
219 bar_file_ = pool_.BuildFile(bar_file); in SetUp()
222 baz_file_ = pool_.BuildFile(baz_file); in SetUp()
248 DescriptorPool pool_; member in google::protobuf::descriptor_unittest::FileDescriptorTest
345 EXPECT_EQ(foo_extension_, pool_.FindExtensionByNumber(foo_message_, 1)); in TEST_F()
346 EXPECT_EQ(bar_extension_, pool_.FindExtensionByNumber(bar_message_, 1)); in TEST_F()
348 EXPECT_TRUE(pool_.FindExtensionByNumber(foo_message_, 2) == NULL); in TEST_F()
356 EXPECT_EQ(foo_file_, pool_.BuildFile(file)); in TEST_F()
360 EXPECT_TRUE(pool_.BuildFile(file) == NULL); in TEST_F()
438 foo_file_ = pool_.BuildFile(foo_file); in SetUp()
[all …]
|
| D | descriptor_database.cc | 394 : pool_(pool) {} in DescriptorPoolDatabase()
400 const FileDescriptor* file = pool_.FindFileByName(filename); in FindFileByName()
410 const FileDescriptor* file = pool_.FindFileContainingSymbol(symbol_name); in FindFileContainingSymbol()
421 const Descriptor* extendee = pool_.FindMessageTypeByName(containing_type); in FindFileContainingExtension()
425 pool_.FindExtensionByNumber(extendee, field_number); in FindFileContainingExtension()
436 const Descriptor* extendee = pool_.FindMessageTypeByName(extendee_type); in FindAllExtensionNumbers()
440 pool_.FindAllExtensions(extendee, &extensions); in FindAllExtensionNumbers()
|
| D | dynamic_message.h | 117 const DescriptorPool* pool_;
|
| D | descriptor.cc | 2293 const DescriptorPool* pool_; member in google::protobuf::DescriptorBuilder
2721 : pool_(pool), in DescriptorBuilder()
2816 MutexLockMaybe lock((pool == pool_) ? NULL : pool->mutex_); in FindSymbolNotEnforcingDepsHelper()
2839 return FindSymbolNotEnforcingDepsHelper(pool_, name); in FindSymbolNotEnforcingDeps()
2847 if (!pool_->enforce_dependencies_) { in FindSymbol()
2960 if (result.IsNull() && pool_->allow_unknown_) { in LookupSymbol()
3003 placeholder_file->pool_ = pool_; in NewPlaceholder()
3078 placeholder->pool_ = pool_; in NewPlaceholderFile()
3274 if (pool_->fallback_database_ == NULL) { in AddImportError()
3330 if (pool_->fallback_database_ != NULL) { in BuildFile()
[all …]
|
| D | dynamic_message.cc | 523 : pool_(NULL), delegate_to_generated_factory_(false), in DynamicMessageFactory()
528 : pool_(pool), delegate_to_generated_factory_(false), in DynamicMessageFactory()
564 type_info->pool = (pool_ == NULL) ? type->file()->pool() : pool_; in GetPrototypeNoLock()
|
| D | descriptor_database_unittest.cc | 141 DescriptorPoolDatabaseTestCase() : database_(pool_) {} in DescriptorPoolDatabaseTestCase()
148 return pool_.BuildFile(file); in AddToDatabase()
152 DescriptorPool pool_; member in google::protobuf::__anon9ff1ad7a0111::DescriptorPoolDatabaseTestCase
|
| /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/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
|
| D | httpclient.cc | 269 : agent_(agent), pool_(pool), in HttpClient()
403 StreamInterface* stream = pool_->RequestConnectedStream(server_, &stream_err); in connect()
437 pool_->ReturnConnectedStream(stream); in release()
|
| /external/protobuf/src/google/protobuf/compiler/ |
| D | importer.cc | 190 pool_(&database_, database_.GetValidationErrorCollector()) { in Importer()
191 pool_.EnforceWeakDependencies(true); in Importer()
198 return pool_.FindFileByName(filename); in Import()
202 pool_.AddUnusedImportTrackFile(file_name); in AddUnusedImportTrackFile()
206 pool_.ClearUnusedImportTrackFiles(); in ClearUnusedImportTrackFiles()
|
| D | importer.h | 166 return &pool_; in pool()
174 DescriptorPool pool_; variable
|
| D | parser_unittest.cc | 170 EXPECT_TRUE(pool_.BuildFileCollectingErrors( in ExpectHasValidationErrors()
176 DescriptorPool pool_; member in google::protobuf::compiler::__anonaab372be0111::ParserTest
1187 EXPECT_TRUE(pool_.BuildFile(other_file) != NULL); in TEST_F()
1341 EXPECT_TRUE(pool_.BuildFile(other_file) != NULL); in TEST_F()
1362 ASSERT_TRUE(pool_.BuildFile(descriptor_proto) != NULL); in TEST_F()
1391 EXPECT_TRUE(pool_.BuildFile(other_file) != NULL); in TEST_F()
1477 ASSERT_TRUE(pool_.BuildFile(public_import_proto) != NULL); in TEST_F()
1482 ASSERT_TRUE(pool_.BuildFile(import_proto) != NULL); in TEST_F()
1483 const FileDescriptor* actual = pool_.BuildFile(parsed); in TEST_F()
1526 ASSERT_TRUE(pool_.BuildFile(import_proto) != NULL); in TEST_F()
[all …]
|
| /external/opencv3/modules/flann/include/opencv2/flann/ |
| D | kdtree_index.h | 187 …return int(pool_.usedMemory+pool_.wastedMemory+dataset_.rows*sizeof(int)); // pool memory and vin… in usedMemory()
256 tree = pool_.allocate<Node>(); in load_tree()
278 NodePtr node = pool_.allocate<Node>(); // allocate memory in divideTree()
612 PooledAllocator pool_; variable
|
| D | kmeans_index.h | 426 return pool_.usedMemory+pool_.wastedMemory+memoryCounter_; in usedMemory()
443 root_ = pool_.allocate<KMeansNode>(); in buildIndex()
628 node = pool_.allocate<KMeansNode>(); in load_tree()
638 node->childs = pool_.allocate<KMeansNodePtr>(branching_); in load_tree()
844 node->childs = pool_.allocate<KMeansNodePtr>(branching); in computeClustering()
866 node->childs[c] = pool_.allocate<KMeansNode>(); in computeClustering()
1157 PooledAllocator pool_; variable
|
| D | kdtree_single_index.h | 200 …return (int)(pool_.usedMemory+pool_.wastedMemory+dataset_.rows*sizeof(int)); // pool memory and v… in usedMemory()
303 tree = pool_.allocate<Node>(); in load_tree()
341 NodePtr node = pool_.allocate<Node>(); // allocate memory in divideTree()
627 PooledAllocator pool_; variable
|
| /external/libchrome/testing/ |
| D | platform_test.h | 30 NSAutoreleasePool* pool_;
|