Home
last modified time | relevance | path

Searched refs:signaling_thread (Results 1 – 25 of 68) sorted by relevance

123

/external/webrtc/pc/
Dpeer_connection.h254 rtc::Thread* signaling_thread() const final { in signaling_thread() function
255 return factory_->signaling_thread(); in signaling_thread()
259 RTC_DCHECK_RUN_ON(signaling_thread()); in session_id()
264 RTC_DCHECK_RUN_ON(signaling_thread()); in initial_offerer()
271 RTC_DCHECK_RUN_ON(signaling_thread()); in GetTransceiversInternal()
311 RTC_DCHECK_RUN_ON(signaling_thread()); in IsClosed()
321 RTC_DCHECK_RUN_ON(signaling_thread()); in ReturnHistogramVeryQuicklyForTesting()
326 RTC_DCHECK_RUN_ON(signaling_thread()); in sctp_mid()
402 RTC_RUN_ON(signaling_thread());
404 RTC_RUN_ON(signaling_thread());
[all …]
Ddata_channel_controller.h88 RTC_DCHECK_RUN_ON(signaling_thread()); in HasSctpDataChannels()
92 RTC_DCHECK_RUN_ON(signaling_thread()); in HasRtpDataChannels()
114 RTC_DCHECK_RUN_ON(signaling_thread()); in SignalRtpDataChannelCreated()
118 RTC_DCHECK_RUN_ON(signaling_thread()); in SignalSctpDataChannelCreated()
140 RTC_RUN_ON(signaling_thread());
144 RTC_RUN_ON(signaling_thread());
148 RTC_RUN_ON(signaling_thread());
152 bool is_local_update) RTC_RUN_ON(signaling_thread());
164 rtc::Thread* signaling_thread() const;
186 RTC_GUARDED_BY(signaling_thread()) = false;
[all …]
Ddata_channel_controller.cc21 RTC_DCHECK_RUN_ON(signaling_thread()); in HasDataChannels()
38 RTC_DCHECK_RUN_ON(signaling_thread()); in ConnectDataChannel()
54 RTC_DCHECK_RUN_ON(signaling_thread()); in DisconnectDataChannel()
66 RTC_DCHECK_RUN_ON(signaling_thread()); in ConnectDataChannel()
86 RTC_DCHECK_RUN_ON(signaling_thread()); in DisconnectDataChannel()
119 RTC_DCHECK_RUN_ON(signaling_thread()); in ReadyToSendData()
133 RTC_FROM_HERE, signaling_thread(), [this, params, buffer] { in OnDataReceived()
134 RTC_DCHECK_RUN_ON(signaling_thread()); in OnDataReceived()
152 RTC_FROM_HERE, signaling_thread(), [this, channel_id] { in OnChannelClosing()
153 RTC_DCHECK_RUN_ON(signaling_thread()); in OnChannelClosing()
[all …]
Dchannel_manager.cc190 rtc::Thread* signaling_thread, in CreateVoiceChannel() argument
199 signaling_thread, content_name, srtp_required, in CreateVoiceChannel()
218 worker_thread_, network_thread_, signaling_thread, in CreateVoiceChannel()
258 rtc::Thread* signaling_thread, in CreateVideoChannel() argument
268 signaling_thread, content_name, srtp_required, in CreateVideoChannel()
289 worker_thread_, network_thread_, signaling_thread, in CreateVideoChannel()
328 rtc::Thread* signaling_thread, in CreateRtpDataChannel() argument
335 return CreateRtpDataChannel(media_config, rtp_transport, signaling_thread, in CreateRtpDataChannel()
350 worker_thread_, network_thread_, signaling_thread, in CreateRtpDataChannel()
Ddtmf_sender.cc62 rtc::Thread* signaling_thread, in Create() argument
64 if (!signaling_thread) { in Create()
68 new rtc::RefCountedObject<DtmfSender>(signaling_thread, provider)); in Create()
72 DtmfSender::DtmfSender(rtc::Thread* signaling_thread, in DtmfSender() argument
75 signaling_thread_(signaling_thread), in DtmfSender()
Dpeer_connection.cc1051 RTC_DCHECK_RUN_ON(signaling_thread()); in ~PeerConnection()
1094 signaling_thread()->Clear(this, rtc::MQID_ANY, &list); in ~PeerConnection()
1128 RTC_DCHECK_RUN_ON(signaling_thread()); in Initialize()
1282 signaling_thread(), network_thread(), port_allocator_.get(), in Initialize()
1339 signaling_thread(), channel_manager(), this, session_id(), in Initialize()
1356 signaling_thread(), new RtpTransceiver(cricket::MEDIA_TYPE_AUDIO))); in Initialize()
1359 signaling_thread(), new RtpTransceiver(cricket::MEDIA_TYPE_VIDEO))); in Initialize()
1363 signaling_thread()->PostDelayed(RTC_FROM_HERE, delay_ms, this, in Initialize()
1383 RTC_DCHECK_RUN_ON(signaling_thread()); in local_streams()
1391 RTC_DCHECK_RUN_ON(signaling_thread()); in remote_streams()
[all …]
Dchannel_manager.h103 rtc::Thread* signaling_thread,
119 rtc::Thread* signaling_thread,
132 rtc::Thread* signaling_thread,
Dstats_collector.cc512 RTC_DCHECK(pc_->signaling_thread()->IsCurrent()); in ~StatsCollector()
523 RTC_DCHECK(pc_->signaling_thread()->IsCurrent()); in AddStream()
546 RTC_DCHECK(pc_->signaling_thread()->IsCurrent()); in AddLocalAudioTrack()
580 RTC_DCHECK(pc_->signaling_thread()->IsCurrent()); in GetStats()
620 RTC_DCHECK(pc_->signaling_thread()->IsCurrent()); in UpdateStats()
650 RTC_DCHECK(pc_->signaling_thread()->IsCurrent()); in PrepareReport()
673 RTC_DCHECK(pc_->signaling_thread()->IsCurrent()); in PrepareADMReport()
687 RTC_DCHECK(pc_->signaling_thread()->IsCurrent()); in AddCertificateReports()
814 RTC_DCHECK(pc_->signaling_thread()->IsCurrent()); in ExtractSessionInfo()
922 RTC_DCHECK(pc_->signaling_thread()->IsCurrent()); in ExtractBweInfo()
[all …]
Ddtmf_sender.h50 static rtc::scoped_refptr<DtmfSender> Create(rtc::Thread* signaling_thread,
67 DtmfSender(rtc::Thread* signaling_thread, DtmfProviderInterface* provider);
Drtp_data_channel.cc71 rtc::Thread* signaling_thread) { in Create() argument
74 signaling_thread)); in Create()
90 rtc::Thread* signaling_thread) in RtpDataChannel() argument
91 : signaling_thread_(signaling_thread), in RtpDataChannel()
/external/webrtc/sdk/android/native_unittests/peerconnection/
Dpeer_connection_factory_unittest.cc38 rtc::Thread* signaling_thread) { in CreateTestPCF() argument
49 pcf_deps.signaling_thread = signaling_thread; in CreateTestPCF()
93 std::unique_ptr<rtc::Thread> signaling_thread = rtc::Thread::Create(); in TEST() local
94 signaling_thread->SetName("signaling_thread", NULL); in TEST()
95 RTC_CHECK(signaling_thread->Start()) << "Failed to start thread"; in TEST()
99 signaling_thread.get()); in TEST()
103 std::move(signaling_thread), nullptr /* network_monitor_factory */); in TEST()
/external/webrtc/test/network/
Dnetwork_emulation_pc_unittest.cc53 rtc::Thread* signaling_thread, in CreatePeerConnectionFactory() argument
61 pcf_deps.signaling_thread = signaling_thread; in CreatePeerConnectionFactory()
97 std::unique_ptr<rtc::Thread> signaling_thread = rtc::Thread::Create(); in TEST() local
98 signaling_thread->SetName(kSignalThreadName, nullptr); in TEST()
99 signaling_thread->Start(); in TEST()
131 signaling_thread->Invoke<void>(RTC_FROM_HERE, [&]() { in TEST()
132 alice_pcf = CreatePeerConnectionFactory(signaling_thread.get(), in TEST()
137 bob_pcf = CreatePeerConnectionFactory(signaling_thread.get(), in TEST()
150 signaling_thread->Invoke<void>(RTC_FROM_HERE, [&]() { in TEST()
/external/webrtc/sdk/android/native_api/video/
Dvideo_source.cc27 rtc::Thread* signaling_thread, in JavaVideoTrackSourceImpl() argument
32 signaling_thread, in JavaVideoTrackSourceImpl()
108 rtc::Thread* signaling_thread, in CreateJavaVideoSource() argument
112 jni, signaling_thread, is_screencast, align_timestamps); in CreateJavaVideoSource()
/external/webrtc/sdk/android/src/jni/pc/
Dpeer_connection_factory.cc141 std::unique_ptr<rtc::Thread> signaling_thread, in NativeToScopedJavaPeerConnectionFactory() argument
145 std::move(signaling_thread), network_monitor_factory, pcf); in NativeToScopedJavaPeerConnectionFactory()
154 PostJavaCallback(env, owned_factory->signaling_thread(), RTC_FROM_HERE, j_pcf, in NativeToScopedJavaPeerConnectionFactory()
181 std::unique_ptr<rtc::Thread> signaling_thread, in NativeToJavaPeerConnectionFactory() argument
185 std::move(signaling_thread), network_monitor_factory) in NativeToJavaPeerConnectionFactory()
283 std::unique_ptr<rtc::Thread> signaling_thread = rtc::Thread::Create(); in CreatePeerConnectionFactoryForJava() local
284 signaling_thread->SetName("signaling_thread", NULL); in CreatePeerConnectionFactoryForJava()
285 RTC_CHECK(signaling_thread->Start()) << "Failed to start thread"; in CreatePeerConnectionFactoryForJava()
302 dependencies.signaling_thread = signaling_thread.get(); in CreatePeerConnectionFactoryForJava()
339 std::move(signaling_thread), network_monitor_factory); in CreatePeerConnectionFactoryForJava()
[all …]
Downed_factory_and_threads.cc21 std::unique_ptr<rtc::Thread> signaling_thread, in OwnedFactoryAndThreads() argument
26 signaling_thread_(std::move(signaling_thread)), in OwnedFactoryAndThreads()
Dvideo.cc44 rtc::Thread* signaling_thread, in CreateVideoSource() argument
50 signaling_thread, env, is_screencast, align_timestamps)); in CreateVideoSource()
Downed_factory_and_threads.h35 std::unique_ptr<rtc::Thread> signaling_thread,
43 rtc::Thread* signaling_thread() { return signaling_thread_.get(); } in signaling_thread() function
/external/webrtc/rtc_base/
Drtc_certificate_generator.cc46 Thread* signaling_thread, in RTCCertificateGenerationTask() argument
51 : signaling_thread_(signaling_thread), in RTCCertificateGenerationTask()
134 RTCCertificateGenerator::RTCCertificateGenerator(Thread* signaling_thread, in RTCCertificateGenerator() argument
136 : signaling_thread_(signaling_thread), worker_thread_(worker_thread) { in RTCCertificateGenerator()
/external/webrtc/api/
Dcreate_peerconnection_factory.cc32 rtc::Thread* signaling_thread, in CreatePeerConnectionFactory() argument
43 dependencies.signaling_thread = signaling_thread; in CreatePeerConnectionFactory()
Dproxy.h197 c##ProxyWithInternal(rtc::Thread* signaling_thread, INTERNAL_CLASS* c) \
198 : signaling_thread_(signaling_thread), c_(c) {} \
205 c##ProxyWithInternal(rtc::Thread* signaling_thread, \
207 : signaling_thread_(signaling_thread), \
252 rtc::Thread* signaling_thread, INTERNAL_CLASS* c) { \
253 return new rtc::RefCountedObject<c##ProxyWithInternal>(signaling_thread, \
263 rtc::Thread* signaling_thread, rtc::Thread* worker_thread, \
265 return new rtc::RefCountedObject<c##ProxyWithInternal>(signaling_thread, \
275 rtc::Thread* signaling_thread, rtc::Thread* worker_thread, \
278 signaling_thread, worker_thread, c.release())); \
/external/webrtc/test/pc/e2e/
Dpeer_connection_quality_test.cc196 const std::unique_ptr<rtc::Thread> signaling_thread = in Run() local
225 signaling_thread.get(), time_controller_, in Run()
315 signaling_thread->Invoke<void>( in Run()
322 signaling_thread->Invoke<void>( in Run()
326 WaitUntilIceCandidatesGathered(signaling_thread.get()); in Run()
328 signaling_thread->Invoke<void>( in Run()
332 WaitUntilPeersAreConnected(signaling_thread.get()); in Run()
363 signaling_thread->Invoke<void>( in Run()
568 rtc::Thread* signaling_thread) { in WaitUntilIceCandidatesGathered() argument
571 return signaling_thread->Invoke<bool>(RTC_FROM_HERE, [&]() { in WaitUntilIceCandidatesGathered()
[all …]
Dtest_peer_factory.h56 TestPeerFactory(rtc::Thread* signaling_thread, in TestPeerFactory() argument
60 : signaling_thread_(signaling_thread), in TestPeerFactory()
/external/webrtc/sdk/android/native_api/peerconnection/
Dpeer_connection_factory.cc26 std::unique_ptr<rtc::Thread> signaling_thread, in NativeToJavaPeerConnectionFactory() argument
30 std::move(signaling_thread), network_monitor_factory); in NativeToJavaPeerConnectionFactory()
/external/webrtc/sdk/objc/native/api/
Dvideo_capturer.mm21 rtc::Thread *signaling_thread,
28 signaling_thread, worker_thread, objc_video_track_source);
/external/webrtc/pc/test/
Dmock_data_channel.h42 rtc::Thread* signaling_thread = rtc::Thread::Current(),
47 signaling_thread,

123