| /external/webrtc/webrtc/base/ |
| D | platform_thread.cc | 102 thread_(NULL) { in PlatformThread()
105 thread_(0) { in PlatformThread()
114 RTC_DCHECK(!thread_); in PlatformThread()
132 RTC_DCHECK(!thread_) << "Thread already started?"; in PlatformThread()
140 thread_ = ::CreateThread(NULL, 1024 * 1024, &StartThread, this, in PlatformThread()
142 RTC_CHECK(thread_) << "CreateThread failed"; in PlatformThread()
147 RTC_CHECK_EQ(0, pthread_create(&thread_, &attr, &StartThread, this)); in PlatformThread()
154 return thread_ != nullptr; in PlatformThread()
156 return thread_ != 0; in PlatformThread()
167 QueueUserAPC(&RaiseFlag, thread_, reinterpret_cast<ULONG_PTR>(&stop_)); in PlatformThread()
[all …]
|
| D | thread.cc | 132 : thread_(Thread::Current()), in ScopedDisallowBlockingCalls()
133 previous_state_(thread_->SetAllowBlockingCalls(false)) { in ScopedDisallowBlockingCalls()
137 ASSERT(thread_->IsCurrent()); in ~ScopedDisallowBlockingCalls()
138 thread_->SetAllowBlockingCalls(previous_state_); in ~ScopedDisallowBlockingCalls()
145 thread_(NULL), in Thread()
206 thread_ = CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE)PreRun, init, 0, in Start()
208 if (thread_) { in Start()
217 int error_code = pthread_create(&thread_, &attr, PreRun, init); in Start()
235 if (thread_ != NULL) { in UnwrapCurrent()
236 if (!CloseHandle(thread_)) { in UnwrapCurrent()
[all …]
|
| D | signalthread_unittest.cc | 75 thread_ = new SlowSignalThread(this); in SetUp()
76 thread_->SignalWorkDone.connect(this, &SignalThreadTest::OnWorkComplete); in SetUp()
89 SlowSignalThread* thread_; member in SignalThreadTest
160 thread_->Start(); in TEST_F()
169 thread_->Start(); in TEST_F()
171 thread_->Release(); in TEST_F()
181 thread_->Start(); in TEST_F()
183 thread_->Destroy(true); in TEST_F()
190 thread_->Start(); in TEST_F()
192 thread_->Destroy(false); in TEST_F()
|
| D | criticalsection.cc | 26 CS_DEBUG_CODE(thread_ = 0); in CriticalSection()
46 RTC_DCHECK(!thread_); in Enter()
47 thread_ = pthread_self(); in Enter()
64 RTC_DCHECK(!thread_); in TryEnter()
65 thread_ = pthread_self(); in TryEnter()
83 thread_ = 0; in Leave()
99 return pthread_equal(thread_, pthread_self()); in CurrentThreadIsOwner()
111 return thread_ != 0; in IsLocked()
|
| D | asyncinvoker.h | 168 if (thread_ == nullptr)
170 invoker_.AsyncInvoke<ReturnT, FunctorT>(thread_, functor, id);
181 if (thread_ == nullptr)
183 invoker_.AsyncInvokeDelayed<ReturnT, FunctorT>(thread_, functor, delay_ms,
196 if (thread_ == nullptr)
198 invoker_.AsyncInvoke<ReturnT, FunctorT, HostT>(thread_, functor, callback,
211 if (thread_ == nullptr)
213 invoker_.AsyncInvoke<ReturnT, FunctorT, HostT>(thread_, functor, callback,
223 Thread* thread_ GUARDED_BY(crit_);
|
| D | asyncinvoker.cc | 80 GuardedAsyncInvoker::GuardedAsyncInvoker() : thread_(Thread::Current()) { in GuardedAsyncInvoker()
81 thread_->SignalQueueDestroyed.connect(this, in GuardedAsyncInvoker()
90 if (thread_ == nullptr) in Flush()
92 invoker_.Flush(thread_, id); in Flush()
99 RTC_DCHECK(thread_ != nullptr); in ThreadDestroyed()
100 thread_ = nullptr; in ThreadDestroyed()
|
| D | thread.h | 115 Thread* const thread_;
188 return thread_; in GetHandle()
195 return thread_; in GetPThread()
266 pthread_t thread_; variable
270 HANDLE thread_; variable
|
| D | network.cc | 369 : thread_(NULL), sent_first_update_(false), start_count_(0), in BasicNetworkManager()
702 thread_ = Thread::Current(); in StartUpdating()
708 thread_->Post(this, kSignalNetworksMessage); in StartUpdating()
710 thread_->Post(this, kUpdateNetworksMessage); in StartUpdating()
717 ASSERT(Thread::Current() == thread_); in StopUpdating()
723 thread_->Clear(this); in StopUpdating()
767 ASSERT(thread_ == Thread::Current()); in QueryDefaultLocalAddress()
768 ASSERT(thread_->socketserver() != nullptr); in QueryDefaultLocalAddress()
772 thread_->socketserver()->CreateAsyncSocket(family, SOCK_DGRAM)); in QueryDefaultLocalAddress()
789 ASSERT(Thread::Current() == thread_); in UpdateNetworksOnce()
[all …]
|
| /external/webrtc/webrtc/modules/utility/source/ |
| D | process_thread_impl.cc | 51 RTC_DCHECK(!thread_.get()); in ~ProcessThreadImpl()
62 RTC_DCHECK(!thread_.get()); in Start()
63 if (thread_.get()) in Start()
78 thread_.reset( in Start()
80 thread_->Start(); in Start()
85 if(!thread_.get()) in Stop()
95 thread_->Stop(); in Stop()
105 thread_.reset(); in Stop()
147 if (thread_.get()) in RegisterModule()
180 if (thread_.get()) in DeRegisterModule()
|
| /external/webrtc/webrtc/p2p/base/ |
| D | stunrequest.cc | 28 : thread_(thread) { in StunRequestManager()
50 thread_->PostDelayed(delay, request, MSG_STUN_SEND, NULL); in SendDelayed()
52 thread_->Send(request, MSG_STUN_SEND, NULL); in SendDelayed()
60 thread_->Clear(request, MSG_STUN_SEND); in Flush()
61 thread_->Send(request, MSG_STUN_SEND, NULL); in Flush()
72 thread_->Clear(request); in Remove()
159 manager_->thread_->Clear(this); in ~StunRequest()
211 manager_->thread_->PostDelayed(resend_delay(), this, MSG_STUN_SEND, NULL); in OnMessage()
|
| D | basicpacketsocketfactory.cc | 28 : thread_(Thread::Current()), in BasicPacketSocketFactory()
33 : thread_(thread), in BasicPacketSocketFactory()
39 : thread_(NULL), in BasicPacketSocketFactory()
201 if (thread_) { in socket_factory()
202 ASSERT(thread_ == Thread::Current()); in socket_factory()
203 return thread_->socketserver(); in socket_factory()
|
| D | turnserver.cc | 69 rtc::Thread* thread_; member in cricket::TurnServerAllocation::Permission
91 rtc::Thread* thread_; member in cricket::TurnServerAllocation::Channel
119 : thread_(thread), in TurnServer()
446 thread_, *conn, external_socket, key); in CreateAllocation()
561 thread_(thread), in TurnServerAllocation()
578 thread_->Clear(this, MSG_ALLOCATION_TIMEOUT); in ~TurnServerAllocation()
628 thread_->PostDelayed(lifetime_secs * 1000, this, MSG_ALLOCATION_TIMEOUT); in HandleAllocateRequest()
655 thread_->Clear(this, MSG_ALLOCATION_TIMEOUT); in HandleRefreshRequest()
656 thread_->PostDelayed(lifetime_secs * 1000, this, MSG_ALLOCATION_TIMEOUT); in HandleRefreshRequest()
748 channel1 = new Channel(thread_, channel_id, peer_attr->GetAddress()); in HandleChannelBindRequest()
[all …]
|
| /external/protobuf/src/google/protobuf/stubs/ |
| D | once_unittest.cc | 79 thread_ = CreateThread(NULL, 0, &Start, this, 0, NULL); in TestThread()
81 pthread_create(&thread_, NULL, &Start, this); in TestThread()
95 WaitForSingleObject(thread_, INFINITE); in Join()
96 CloseHandle(thread_); in Join()
98 pthread_join(thread_, NULL); in Join()
104 HANDLE thread_; member in google::protobuf::__anon64ff714b0111::OnceInitTest::TestThread
106 pthread_t thread_;
|
| /external/libmojo/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::__anon5c60c0540111::MultiThreadedTest
|
| /external/webrtc/webrtc/test/ |
| D | frame_generator_capturer.cc | 68 thread_(FrameGeneratorCapturer::Run, this, "FrameGeneratorCapturer"), in FrameGeneratorCapturer()
80 thread_.Stop(); in ~FrameGeneratorCapturer()
91 thread_.Start(); in Init()
92 thread_.SetPriority(rtc::kHighPriority); in Init()
|
| D | fake_audio_device.cc | 33 thread_(FakeAudioDevice::Run, this, "FakeAudioDevice"), in FakeAudioDevice()
46 thread_.Stop(); in ~FakeAudioDevice()
56 thread_.Start(); in Init()
57 thread_.SetPriority(rtc::kHighPriority); in Init()
|
| D | direct_transport.cc | 27 thread_(NetworkProcess, this, "NetworkProcess"), in DirectTransport()
31 thread_.Start(); in DirectTransport()
47 thread_.Stop(); in StopSending()
|
| /external/libchrome/base/threading/ |
| D | simple_thread.cc | 17 thread_(), in SimpleThread()
28 thread_(), in SimpleThread()
43 success = PlatformThread::Create(options_.stack_size(), this, &thread_); in Start()
46 &thread_, options_.priority()); in Start()
56 PlatformThread::Join(thread_); in Join()
|
| D | thread.cc | 67 thread_(0), in Thread()
118 if (!PlatformThread::CreateWithPriority(options.stack_size, this, &thread_, in StartWithOptions()
152 if (thread_.is_null()) in Stop()
162 PlatformThread::Join(thread_); in Stop()
163 thread_ = base::PlatformThreadHandle(); in Stop()
|
| /external/webrtc/webrtc/system_wrappers/source/ |
| D | condition_variable_unittest.cc | 147 CondVarTest() : thread_(&WaitingRunFunction, &baton_, "CondVarTest") {} in CondVarTest()
150 thread_.Start(); in SetUp()
161 thread_.Stop(); in TearDown()
168 rtc::PlatformThread thread_; member in webrtc::__anon466938020111::CondVarTest
|
| /external/libchrome/base/ |
| D | sync_socket_unittest.cc | 19 thread_(this, "HangingReceiveThread") { in HangingReceiveThread()
20 thread_.Start(); in HangingReceiveThread()
36 thread_.Join(); in Stop()
41 base::DelegateSimpleThread thread_; member in __anonff45e3960111::HangingReceiveThread
|
| /external/gemmlowp/test/ |
| D | test_blocking_counter.cc | 30 pthread_create(&thread_, nullptr, ThreadFunc, this); in Thread()
36 pthread_join(thread_, nullptr); in Join()
57 pthread_t thread_; member in gemmlowp::Thread
|
| /external/webrtc/webrtc/voice_engine/test/auto_test/fixtures/ |
| D | after_initialization_fixture.h | 33 thread_(NetworkProcess, this, "LoopBackTransport"), in LoopBackTransport()
37 thread_.Start(); in LoopBackTransport()
40 ~LoopBackTransport() { thread_.Stop(); } in ~LoopBackTransport()
148 rtc::PlatformThread thread_; variable
|
| /external/webrtc/webrtc/examples/peerconnection/client/linux/ |
| D | main.cc | 24 : thread_(thread), wnd_(wnd), conductor_(NULL), client_(NULL) {} in CustomSocketServer()
42 thread_->Quit(); in Wait()
49 rtc::Thread* thread_; member in CustomSocketServer
|
| /external/parameter-framework/asio-1.10.6/include/asio/detail/impl/ |
| D | posix_thread.ipp | 31 ::pthread_detach(thread_);
38 ::pthread_join(thread_, 0);
45 int error = ::pthread_create(&thread_, 0,
|