| /external/tensorflow/tensorflow/core/data/service/ |
| D | thread_safe_buffer_test.cc | 64 auto thread = absl::WrapUnique(Env::Default()->StartThread( in TEST_P()
81 threads.push_back(absl::WrapUnique(Env::Default()->StartThread( in TEST_P()
101 threads.push_back(absl::WrapUnique(Env::Default()->StartThread( in TEST_P()
126 threads.push_back(absl::WrapUnique(Env::Default()->StartThread( in TEST_P()
136 threads.push_back(absl::WrapUnique(Env::Default()->StartThread( in TEST_P()
150 auto thread = absl::WrapUnique(Env::Default()->StartThread( in TEST_P()
169 auto thread = absl::WrapUnique(Env::Default()->StartThread( in TEST_P()
188 threads.push_back(absl::WrapUnique(Env::Default()->StartThread( in TEST_P()
204 threads.push_back(absl::WrapUnique(Env::Default()->StartThread( in TEST_P()
|
| D | task_runner_test.cc | 247 reader_threads.push_back(absl::WrapUnique(Env::Default()->StartThread( in TEST()
368 reader_threads.push_back(absl::WrapUnique(Env::Default()->StartThread( in TEST()
413 reader_threads.push_back(absl::WrapUnique(Env::Default()->StartThread( in TEST()
463 reader_threads.push_back(absl::WrapUnique(Env::Default()->StartThread( in TEST()
516 consumers.push_back(absl::WrapUnique(Env::Default()->StartThread( in TEST_P()
564 consumers.push_back(absl::WrapUnique(Env::Default()->StartThread( in TEST()
|
| /external/compiler-rt/test/tsan/ |
| D | simple_stack.c | 36 void StartThread(pthread_t *t, void *(*f)(void*)) { in StartThread() function
43 StartThread(&t[0], Thread1); in main()
44 StartThread(&t[1], Thread2); in main()
|
| /external/tensorflow/tensorflow/core/data/ |
| D | unbounded_thread_pool_test.cc | 36 threads.push_back(thread_factory->StartThread("", [=, &i, in TEST()
41 thread_factory->StartThread("", [&i]() { ++i; })); in TEST()
65 threads.push_back(thread_factory->StartThread("", [&bc, &n]() { in TEST()
|
| D | metric_utils_test.cc | 83 auto thread = absl::WrapUnique(Env::Default()->StartThread( in TEST()
124 auto thread = absl::WrapUnique(Env::Default()->StartThread( in TEST()
|
| /external/compiler-rt/lib/sanitizer_common/tests/ |
| D | sanitizer_thread_registry_test.cc | 70 registry->StartThread(0, 0, 0); in TestRegistry()
78 registry->StartThread(i, 0, 0); in TestRegistry()
88 registry->StartThread(i, 0, 0); in TestRegistry()
115 registry->StartThread(tid, 0, 0); in TestRegistry()
192 args->registry->StartThread(tids[i], 0, (void*)args->shard); in RunThread()
203 registry->StartThread(0, 0, 0); in ThreadedTestRegistry()
|
| /external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/lib/event_engine/thread_pool/ |
| D | original_thread_pool.cc | 40 void OriginalThreadPool::StartThread(StatePtr state, StartThreadReason reason) { in StartThread() function in grpc_event_engine::experimental::OriginalThreadPool
86 StartThread(a->state, in StartThread()
137 StartThread(state_, StartThreadReason::kInitialPool); in OriginalThreadPool()
163 StartThread(state_, StartThreadReason::kNoWaitersWhenScheduling); in Run()
251 StartThread(state_, StartThreadReason::kInitialPool); in Postfork()
|
| D | work_stealing_thread_pool.cc | 121 StartThread(); in Start()
136 void WorkStealingThreadPool::WorkStealingThreadPoolImpl::StartThread() { in StartThread() function in grpc_event_engine::experimental::WorkStealingThreadPool::WorkStealingThreadPoolImpl
290 pool_->StartThread(); in MaybeStartNewThread()
|
| /external/mdnsresponder/mDNSWindows/DLL.NET/ |
| D | dnssd_NET.cpp | 78 ServiceRef::StartThread() in StartThread() function in ServiceRef
669 sdRef->StartThread(); in EnumerateDomains()
719 sdRef->StartThread(); in Register()
855 sdRef->StartThread(); in Browse()
891 sdRef->StartThread(); in Resolve()
919 sdRef->StartThread(); in CreateConnection()
998 sdRef->StartThread(); in QueryRecord()
|
| /external/tensorflow/tensorflow/compiler/xla/service/gpu/tests/ |
| D | infeed_test.cc | 138 std::unique_ptr<tensorflow::Thread> thread{env->StartThread( in TEST_F()
182 std::unique_ptr<tensorflow::Thread> thread{env->StartThread( in TEST_F()
|
| /external/tensorflow/tensorflow/core/framework/ |
| D | thread_factory.h | 36 virtual std::unique_ptr<Thread> StartThread(const string& name,
|
| /external/tensorflow/tensorflow/compiler/xla/tests/ |
| D | outfeed_in_nested_computation_test.cc | 75 tensorflow::Env::Default()->StartThread( in XLA_TEST_F()
150 tensorflow::Env::Default()->StartThread( in XLA_TEST_F()
|
| /external/tensorflow/tensorflow/core/kernels/batching_util/ |
| D | batch_scheduler_test.cc | 89 Env::Default()->StartThread(ThreadOptions(), "test", [&batch]() { in TEST()
103 std::unique_ptr<Thread> delete_thread(Env::Default()->StartThread( in TEST()
|
| /external/leveldb/include/leveldb/ |
| D | env.h | 202 virtual void StartThread(void (*function)(void* arg), void* arg) = 0;
387 void StartThread(void (*f)(void*), void* a) override { in StartThread() function
388 return target_->StartThread(f, a); in StartThread()
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | grpc_server_lib.cc | 414 env_->StartThread(ThreadOptions(), "TF_master_service", in Start()
417 env_->StartThread(ThreadOptions(), "TF_worker_service", in Start()
420 env_->StartThread(ThreadOptions(), "TF_eager_service", in Start()
422 coordination_thread_.reset(env_->StartThread( in Start()
430 extra_service_thread.reset(env_->StartThread( in Start()
|
| /external/cronet/stable/components/metrics/ |
| D | single_sample_metrics_factory_impl_unittest.cc | 52 void StartThread() { ASSERT_TRUE(thread_.Start()); } in StartThread() function in metrics::__anonfbba805a0111::SingleSampleMetricsFactoryImplTest
157 StartThread(); in TEST_F()
|
| /external/cronet/tot/components/metrics/ |
| D | single_sample_metrics_factory_impl_unittest.cc | 52 void StartThread() { ASSERT_TRUE(thread_.Start()); } in StartThread() function in metrics::__anonbfcc5c760111::SingleSampleMetricsFactoryImplTest
157 StartThread(); in TEST_F()
|
| /external/grpc-grpc/src/cpp/server/load_reporter/ |
| D | load_reporting_service_server_builder_plugin.cc | 58 service_->StartThread(); in Finish()
|
| /external/rust/android-crates-io/crates/grpcio-sys/grpc/src/cpp/server/load_reporter/ |
| D | load_reporting_service_server_builder_plugin.cc | 59 service_->StartThread(); in Finish()
|
| /external/crosvm/devices/src/utils/ |
| D | error.rs | 23 StartThread(std::io::Error), enumerator
|
| /external/tensorflow/tensorflow/compiler/xla/pjrt/ |
| D | worker_thread.cc | 21 thread_.reset(env->StartThread(tensorflow::ThreadOptions(), name, in WorkerThread()
|
| /external/stressapptest/src/ |
| D | logger.h | 105 void StartThread();
|
| /external/tensorflow/tensorflow/core/platform/ |
| D | refcount_test.cc | 148 auto t1 = env->StartThread(ThreadOptions{}, "thread-1", fn); in TEST()
149 auto t2 = env->StartThread(ThreadOptions{}, "thread-2", fn); in TEST()
|
| /external/tensorflow/tensorflow/tsl/platform/default/ |
| D | unbounded_work_queue.cc | 68 env_->StartThread({}, thread_name_, [this]() { PooledThreadFunc(); }); in Schedule()
|
| /external/tensorflow/tensorflow/compiler/xla/service/cpu/tests/ |
| D | cpu_infeed_test.cc | 152 tensorflow::Env::Default()->StartThread( in TEST_F()
268 tensorflow::Env::Default()->StartThread( in TEST_F()
|