| /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/webrtc/webrtc/base/ |
| D | thread.cc | 38 ThreadManager* ThreadManager::Instance() { in Instance()
39 RTC_DEFINE_STATIC_LOCAL(ThreadManager, thread_manager, ()); in Instance()
45 return ThreadManager::Instance()->CurrentThread(); in Current()
49 ThreadManager::ThreadManager() { in ThreadManager() function in rtc::ThreadManager
63 ThreadManager::~ThreadManager() { in ~ThreadManager()
78 Thread *ThreadManager::CurrentThread() { in CurrentThread()
82 void ThreadManager::SetCurrentThread(Thread *thread) { in SetCurrentThread()
88 ThreadManager::ThreadManager() { in ThreadManager() function in rtc::ThreadManager
95 ThreadManager::~ThreadManager() { in ~ThreadManager()
100 Thread *ThreadManager::CurrentThread() { in CurrentThread()
[all …]
|
| D | thread.h | 34 class ThreadManager {
38 ThreadManager();
39 ~ThreadManager();
41 static ThreadManager* Instance();
71 RTC_DISALLOW_COPY_AND_ASSIGN(ThreadManager);
241 bool WrapCurrentWithThreadManager(ThreadManager* thread_manager,
277 friend class ThreadManager; variable
|
| D | messagequeue_unittest.cc | 118 if (rewrap_) ThreadManager::Instance()->UnwrapCurrentThread(); in UnwrapMainThreadScope()
121 if (rewrap_) ThreadManager::Instance()->WrapCurrentThread(); in ~UnwrapMainThreadScope()
|
| /external/v8/src/execution/ |
| D | v8threads.cc | 86 void ThreadManager::InitThread(const ExecutionAccess& lock) { in InitThread()
92 bool ThreadManager::RestoreThread() { in RestoreThread()
144 void ThreadManager::Lock() { in Lock()
150 void ThreadManager::Unlock() { in Unlock()
164 ThreadState::ThreadState(ThreadManager* thread_manager) in ThreadState()
192 ThreadState* ThreadManager::GetFreeThreadState() { in GetFreeThreadState()
203 ThreadState* ThreadManager::FirstThreadStateInUse() { in FirstThreadStateInUse()
215 ThreadManager::ThreadManager(Isolate* isolate) in ThreadManager() function in v8::internal::ThreadManager
226 ThreadManager::~ThreadManager() { in ~ThreadManager()
231 void ThreadManager::DeleteThreadStateList(ThreadState* anchor) { in DeleteThreadStateList()
[all …]
|
| D | v8threads.h | 36 explicit ThreadState(ThreadManager* thread_manager);
46 ThreadManager* thread_manager_;
48 friend class ThreadManager; variable
60 class ThreadManager {
87 explicit ThreadManager(Isolate* isolate);
88 ~ThreadManager();
|
| /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()
329 std::unique_ptr<internal::ThreadManager> manager; in DoOneRepetition()
330 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()
|
| D | benchmark_api_internal.h | 39 internal::ThreadManager* manager) const;
|
| D | benchmark.cc | 120 internal::ThreadManager* manager) in State()
|
| /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()
|
| 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/webrtc/talk/app/webrtc/ |
| D | peerconnectionfactory.cc | 127 signaling_thread_(rtc::ThreadManager::Instance()->CurrentThread()), in PeerConnectionFactory()
130 signaling_thread_ = rtc::ThreadManager::Instance()->WrapCurrentThread(); in PeerConnectionFactory()
169 rtc::ThreadManager::Instance()->UnwrapCurrentThread(); in ~PeerConnectionFactory()
|
| /external/webrtc/webrtc/examples/peerconnection/client/ |
| D | main.cc | 24 rtc::ThreadManager::Instance()->SetCurrentThread(&w32_thread); in wWinMain()
|
| /external/grpc-grpc/src/cpp/server/ |
| D | server_cc.cc | 278 class Server::SyncRequestThreadManager : public ThreadManager {
284 : ThreadManager("SyncServer", rq, min_pollers, max_pollers), in SyncRequestThreadManager()
352 ThreadManager::Shutdown(); in Shutdown()
357 ThreadManager::Wait(); in Wait()
|
| /external/webrtc/webrtc/p2p/stunprober/ |
| D | main.cc | 121 rtc::Thread* thread = rtc::ThreadManager::Instance()->WrapCurrentThread(); in main()
|
| /external/libcxx/utils/google-benchmark/include/benchmark/ |
| D | benchmark.h | 435 class ThreadManager; variable
672 internal::ThreadManager* manager);
680 internal::ThreadManager* manager_;
|
| /external/google-benchmark/include/benchmark/ |
| D | benchmark.h | 438 class ThreadManager; variable
675 internal::ThreadManager* manager);
683 internal::ThreadManager* manager_;
|
| /external/webrtc/talk/app/webrtc/java/jni/ |
| D | androidmediadecoder_jni.cc | 53 using rtc::ThreadManager;
424 RTC_CHECK(codec_thread_ == ThreadManager::Instance()->CurrentThread()) in CheckOnCodecThread()
|
| /external/webrtc/talk/media/devices/ |
| D | linuxdevicemanager.cc | 307 rtc::ThreadManager::Instance()->WrapCurrentThread()->socketserver(); in CurrentSocketServer()
|