Home
last modified time | relevance | path

Searched refs:signaling_thread_ (Results 1 – 16 of 16) sorted by relevance

/external/webrtc/talk/app/webrtc/
Dpeerconnectionfactory.cc127 signaling_thread_(rtc::ThreadManager::Instance()->CurrentThread()), in PeerConnectionFactory()
129 if (!signaling_thread_) { in PeerConnectionFactory()
130 signaling_thread_ = rtc::ThreadManager::Instance()->WrapCurrentThread(); in PeerConnectionFactory()
144 signaling_thread_(signaling_thread), in PeerConnectionFactory()
157 RTC_DCHECK(signaling_thread_->IsCurrent()); in ~PeerConnectionFactory()
175 RTC_DCHECK(signaling_thread_->IsCurrent()); in Initialize()
204 signaling_thread_, worker_thread_); in Initialize()
212 RTC_DCHECK(signaling_thread_->IsCurrent()); in CreateAudioSource()
222 RTC_DCHECK(signaling_thread_->IsCurrent()); in CreateVideoSource()
225 return VideoSourceProxy::Create(signaling_thread_, source); in CreateVideoSource()
[all …]
Ddtlsidentitystore.cc60 : signaling_thread_(rtc::Thread::Current()), in WorkerTask()
66 virtual ~WorkerTask() { RTC_DCHECK(signaling_thread_->IsCurrent()); } in ~WorkerTask()
78 signaling_thread_->Post(this, MSG_GENERATE_IDENTITY_RESULT, msg); in GenerateIdentity_w()
89 signaling_thread_->Post(this, MSG_DESTROY, msg->pdata); in OnMessage()
92 RTC_DCHECK(signaling_thread_->IsCurrent()); in OnMessage()
103 RTC_DCHECK(signaling_thread_->IsCurrent()); in OnMessage()
113 RTC_DCHECK(signaling_thread_->IsCurrent()); in OnStoreDestroyed()
117 rtc::Thread* const signaling_thread_; member in webrtc::DtlsIdentityStoreImpl::WorkerTask
124 : signaling_thread_(signaling_thread), in DtlsIdentityStoreImpl()
127 RTC_DCHECK(signaling_thread_->IsCurrent()); in DtlsIdentityStoreImpl()
[all …]
Ddtmfsender.cc96 signaling_thread_(signaling_thread), in DtmfSender()
101 ASSERT(signaling_thread_ != NULL); in DtmfSender()
126 ASSERT(signaling_thread_->IsCurrent()); in CanInsertDtmf()
135 ASSERT(signaling_thread_->IsCurrent()); in InsertDtmf()
157 signaling_thread_->Clear(this, MSG_DO_INSERT_DTMF); in InsertDtmf()
159 signaling_thread_->Post(this, MSG_DO_INSERT_DTMF); in InsertDtmf()
193 ASSERT(signaling_thread_->IsCurrent()); in DoInsertDtmf()
244 signaling_thread_->PostDelayed(tone_gap, this, MSG_DO_INSERT_DTMF); in DoInsertDtmf()
254 signaling_thread_->Clear(this); in StopSending()
Dproxy_unittest.cc95 EXPECT_EQ(rtc::Thread::Current(), signaling_thread_.get()); in CheckThread()
100 signaling_thread_.reset(new rtc::Thread()); in SetUp()
101 ASSERT_TRUE(signaling_thread_->Start()); in SetUp()
103 fake_proxy_ = FakeProxy::Create(signaling_thread_.get(), fake_.get()); in SetUp()
107 rtc::scoped_ptr<rtc::Thread> signaling_thread_; member in webrtc::ProxyTest
Dwebrtcsessiondescriptionfactory.cc141 : signaling_thread_(signaling_thread), in WebRtcSessionDescriptionFactory()
226 signaling_thread_->Post( in WebRtcSessionDescriptionFactory()
232 ASSERT(signaling_thread_->IsCurrent()); in ~WebRtcSessionDescriptionFactory()
240 signaling_thread_->Clear(this, rtc::MQID_ANY, &list); in ~WebRtcSessionDescriptionFactory()
470 ASSERT(signaling_thread_->IsCurrent()); in FailPendingRequests()
485 signaling_thread_->Post(this, MSG_CREATE_SESSIONDESCRIPTION_FAILED, msg); in PostCreateSessionDescriptionFailed()
494 signaling_thread_->Post(this, MSG_CREATE_SESSIONDESCRIPTION_SUCCESS, msg); in PostCreateSessionDescriptionSucceeded()
498 ASSERT(signaling_thread_->IsCurrent()); in OnIdentityRequestFailed()
Ddtmfsender.h113 rtc::Thread* signaling_thread_; variable
Dpeerconnectionfactory.h110 rtc::Thread* signaling_thread_; variable
Ddtlsidentitystore.h143 rtc::Thread* const signaling_thread_; variable
Dwebrtcsession.h161 rtc::Thread* signaling_thread() const { return signaling_thread_; } in signaling_thread()
470 rtc::Thread* const signaling_thread_; variable
Dwebrtcsessiondescriptionfactory.h177 rtc::Thread* const signaling_thread_; variable
Dpeerconnection.cc403 : signaling_thread_(signaling_thread), in RemoteMediaStreamFactory()
408 return MediaStreamProxy::Create(signaling_thread_, in CreateMediaStream()
435 TP::Create(signaling_thread_, T::Create(track_id, source))); in AddTrack()
443 rtc::Thread* signaling_thread_; member in webrtc::RemoteMediaStreamFactory
Dwebrtcsession.cc546 : signaling_thread_(signaling_thread), in WebRtcSession()
928 ASSERT(signaling_thread_->IsCurrent()); in SetState()
937 ASSERT(signaling_thread_->IsCurrent()); in SetError()
/external/webrtc/webrtc/p2p/base/
Dtransportcontroller.cc43 : signaling_thread_(signaling_thread), in TransportController()
50 signaling_thread_->Clear(this); in ~TransportController()
228 RTC_DCHECK(signaling_thread_->IsCurrent()); in OnMessage()
518 signaling_thread_->Post(this, MSG_CANDIDATESGATHERED, data); in OnChannelCandidateGathered_w()
585 signaling_thread_->Post( in UpdateAggregateStates_w()
592 signaling_thread_->Post(this, MSG_RECEIVING, in UpdateAggregateStates_w()
603 signaling_thread_->Post( in UpdateAggregateStates_w()
Dtransportcontroller_unittest.cc56 signaling_thread_(rtc::Thread::Current()) { in TransportControllerTest()
147 if (!signaling_thread_->IsCurrent()) { in OnConnectionState()
155 if (!signaling_thread_->IsCurrent()) { in OnReceiving()
163 if (!signaling_thread_->IsCurrent()) { in OnGatheringState()
172 if (!signaling_thread_->IsCurrent()) { in OnCandidatesGathered()
196 rtc::Thread* const signaling_thread_ = nullptr; member in TransportControllerTest
Dtransportcontroller.h38 rtc::Thread* signaling_thread() const { return signaling_thread_; } in signaling_thread()
193 rtc::Thread* const signaling_thread_ = nullptr; variable
/external/webrtc/talk/app/webrtc/java/jni/
Dpeerconnection_jni.cc1084 signaling_thread_(signaling_thread), in OwnedFactoryAndThreads()
1110 const scoped_ptr<Thread> signaling_thread_; member in webrtc_jni::OwnedFactoryAndThreads
1126 if (Thread::Current() == signaling_thread_) { in JavaCallbackOnFactoryThreads()
1141 signaling_thread_->Invoke<void>( in InvokeJavaCallbacksOnFactoryThreads()