| /external/adhd/cras/src/tests/ |
| D | audio_thread_unittest.cc | 142 thread_ = audio_thread_create(); in SetUp()
147 audio_thread_destroy(thread_); in TearDown()
236 struct audio_thread* thread_; member in StreamDeviceSuite
264 thread_add_open_dev(thread_, &iodev); in TEST_F()
265 adev = thread_->open_devs[CRAS_STREAM_OUTPUT]; in TEST_F()
268 thread_rm_open_dev(thread_, CRAS_STREAM_OUTPUT, iodev.info.idx); in TEST_F()
269 adev = thread_->open_devs[CRAS_STREAM_OUTPUT]; in TEST_F()
282 thread_add_open_dev(thread_, &iodev); in TEST_F()
283 adev = thread_->open_devs[CRAS_STREAM_OUTPUT]; in TEST_F()
289 rc = thread_dev_start_ramp(thread_, iodev.info.idx, req); in TEST_F()
[all …]
|
| D | audio_thread_unittest_obsolete.cc | 517 thread_ = audio_thread_create(); in SetUp()
518 ASSERT_TRUE(thread_); in SetUp()
519 thread_set_active_dev(thread_, &iodev_); in SetUp()
535 thread_add_stream(thread_, rstream_); in SetUp()
544 audio_thread_destroy(thread_); in TearDown()
643 struct audio_thread* thread_; member in WriteStreamSuite
666 rc = unified_io(thread_, &ts); in TEST_F()
684 rc = unified_io(thread_, &ts); in TEST_F()
708 rc = unified_io(thread_, &ts); in TEST_F()
747 rc = unified_io(thread_, &ts); in TEST_F()
[all …]
|
| /external/webrtc/test/network/ |
| D | fake_network_socket_server.cc | 68 rtc::Thread* const thread_; member in webrtc::test::FakeNetworkSocket
69 EmulatedEndpointImpl* endpoint_ RTC_GUARDED_BY(&thread_);
70 rtc::SocketAddress local_addr_ RTC_GUARDED_BY(&thread_);
71 rtc::SocketAddress remote_addr_ RTC_GUARDED_BY(&thread_);
72 ConnState state_ RTC_GUARDED_BY(&thread_);
73 int error_ RTC_GUARDED_BY(&thread_);
74 std::map<Option, int> options_map_ RTC_GUARDED_BY(&thread_);
76 absl::optional<EmulatedIpPacket> pending_ RTC_GUARDED_BY(thread_);
83 thread_(thread), in FakeNetworkSocket()
94 RTC_DCHECK_RUN_ON(thread_); in OnPacketReceived()
[all …]
|
| /external/webrtc/rtc_base/ |
| D | platform_thread.cc | 50 RTC_DCHECK(!thread_); in ~PlatformThread()
74 RTC_DCHECK(!thread_) << "Thread already started?"; in Start()
79 thread_ = ::CreateThread(nullptr, 1024 * 1024, &StartThread, this, in Start()
81 RTC_CHECK(thread_) << "CreateThread failed"; in Start()
87 RTC_CHECK_EQ(0, pthread_create(&thread_, &attr, &StartThread, this)); in Start()
94 return thread_ != nullptr; in IsRunning()
96 return thread_ != 0; in IsRunning()
104 return thread_; in GetThreadRef()
114 WaitForSingleObject(thread_, INFINITE); in Stop()
115 CloseHandle(thread_); in Stop()
[all …]
|
| D | thread_checker_unittest.cc | 213 RTC_DCHECK_RUN_ON(thread_); in access_var_annotate_thread()
228 RTC_DCHECK_RUN_ON(thread_); in access_fun_annotate()
233 RTC_DCHECK_RUN_ON(thread_); in access_fun_and_var()
238 void function() RTC_RUN_ON(thread_) {} in function()
239 void fun_acccess_var() RTC_RUN_ON(thread_) { var_thread_ = 13; } in fun_acccess_var()
241 rtc::Thread* thread_; member in rtc::ThreadAnnotateTest
245 int var_thread_ RTC_GUARDED_BY(thread_);
|
| D | thread.cc | 344 : thread_(Thread::Current()), in ScopedDisallowBlockingCalls()
345 previous_state_(thread_->SetAllowBlockingCalls(false)) {} in ScopedDisallowBlockingCalls()
348 RTC_DCHECK(thread_->IsCurrent()); in ~ScopedDisallowBlockingCalls()
349 thread_->SetAllowBlockingCalls(previous_state_); in ~ScopedDisallowBlockingCalls()
753 thread_ = CreateThread(nullptr, 0, PreRun, this, 0, &thread_id_); in Start()
754 if (!thread_) { in Start()
761 int error_code = pthread_create(&thread_, &attr, PreRun, this); in Start()
764 thread_ = 0; in Start()
767 RTC_DCHECK(thread_); in Start()
780 if (thread_ != nullptr) { in UnwrapCurrent()
[all …]
|
| D | fake_mdns_responder.h | 28 explicit FakeMdnsResponder(rtc::Thread* thread) : thread_(thread) {} in FakeMdnsResponder()
41 RTC_FROM_HERE, thread_, in CreateNameForAddress()
51 invoker_.AsyncInvoke<void>(RTC_FROM_HERE, thread_, in RemoveNameForAddress()
67 rtc::Thread* thread_; variable
|
| D | event_unittest.cc | 46 SignalerThread() : thread_(&ThreadFn, this, "EventPerf") {} in SignalerThread()
50 thread_.Start(); in Start()
54 thread_.Stop(); in Stop()
66 PlatformThread thread_; member in rtc::SignalerThread
|
| D | task_queue_win.cc | 207 WorkerThread thread_; member in webrtc::__anonb2f280180111::TaskQueueWin
216 : thread_(&TaskQueueWin::ThreadMain, this, queue_name, priority), in TaskQueueWin()
219 thread_.Start(); in TaskQueueWin()
221 RTC_CHECK(thread_.QueueAPC(&InitializeQueueThread, in TaskQueueWin()
228 while (!::PostThreadMessage(thread_.GetThreadRef(), WM_QUIT, 0, 0)) { in Delete()
232 thread_.Stop(); in Delete()
255 if (!::PostThreadMessage(thread_.GetThreadRef(), WM_QUEUE_DELAYED_TASK, 0, in PostDelayedTask()
|
| /external/webrtc/rtc_base/deprecated/ |
| D | signal_thread_unittest.cc | 86 thread_ = new SlowSignalThread(this); in SetUp()
87 thread_->SignalWorkDone.connect(this, &SignalThreadTest::OnWorkComplete); in SetUp()
122 SlowSignalThread* thread_; member in rtc::__anon298920680111::SignalThreadTest
176 thread_->Destroy(true); in TEST_F()
194 thread_->Start(); in TEST_F()
200 thread_->Start(); in TEST_F()
202 thread_->Release(); in TEST_F()
209 thread_->Start(); in TEST_F()
211 thread_->Destroy(true); in TEST_F()
218 thread_->Start(); in TEST_F()
[all …]
|
| D | recursive_critical_section.cc | 49 RTC_CS_DEBUG_CODE(thread_ = 0); in RecursiveCriticalSection()
51 RTC_UNUSED(thread_); in RecursiveCriticalSection()
119 RTC_DCHECK(!thread_); in Enter()
120 thread_ = CurrentThreadRef(); in Enter()
152 RTC_DCHECK(!thread_); in TryEnter()
153 thread_ = CurrentThreadRef(); in TryEnter()
174 thread_ = 0; in Leave()
203 return IsThreadRefEqual(thread_, CurrentThreadRef()); in CurrentThreadIsOwner()
|
| /external/webrtc/test/time_controller/ |
| D | external_time_controller.cc | 38 : parent_(parent), thread_(std::move(thread)) {} in ProcessThreadWrapper()
42 thread_->Start(); in Start()
48 thread_->Stop(); in Stop()
54 thread_->WakeUp(GetWrapper(module)); in WakeUp()
60 thread_->PostTask(std::move(task)); in PostTask()
67 thread_->PostDelayedTask(std::move(task), milliseconds); in PostDelayedTask()
74 thread_->RegisterModule(GetWrapper(module), from); in RegisterModule()
80 thread_->DeRegisterModule(GetWrapper(module)); in DeRegisterModule()
89 : module_(module), thread_(thread) {} in ModuleWrapper()
99 module_->ProcessThreadAttached(thread_); in ProcessThreadAttached()
[all …]
|
| /external/webrtc/test/ |
| D | test_main_lib.cc | 137 thread_ = rtc::Thread::CreateWithSocketServer(); in OnTestStart()
138 thread_->WrapCurrent(); in OnTestStart()
139 RTC_DCHECK_EQ(rtc::Thread::Current(), thread_.get()); in OnTestStart()
149 if (thread_) { in OnTestEnd()
150 thread_->Quit(); // Signal quit. in OnTestEnd()
151 thread_->Run(); // Flush + process Quit signal. in OnTestEnd()
152 thread_->UnwrapCurrent(); in OnTestEnd()
153 thread_ = nullptr; in OnTestEnd()
157 std::unique_ptr<rtc::Thread> thread_; member in webrtc::__anonf1a0712b0111::TestMainImpl::TestListener
|
| /external/webrtc/modules/utility/source/ |
| D | process_thread_impl.cc | 51 RTC_DCHECK(!thread_.get()); in ~ProcessThreadImpl()
74 RTC_DCHECK(!thread_.get()); in Start()
75 if (thread_.get()) in Start()
83 thread_.reset( in Start()
85 thread_->Start(); in Start()
90 if (!thread_.get()) in Stop()
100 thread_->Stop(); in Stop()
103 thread_.reset(); in Stop()
166 if (thread_.get()) in RegisterModule()
|
| /external/webrtc/logging/rtc_event_log/ |
| D | fake_rtc_event_log.cc | 20 FakeRtcEventLog::FakeRtcEventLog(rtc::Thread* thread) : thread_(thread) { in FakeRtcEventLog()
21 RTC_DCHECK(thread_); in FakeRtcEventLog()
31 invoker_.Flush(thread_); in StopLogging()
37 RTC_FROM_HERE, thread_, in Log()
|
| D | fake_rtc_event_log_factory.h | 24 explicit FakeRtcEventLogFactory(rtc::Thread* thread) : thread_(thread) {} in FakeRtcEventLogFactory()
31 rtc::Thread* thread() { return thread_; } in thread()
35 rtc::Thread* thread_; variable
|
| /external/perfetto/src/base/ |
| D | thread_task_runner.cc | 39 : thread_(std::move(other.thread_)), task_runner_(other.task_runner_) { in ThreadTaskRunner()
54 PERFETTO_DCHECK(thread_.joinable()); in ~ThreadTaskRunner()
56 if (thread_.joinable()) in ~ThreadTaskRunner()
57 thread_.join(); in ~ThreadTaskRunner()
75 thread_ = std::thread(&ThreadTaskRunner::RunTaskThread, this, in ThreadTaskRunner()
|
| /external/libchrome/base/android/ |
| D | application_status_listener_unittest.cc | 48 thread_("ApplicationStatusTest thread"), in MultiThreadedTest()
53 thread_.Start(); in Run()
54 thread_.task_runner()->PostTask( in Run()
76 EXPECT_EQ(thread_.message_loop(), base::MessageLoop::current()); in ExpectOnThread()
95 base::Thread thread_; member in base::android::__anon2007fe850111::MultiThreadedTest
|
| /external/webrtc/p2p/base/ |
| D | stun_request.cc | 45 StunRequestManager::StunRequestManager(rtc::Thread* thread) : thread_(thread) {} in StunRequestManager()
66 thread_->PostDelayed(RTC_FROM_HERE, delay, request, MSG_STUN_SEND, NULL); in SendDelayed()
68 thread_->Send(RTC_FROM_HERE, request, MSG_STUN_SEND, NULL); in SendDelayed()
76 thread_->Clear(request, MSG_STUN_SEND); in Flush()
77 thread_->Send(RTC_FROM_HERE, request, MSG_STUN_SEND, NULL); in Flush()
98 thread_->Clear(request); in Remove()
194 manager_->thread_->Clear(this); in ~StunRequest()
249 manager_->thread_->PostDelayed(RTC_FROM_HERE, resend_delay(), this, in OnMessage()
|
| D | basic_packet_socket_factory.cc | 32 : thread_(Thread::Current()), socket_factory_(NULL) {} in BasicPacketSocketFactory()
35 : thread_(thread), socket_factory_(NULL) {} in BasicPacketSocketFactory()
39 : thread_(NULL), socket_factory_(socket_factory) {} in BasicPacketSocketFactory()
213 if (thread_) { in socket_factory()
214 RTC_DCHECK(thread_ == Thread::Current()); in socket_factory()
215 return thread_->socketserver(); in socket_factory()
|
| D | regathering_controller.cc | 19 : config_(config), ice_transport_(ice_transport), thread_(thread) { in BasicRegatheringController()
21 RTC_DCHECK(thread_); in BasicRegatheringController()
56 RTC_FROM_HERE, thread_, in ScheduleRecurringRegatheringOnFailedNetworks()
|
| D | turn_server.cc | 75 rtc::Thread* thread_; member in cricket::TurnServerAllocation::Permission
96 rtc::Thread* thread_; member in cricket::TurnServerAllocation::Channel
125 : thread_(thread), in TurnServer()
475 new TurnServerAllocation(this, thread_, *conn, external_socket, key); in CreateAllocation()
617 thread_(thread), in TurnServerAllocation()
633 thread_->Clear(this, MSG_ALLOCATION_TIMEOUT); in ~TurnServerAllocation()
684 thread_->PostDelayed(RTC_FROM_HERE, lifetime_secs * 1000, this, in HandleAllocateRequest()
712 thread_->Clear(this, MSG_ALLOCATION_TIMEOUT); in HandleRefreshRequest()
713 thread_->PostDelayed(RTC_FROM_HERE, lifetime_secs * 1000, this, in HandleRefreshRequest()
809 channel1 = new Channel(thread_, channel_id, peer_attr->GetAddress()); in HandleChannelBindRequest()
[all …]
|
| /external/tensorflow/tensorflow/compiler/xla/python/tpu_driver/platform/external/ |
| D | compat.h | 29 : thread_(std::forward<Function>(f), std::forward<Args>(args)...) {} in Thread()
30 void join() { thread_.join(); } in join()
33 std::thread thread_;
|
| /external/perfetto/src/profiling/perf/ |
| D | unwinding.h | 270 thread_ = std::thread(&UnwinderHandle::RunTaskThread, this, in UnwinderHandle()
282 PERFETTO_DCHECK(thread_.joinable()); in ~UnwinderHandle()
284 if (thread_.joinable()) in ~UnwinderHandle()
285 thread_.join(); in ~UnwinderHandle()
301 std::thread thread_; variable
|
| /external/tensorflow/tensorflow/core/platform/windows/ |
| D | env.cc | 57 : thread_(fn) { in StdThread()
59 GetThreadNameRegistry().emplace(thread_.get_id(), name); in StdThread()
63 std::thread::id thread_id = thread_.get_id(); in ~StdThread()
64 thread_.join(); in ~StdThread()
70 std::thread thread_; member in tensorflow::__anon6902f3df0111::StdThread
|