Home
last modified time | relevance | path

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

12

/external/webrtc/pc/
Ddtmf_sender.h79 void QueueInsertDtmf(uint32_t delay_ms) RTC_RUN_ON(signaling_thread_);
82 void DoInsertDtmf() RTC_RUN_ON(signaling_thread_);
84 void StopSending() RTC_RUN_ON(signaling_thread_);
86 DtmfSenderObserverInterface* observer_ RTC_GUARDED_BY(signaling_thread_);
87 TaskQueueBase* const signaling_thread_; variable
88 DtmfProviderInterface* provider_ RTC_GUARDED_BY(signaling_thread_);
89 std::string tones_ RTC_GUARDED_BY(signaling_thread_);
90 int duration_ RTC_GUARDED_BY(signaling_thread_);
91 int inter_tone_gap_ RTC_GUARDED_BY(signaling_thread_);
92 int comma_delay_ RTC_GUARDED_BY(signaling_thread_);
[all …]
Dsctp_data_channel.cc159 auto* signaling_thread = channel->signaling_thread_; in CreateProxy()
168 : signaling_thread_(signaling_thread), in SctpDataChannel()
175 RTC_DCHECK_RUN_ON(signaling_thread_); in SctpDataChannel()
180 RTC_DCHECK_RUN_ON(signaling_thread_); in DetachFromController()
185 RTC_DCHECK_RUN_ON(signaling_thread_); in Init()
225 RTC_DCHECK_RUN_ON(signaling_thread_); in Init()
235 RTC_DCHECK_RUN_ON(signaling_thread_); in ~SctpDataChannel()
239 RTC_DCHECK_RUN_ON(signaling_thread_); in RegisterObserver()
245 RTC_DCHECK_RUN_ON(signaling_thread_); in UnregisterObserver()
255 RTC_DCHECK_RUN_ON(signaling_thread_); in buffered_amount()
[all …]
Ddtmf_sender.cc72 signaling_thread_(signaling_thread), in DtmfSender()
77 RTC_DCHECK(signaling_thread_); in DtmfSender()
82 RTC_DCHECK_RUN_ON(signaling_thread_); in OnDtmfProviderDestroyed()
89 RTC_DCHECK_RUN_ON(signaling_thread_); in ~DtmfSender()
94 RTC_DCHECK_RUN_ON(signaling_thread_); in RegisterObserver()
99 RTC_DCHECK_RUN_ON(signaling_thread_); in UnregisterObserver()
104 RTC_DCHECK_RUN_ON(signaling_thread_); in CanInsertDtmf()
115 RTC_DCHECK_RUN_ON(signaling_thread_); in InsertDtmf()
150 RTC_DCHECK_RUN_ON(signaling_thread_); in tones()
155 RTC_DCHECK_RUN_ON(signaling_thread_); in duration()
[all …]
Dsctp_data_channel.h260 rtc::Thread* const signaling_thread_; variable
265 DataChannelObserver* observer_ RTC_GUARDED_BY(signaling_thread_) = nullptr;
266 DataState state_ RTC_GUARDED_BY(signaling_thread_) = kConnecting;
267 RTCError error_ RTC_GUARDED_BY(signaling_thread_);
268 uint32_t messages_sent_ RTC_GUARDED_BY(signaling_thread_) = 0;
269 uint64_t bytes_sent_ RTC_GUARDED_BY(signaling_thread_) = 0;
270 uint32_t messages_received_ RTC_GUARDED_BY(signaling_thread_) = 0;
271 uint64_t bytes_received_ RTC_GUARDED_BY(signaling_thread_) = 0;
273 RTC_GUARDED_BY(signaling_thread_);
274 bool controller_detached_ RTC_GUARDED_BY(signaling_thread_) = false;
[all …]
Drtp_sender.cc95 : signaling_thread_(signaling_thread), callback_(std::move(callback)) {} in SignalingThreadCallback()
97 : signaling_thread_(other.signaling_thread_), in SignalingThreadCallback()
114 if (!signaling_thread_->IsCurrent()) { in Resolve()
115 signaling_thread_->PostTask( in Resolve()
127 rtc::Thread* signaling_thread_; member in webrtc::__anon9464d1180111::SignalingThreadCallback
153 : signaling_thread_(rtc::Thread::Current()), in RtpSenderBase()
163 RTC_DCHECK_RUN_ON(signaling_thread_); in SetFrameEncryptor()
175 RTC_DCHECK_RUN_ON(signaling_thread_); in SetEncoderSelector()
181 RTC_DCHECK_RUN_ON(signaling_thread_); in SetEncoderSelectorOnChannel()
196 RTC_DCHECK_RUN_ON(signaling_thread_); in GetParametersInternal()
[all …]
Dconnection_context.h72 rtc::Thread* signaling_thread() { return signaling_thread_; } in signaling_thread()
73 const rtc::Thread* signaling_thread() const { return signaling_thread_; } in signaling_thread()
87 RTC_DCHECK_RUN_ON(signaling_thread_); in default_network_manager()
91 RTC_DCHECK_RUN_ON(signaling_thread_); in default_socket_factory()
117 RTC_GUARDED_BY(signaling_thread_);
120 rtc::Thread* const signaling_thread_; variable
133 RTC_GUARDED_BY(signaling_thread_);
135 RTC_GUARDED_BY(signaling_thread_);
140 RTC_GUARDED_BY(signaling_thread_);
Dvideo_track.cc31 RTC_DCHECK_RUN_ON(&signaling_thread_); in VideoTrack()
40 RTC_DCHECK_RUN_ON(&signaling_thread_); in ~VideoTrack()
80 RTC_DCHECK_RUN_ON(&signaling_thread_); in content_hint()
85 RTC_DCHECK_RUN_ON(&signaling_thread_); in set_content_hint()
93 RTC_DCHECK_RUN_ON(&signaling_thread_); in set_enabled()
115 RTC_DCHECK_RUN_ON(&signaling_thread_); in enabled()
125 RTC_DCHECK_RUN_ON(&signaling_thread_); in OnChanged()
Dpeer_connection_message_handler.cc37 signaling_thread_->PostTask( in PostSetSessionDescriptionSuccess()
46 signaling_thread_->PostTask(SafeTask( in PostSetSessionDescriptionFailure()
59 signaling_thread_->PostTask( in PostCreateSessionDescriptionFailure()
69 signaling_thread_->PostTask( in PostGetStats()
81 signaling_thread_->PostDelayedTask(SafeTask(safety_.flag(), std::move(func)), in RequestUsagePatternReport()
Dproxy_unittest.cc94 void CheckSignalingThread() { EXPECT_TRUE(signaling_thread_->IsCurrent()); } in CheckSignalingThread()
98 signaling_thread_ = rtc::Thread::Create(); in SetUp()
99 ASSERT_TRUE(signaling_thread_->Start()); in SetUp()
102 FakeSignalingProxy::Create(signaling_thread_.get(), fake_); in SetUp()
106 std::unique_ptr<rtc::Thread> signaling_thread_; member in webrtc::SignalingProxyTest
180 void CheckSignalingThread() { EXPECT_TRUE(signaling_thread_->IsCurrent()); } in CheckSignalingThread()
185 signaling_thread_ = rtc::Thread::Create(); in SetUp()
187 ASSERT_TRUE(signaling_thread_->Start()); in SetUp()
191 FakeProxy::Create(signaling_thread_.get(), worker_thread_.get(), fake_); in SetUp()
195 std::unique_ptr<rtc::Thread> signaling_thread_; member in webrtc::ProxyTest
Dconnection_context.cc97 signaling_thread_(MaybeWrapThread(dependencies->signaling_thread,
111 RTC_DCHECK_RUN_ON(signaling_thread_);
115 signaling_thread_->AllowInvokesToThread(worker_thread());
116 signaling_thread_->AllowInvokesToThread(network_thread_);
163 signaling_thread_->SetDispatchWarningMs(100);
175 RTC_DCHECK_RUN_ON(signaling_thread_); in ~ConnectionContext()
Dwebrtc_session_description_factory.cc112 : signaling_thread_(context->signaling_thread()), in WebRtcSessionDescriptionFactory()
128 RTC_DCHECK(signaling_thread_); in WebRtcSessionDescriptionFactory()
173 RTC_DCHECK_RUN_ON(signaling_thread_); in ~WebRtcSessionDescriptionFactory()
193 RTC_DCHECK_RUN_ON(signaling_thread_); in CreateOffer()
384 RTC_DCHECK_RUN_ON(signaling_thread_); in FailPendingRequests()
422 RTC_DCHECK_RUN_ON(signaling_thread_); in Post()
424 signaling_thread_->PostTask([weak_ptr = weak_factory_.GetWeakPtr()] { in Post()
437 RTC_DCHECK_RUN_ON(signaling_thread_); in OnCertificateRequestFailed()
Drtp_sender.h162 RTC_DCHECK_RUN_ON(signaling_thread_); in stream_ids()
177 RTC_DCHECK_RUN_ON(signaling_thread_); in init_send_encodings()
186 RTC_DCHECK_RUN_ON(signaling_thread_); in dtls_transport()
219 RTC_DCHECK_RUN_ON(signaling_thread_); in SetTransceiverAsStopped()
253 rtc::Thread* const signaling_thread_; variable
256 bool stopped_ RTC_GUARDED_BY(signaling_thread_) = false;
257 bool is_transceiver_stopped_ RTC_GUARDED_BY(signaling_thread_) = false;
Dpeer_connection_message_handler.h30 : signaling_thread_(signaling_thread) {} in PeerConnectionMessageHandler()
47 TaskQueueBase* const signaling_thread_; variable
Dsdp_offer_answer_unittest.cc61 : signaling_thread_(CreateAndStartThread()), in SdpOfferAnswerTest()
65 signaling_thread_.get(), in SdpOfferAnswerTest()
94 std::unique_ptr<rtc::Thread> signaling_thread_; member in webrtc::SdpOfferAnswerTest
Dvideo_track.h73 RTC_NO_UNIQUE_ADDRESS webrtc::SequenceChecker signaling_thread_; variable
78 ContentHint content_hint_ RTC_GUARDED_BY(&signaling_thread_);
/external/webrtc/test/peer_scenario/
Dpeer_scenario_client.cc203 signaling_thread_(signaling_thread), in PeerScenarioClient()
213 RTC_DCHECK_RUN_ON(signaling_thread_); in PeerScenarioClient()
221 RTC_DCHECK_RUN_ON(signaling_thread_); in PeerScenarioClient()
238 pcf_deps.signaling_thread = signaling_thread_; in PeerScenarioClient()
306 RTC_DCHECK_RUN_ON(signaling_thread_); in CreateAudio()
318 RTC_DCHECK_RUN_ON(signaling_thread_); in CreateVideo()
336 RTC_DCHECK_RUN_ON(signaling_thread_); in AddVideoReceiveSink()
343 RTC_DCHECK_RUN_ON(signaling_thread_); in CreateAndSetSdp()
347 RTC_DCHECK_RUN_ON(signaling_thread_); in CreateAndSetSdp()
367 if (!signaling_thread_->IsCurrent()) { in SetSdpOfferAndGetAnswer()
[all …]
Dpeer_scenario_client.h122 RTC_DCHECK_RUN_ON(signaling_thread_); in pc()
125 rtc::Thread* thread() { return signaling_thread_; } in thread()
161 rtc::Thread* const signaling_thread_; variable
164 CallbackHandlers handlers_ RTC_GUARDED_BY(signaling_thread_);
167 track_id_to_video_sinks_ RTC_GUARDED_BY(signaling_thread_);
169 RTC_GUARDED_BY(signaling_thread_);
173 RTC_GUARDED_BY(signaling_thread_);
Dscenario_connection.cc58 rtc::Thread* const signaling_thread_; member in webrtc::ScenarioIceConnectionImpl
63 RTC_GUARDED_BY(signaling_thread_);
70 RTC_GUARDED_BY(signaling_thread_);
72 RTC_GUARDED_BY(signaling_thread_);
87 signaling_thread_(rtc::Thread::Current()),
167 RTC_DCHECK_RUN_ON(signaling_thread_); in SetRemoteSdp()
203 RTC_DCHECK_RUN_ON(signaling_thread_); in SetLocalSdp()
238 RTC_DCHECK_RUN_ON(signaling_thread_); in OnCandidates()
/external/webrtc/rtc_base/
Drtc_certificate_generator_unittest.cc27 : signaling_thread_(Thread::Current()), in RTCCertificateGeneratorFixture()
30 RTC_CHECK(signaling_thread_); in RTCCertificateGeneratorFixture()
33 new RTCCertificateGenerator(signaling_thread_, worker_thread_.get())); in RTCCertificateGeneratorFixture()
41 RTC_CHECK(signaling_thread_->IsCurrent()); in OnGenerated()
48 RTC_CHECK(signaling_thread_->IsCurrent()); in GenerateAsyncCompleted()
58 Thread* const signaling_thread_; member in rtc::RTCCertificateGeneratorFixture
Drtc_certificate_generator.cc64 : signaling_thread_(signaling_thread), worker_thread_(worker_thread) { in RTCCertificateGenerator()
65 RTC_DCHECK(signaling_thread_); in RTCCertificateGenerator()
73 RTC_DCHECK(signaling_thread_->IsCurrent()); in GenerateCertificateAsync()
77 signaling_thread = signaling_thread_, in GenerateCertificateAsync()
/external/webrtc/pc/test/
Dfake_peer_connection_for_stats.h152 signaling_thread_(rtc::Thread::Current()), in FakePeerConnectionForStats()
186 signaling_thread_, sender); in AddSender()
204 signaling_thread_, worker_thread_, receiver); in AddReceiver()
225 worker_thread_, network_thread_, signaling_thread_,
251 worker_thread_, network_thread_, signaling_thread_,
352 rtc::Thread* signaling_thread() const override { return signaling_thread_; } in signaling_thread()
437 signaling_thread_, in CreateTransceiverOfType()
445 rtc::Thread* const signaling_thread_; variable
/external/webrtc/examples/androidnativeapi/jni/
Dandroid_call_client.cc101 video_source_ = webrtc::CreateJavaVideoSource(env, signaling_thread_.get(), in Call()
149 signaling_thread_ = rtc::Thread::Create(); in CreatePeerConnectionFactory()
150 signaling_thread_->SetName("signaling_thread", nullptr); in CreatePeerConnectionFactory()
151 RTC_CHECK(signaling_thread_->Start()) << "Failed to start thread"; in CreatePeerConnectionFactory()
156 pcf_deps.signaling_thread = signaling_thread_.get(); in CreatePeerConnectionFactory()
/external/webrtc/sdk/android/src/jni/
Dandroid_video_track_source.cc46 signaling_thread_(signaling_thread), in AndroidVideoTrackSource()
65 if (rtc::Thread::Current() == signaling_thread_) { in SetState()
70 signaling_thread_->PostTask([this] { FireOnChanged(); }); in SetState()
/external/webrtc/sdk/android/src/jni/pc/
Downed_factory_and_threads.h44 rtc::Thread* signaling_thread() { return signaling_thread_.get(); } in signaling_thread()
53 const std::unique_ptr<rtc::Thread> signaling_thread_; variable
/external/webrtc/test/pc/e2e/
Dtest_peer_factory.h59 : signaling_thread_(signaling_thread), in TestPeerFactory()
75 rtc::Thread* signaling_thread_;

12