| /external/grpc-grpc/src/cpp/thread_manager/ |
| D | thread_manager.cc | 30 ThreadManager::WorkerThread::WorkerThread(ThreadManager* thd_mgr) in WorkerThread()
36 [](void* th) { static_cast<ThreadManager::WorkerThread*>(th)->Run(); }, in WorkerThread()
41 void ThreadManager::WorkerThread::Run() { in Run()
46 ThreadManager::WorkerThread::~WorkerThread() { in ~WorkerThread()
51 ThreadManager::ThreadManager(const char* name, in ThreadManager() function in grpc::ThreadManager
63 ThreadManager::~ThreadManager() { in ~ThreadManager()
74 void ThreadManager::Wait() { in Wait()
81 void ThreadManager::Shutdown() { in Shutdown()
86 bool ThreadManager::IsShutdown() { in IsShutdown()
91 int ThreadManager::GetMaxActiveThreadsSoFar() { in GetMaxActiveThreadsSoFar()
[all …]
|
| D | thread_manager.h | 34 class ThreadManager {
36 explicit ThreadManager(const char* name, grpc_resource_quota* resource_quota,
38 virtual ~ThreadManager();
123 WorkerThread(ThreadManager* thd_mgr);
131 ThreadManager* const thd_mgr_;
|
| /external/rust/crates/grpcio-sys/grpc/src/cpp/thread_manager/ |
| D | thread_manager.cc | 29 ThreadManager::WorkerThread::WorkerThread(ThreadManager* thd_mgr) in WorkerThread()
35 [](void* th) { static_cast<ThreadManager::WorkerThread*>(th)->Run(); }, in WorkerThread()
42 void ThreadManager::WorkerThread::Run() { in Run()
47 ThreadManager::WorkerThread::~WorkerThread() { in ~WorkerThread()
52 ThreadManager::ThreadManager(const char* name, in ThreadManager() function in grpc::ThreadManager
64 ThreadManager::~ThreadManager() { in ~ThreadManager()
75 void ThreadManager::Wait() { in Wait()
82 void ThreadManager::Shutdown() { in Shutdown()
87 bool ThreadManager::IsShutdown() { in IsShutdown()
92 int ThreadManager::GetMaxActiveThreadsSoFar() { in GetMaxActiveThreadsSoFar()
[all …]
|
| D | thread_manager.h | 33 class ThreadManager {
35 explicit ThreadManager(const char* name, grpc_resource_quota* resource_quota,
37 virtual ~ThreadManager();
122 explicit WorkerThread(ThreadManager* thd_mgr);
133 ThreadManager* const thd_mgr_;
|
| /external/webrtc/rtc_base/ |
| D | thread.cc | 112 ThreadManager* ThreadManager::Instance() { in Instance()
113 static ThreadManager* const thread_manager = new ThreadManager(); in Instance()
117 ThreadManager::~ThreadManager() { in ~ThreadManager()
123 void ThreadManager::Add(Thread* message_queue) { in Add()
126 void ThreadManager::AddInternal(Thread* message_queue) { in AddInternal()
134 void ThreadManager::Remove(Thread* message_queue) { in Remove()
137 void ThreadManager::RemoveInternal(Thread* message_queue) { in RemoveInternal()
154 void ThreadManager::RemoveFromSendGraph(Thread* thread) { in RemoveFromSendGraph()
165 void ThreadManager::RegisterSendAndCheckForCycles(Thread* source, in RegisterSendAndCheckForCycles()
186 void ThreadManager::Clear(MessageHandler* handler) { in Clear()
[all …]
|
| D | thread.h | 74 class RTC_EXPORT ThreadManager {
79 static ThreadManager* Instance();
125 ThreadManager();
126 ~ThreadManager();
163 RTC_DISALLOW_COPY_AND_ASSIGN(ThreadManager);
455 manager_(rtc::ThreadManager::Instance()), in CurrentThreadSetter()
462 rtc::ThreadManager* const manager_;
557 bool WrapCurrentWithThreadManager(ThreadManager* thread_manager,
623 friend class ThreadManager; variable
|
| D | fake_clock.cc | 38 ThreadManager::ProcessAllMessageQueuesForTesting(); in SetTime()
43 ThreadManager::ProcessAllMessageQueuesForTesting(); in AdvanceTime()
|
| D | async_invoker.cc | 26 ThreadManager::Clear(this); in ~AsyncInvoker()
71 ThreadManager::Clear(this); in Clear()
|
| D | message_handler.cc | 18 ThreadManager::Clear(this); in ~MessageHandler()
|
| D | thread_unittest.cc | 279 ThreadManager::Instance()->SetCurrentThread(nullptr); in TEST()
290 ThreadManager::Instance()->SetCurrentThread(current_thread); in TEST()
602 TEST(ThreadManager, ProcessAllMessageQueues) { in TEST() argument
630 ThreadManager::ProcessAllMessageQueuesForTesting(); in TEST()
635 TEST(ThreadManager, ProcessAllMessageQueuesWithQuittingThread) { in TEST() argument
639 ThreadManager::ProcessAllMessageQueuesForTesting(); in TEST()
644 TEST(ThreadManager, ProcessAllMessageQueuesWithClearedQueue) { in TEST() argument
664 ThreadManager::ProcessAllMessageQueuesForTesting(); in TEST()
677 TEST(ThreadManager, ClearReentrant) { in TEST() argument
|
| /external/webrtc/sdk/android/native_unittests/video/ |
| D | video_source_unittest.cc | 40 rtc::ThreadManager::Instance()->WrapCurrentThread(); in TEST()
44 env, rtc::ThreadManager::Instance()->CurrentThread(), in TEST()
57 rtc::ThreadManager::Instance()->WrapCurrentThread(); in TEST()
61 env, rtc::ThreadManager::Instance()->CurrentThread(), in TEST()
90 rtc::ThreadManager::Instance()->WrapCurrentThread(); in TEST()
94 env, rtc::ThreadManager::Instance()->CurrentThread(), in TEST()
121 rtc::ThreadManager::Instance()->WrapCurrentThread(); in TEST()
125 env, rtc::ThreadManager::Instance()->CurrentThread(), in TEST()
139 rtc::ThreadManager::Instance()->WrapCurrentThread(); in TEST()
143 env, rtc::ThreadManager::Instance()->CurrentThread(), in TEST()
[all …]
|
| /external/libcxx/utils/google-benchmark/src/ |
| D | benchmark_runner.cc | 66 const internal::ThreadManager::Result& results, size_t memory_iterations, in CreateRunReport()
109 ThreadManager* manager) { in RunInThread()
116 internal::ThreadManager::Result& results = manager->results; in RunInThread()
189 internal::ThreadManager::Result results;
196 std::unique_ptr<internal::ThreadManager> manager; in DoNIterations()
197 manager.reset(new internal::ThreadManager(b.threads)); in DoNIterations()
319 std::unique_ptr<internal::ThreadManager> manager; in DoOneRepetition()
320 manager.reset(new internal::ThreadManager(1)); in DoOneRepetition()
|
| D | thread_manager.h | 12 class ThreadManager {
14 ThreadManager(int num_threads) in ThreadManager() function
|
| D | benchmark_api_internal.cc | 8 internal::ThreadManager* manager) const { in Run()
|
| /external/google-benchmark/src/ |
| D | benchmark_runner.cc | 66 const internal::ThreadManager::Result& results, in CreateRunReport()
114 int thread_id, ThreadManager* manager) { in RunInThread()
124 internal::ThreadManager::Result& results = manager->results; in RunInThread()
196 internal::ThreadManager::Result results;
203 std::unique_ptr<internal::ThreadManager> manager; in DoNIterations()
204 manager.reset(new internal::ThreadManager(b.threads)); in DoNIterations()
330 std::unique_ptr<internal::ThreadManager> manager; in DoOneRepetition()
331 manager.reset(new internal::ThreadManager(1)); in DoOneRepetition()
|
| D | thread_manager.h | 12 class ThreadManager {
14 explicit ThreadManager(int num_threads) in ThreadManager() function
|
| D | benchmark_api_internal.cc | 8 internal::ThreadManager* manager) const { in Run()
|
| /external/llvm-project/libcxx/utils/google-benchmark/src/ |
| D | benchmark_runner.cc | 66 const internal::ThreadManager::Result& results, size_t memory_iterations, in CreateRunReport()
109 ThreadManager* manager) { in RunInThread()
116 internal::ThreadManager::Result& results = manager->results; in RunInThread()
189 internal::ThreadManager::Result results;
196 std::unique_ptr<internal::ThreadManager> manager; in DoNIterations()
197 manager.reset(new internal::ThreadManager(b.threads)); in DoNIterations()
319 std::unique_ptr<internal::ThreadManager> manager; in DoOneRepetition()
320 manager.reset(new internal::ThreadManager(1)); in DoOneRepetition()
|
| D | thread_manager.h | 12 class ThreadManager {
14 ThreadManager(int num_threads) in ThreadManager() function
|
| D | benchmark_api_internal.cc | 8 internal::ThreadManager* manager) const { in Run()
|
| D | benchmark_api_internal.h | 38 internal::ThreadManager* manager) const;
|
| /external/grpc-grpc/test/cpp/thread_manager/ |
| D | thread_manager_test.cc | 47 class ThreadManagerTest final : public grpc::ThreadManager {
51 : ThreadManager(name, rq, settings.min_pollers, settings.max_pollers), in ThreadManagerTest()
57 grpc::ThreadManager::WorkStatus PollForWork(void** tag, bool* ok) override;
83 grpc::ThreadManager::WorkStatus ThreadManagerTest::PollForWork(void** tag, in PollForWork()
|
| /external/llvm-project/llvm/utils/benchmark/src/ |
| D | thread_manager.h | 12 class ThreadManager {
14 ThreadManager(int num_threads) in ThreadManager() function
|
| D | benchmark.cc | 118 const internal::ThreadManager::Result& results, in CreateRunReport()
163 internal::ThreadManager* manager) { in RunInThread()
171 internal::ThreadManager::Result& results = manager->results; in RunInThread()
191 std::unique_ptr<internal::ThreadManager> manager; in RunBenchmark()
205 manager.reset(new internal::ThreadManager(b.threads)); in RunBenchmark()
213 internal::ThreadManager::Result results; in RunBenchmark()
295 internal::ThreadManager* manager) in State()
|
| /external/webrtc/audio/ |
| D | channel_receive_frame_transformer_delegate_unittest.cc | 94 rtc::ThreadManager::ProcessAllMessageQueuesForTesting(); in TEST()
113 rtc::ThreadManager::ProcessAllMessageQueuesForTesting(); in TEST()
|