Home
last modified time | relevance | path

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

12

/external/webrtc/pc/
Drtp_data_channel.cc84 return DataChannelProxy::Create(channel->signaling_thread_, channel.get()); in CreateProxy()
91 : signaling_thread_(signaling_thread), in RtpDataChannel()
96 RTC_DCHECK_RUN_ON(signaling_thread_); in RtpDataChannel()
100 RTC_DCHECK_RUN_ON(signaling_thread_); in Init()
112 RTC_DCHECK_RUN_ON(signaling_thread_); in ~RtpDataChannel()
116 RTC_DCHECK_RUN_ON(signaling_thread_); in RegisterObserver()
122 RTC_DCHECK_RUN_ON(signaling_thread_); in UnregisterObserver()
127 RTC_DCHECK_RUN_ON(signaling_thread_); in Close()
137 RTC_DCHECK_RUN_ON(signaling_thread_); in state()
142 RTC_DCHECK_RUN_ON(signaling_thread_); in error()
[all …]
Drtp_data_channel.h175 rtc::Thread* const signaling_thread_; variable
179 DataChannelObserver* observer_ RTC_GUARDED_BY(signaling_thread_) = nullptr;
180 DataState state_ RTC_GUARDED_BY(signaling_thread_) = kConnecting;
181 RTCError error_ RTC_GUARDED_BY(signaling_thread_);
182 uint32_t messages_sent_ RTC_GUARDED_BY(signaling_thread_) = 0;
183 uint64_t bytes_sent_ RTC_GUARDED_BY(signaling_thread_) = 0;
184 uint32_t messages_received_ RTC_GUARDED_BY(signaling_thread_) = 0;
185 uint64_t bytes_received_ RTC_GUARDED_BY(signaling_thread_) = 0;
187 bool connected_to_provider_ RTC_GUARDED_BY(signaling_thread_) = false;
188 bool send_ssrc_set_ RTC_GUARDED_BY(signaling_thread_) = false;
[all …]
Dsctp_data_channel.h252 rtc::Thread* const signaling_thread_; variable
257 DataChannelObserver* observer_ RTC_GUARDED_BY(signaling_thread_) = nullptr;
258 DataState state_ RTC_GUARDED_BY(signaling_thread_) = kConnecting;
259 RTCError error_ RTC_GUARDED_BY(signaling_thread_);
260 uint32_t messages_sent_ RTC_GUARDED_BY(signaling_thread_) = 0;
261 uint64_t bytes_sent_ RTC_GUARDED_BY(signaling_thread_) = 0;
262 uint32_t messages_received_ RTC_GUARDED_BY(signaling_thread_) = 0;
263 uint64_t bytes_received_ RTC_GUARDED_BY(signaling_thread_) = 0;
266 uint64_t buffered_amount_ RTC_GUARDED_BY(signaling_thread_) = 0;
268 RTC_GUARDED_BY(signaling_thread_);
[all …]
Dsctp_data_channel.cc154 return DataChannelProxy::Create(channel->signaling_thread_, channel.get()); in CreateProxy()
162 : signaling_thread_(signaling_thread), in SctpDataChannel()
169 RTC_DCHECK_RUN_ON(signaling_thread_); in SctpDataChannel()
173 RTC_DCHECK_RUN_ON(signaling_thread_); in Init()
217 RTC_DCHECK_RUN_ON(signaling_thread_); in ~SctpDataChannel()
221 RTC_DCHECK_RUN_ON(signaling_thread_); in RegisterObserver()
227 RTC_DCHECK_RUN_ON(signaling_thread_); in UnregisterObserver()
237 RTC_DCHECK_RUN_ON(signaling_thread_); in buffered_amount()
242 RTC_DCHECK_RUN_ON(signaling_thread_); in Close()
251 RTC_DCHECK_RUN_ON(signaling_thread_); in state()
[all …]
Dpeer_connection_factory.cc75 signaling_thread_(dependencies.signaling_thread), in PeerConnectionFactory()
102 if (!signaling_thread_) { in PeerConnectionFactory()
103 signaling_thread_ = rtc::Thread::Current(); in PeerConnectionFactory()
104 if (!signaling_thread_) { in PeerConnectionFactory()
107 signaling_thread_ = rtc::ThreadManager::Instance()->WrapCurrentThread(); in PeerConnectionFactory()
111 signaling_thread_->AllowInvokesToThread(worker_thread_); in PeerConnectionFactory()
112 signaling_thread_->AllowInvokesToThread(network_thread_); in PeerConnectionFactory()
118 RTC_DCHECK(signaling_thread_->IsCurrent()); in ~PeerConnectionFactory()
131 RTC_DCHECK(signaling_thread_->IsCurrent()); in Initialize()
163 RTC_DCHECK_RUN_ON(signaling_thread_); in GetRtpSenderCapabilities()
[all …]
Dproxy_unittest.cc93 void CheckSignalingThread() { EXPECT_TRUE(signaling_thread_->IsCurrent()); } in CheckSignalingThread()
97 signaling_thread_ = rtc::Thread::Create(); in SetUp()
98 ASSERT_TRUE(signaling_thread_->Start()); in SetUp()
101 FakeSignalingProxy::Create(signaling_thread_.get(), fake_.get()); in SetUp()
105 std::unique_ptr<rtc::Thread> signaling_thread_; member in webrtc::SignalingProxyTest
179 void CheckSignalingThread() { EXPECT_TRUE(signaling_thread_->IsCurrent()); } in CheckSignalingThread()
184 signaling_thread_ = rtc::Thread::Create(); in SetUp()
186 ASSERT_TRUE(signaling_thread_->Start()); in SetUp()
189 fake_proxy_ = FakeProxy::Create(signaling_thread_.get(), in SetUp()
194 std::unique_ptr<rtc::Thread> signaling_thread_; member in webrtc::ProxyTest
[all …]
Ddtmf_sender.cc75 signaling_thread_(signaling_thread), in DtmfSender()
80 RTC_DCHECK(signaling_thread_); in DtmfSender()
101 RTC_DCHECK(signaling_thread_->IsCurrent()); in CanInsertDtmf()
112 RTC_DCHECK(signaling_thread_->IsCurrent()); in InsertDtmf()
161 posted_from, signaling_thread_, [this] { DoInsertDtmf(); }, delay_ms); in QueueInsertDtmf()
165 RTC_DCHECK(signaling_thread_->IsCurrent()); in DoInsertDtmf()
Djitter_buffer_delay.cc29 : signaling_thread_(rtc::Thread::Current()), worker_thread_(worker_thread) { in JitterBufferDelay()
35 RTC_DCHECK_RUN_ON(signaling_thread_); in OnStart()
47 RTC_DCHECK_RUN_ON(signaling_thread_); in OnStop()
Dwebrtc_session_description_factory.cc133 : signaling_thread_(signaling_thread), in WebRtcSessionDescriptionFactory()
146 RTC_DCHECK(signaling_thread_); in WebRtcSessionDescriptionFactory()
164 signaling_thread_->Post( in WebRtcSessionDescriptionFactory()
191 RTC_DCHECK(signaling_thread_->IsCurrent()); in ~WebRtcSessionDescriptionFactory()
199 signaling_thread_->Clear(this, rtc::MQID_ANY, &list); in ~WebRtcSessionDescriptionFactory()
435 RTC_DCHECK(signaling_thread_->IsCurrent()); in FailPendingRequests()
454 signaling_thread_->Post(RTC_FROM_HERE, this, in PostCreateSessionDescriptionFailed()
465 signaling_thread_->Post(RTC_FROM_HERE, this, in PostCreateSessionDescriptionSucceeded()
470 RTC_DCHECK(signaling_thread_->IsCurrent()); in OnCertificateRequestFailed()
Drtc_stats_collector.cc1002 signaling_thread_(pc->signaling_thread()), in RTCStatsCollector()
1012 RTC_DCHECK(signaling_thread_); in RTCStatsCollector()
1045 RTC_DCHECK(signaling_thread_->IsCurrent()); in GetStatsReportInternal()
1057 signaling_thread_->PostTask( in GetStatsReportInternal()
1104 RTC_DCHECK(signaling_thread_->IsCurrent()); in ClearCachedStatsReport()
1109 RTC_DCHECK(signaling_thread_->IsCurrent()); in WaitForPendingRequest()
1117 RTC_DCHECK(signaling_thread_->IsCurrent()); in ProducePartialResultsOnSignalingThread()
1136 RTC_DCHECK(signaling_thread_->IsCurrent()); in ProducePartialResultsOnSignalingThreadImpl()
1167 signaling_thread_->PostTask( in ProducePartialResultsOnNetworkThread()
1191 RTC_DCHECK(signaling_thread_->IsCurrent()); in MergeNetworkReport_s()
[all …]
Dpeer_connection_factory.h82 return signaling_thread_; in signaling_thread()
110 rtc::Thread* signaling_thread_; variable
Djsep_transport_controller.cc82 : signaling_thread_(signaling_thread), in JsepTransportController()
1156 RTC_FROM_HERE, signaling_thread_, [this, transport_name, candidate] { in OnTransportCandidateGathered_n()
1166 invoker_.AsyncInvoke<void>(RTC_FROM_HERE, signaling_thread_, in OnTransportCandidateError_n()
1173 RTC_FROM_HERE, signaling_thread_, in OnTransportCandidatesRemoved_n()
1178 invoker_.AsyncInvoke<void>(RTC_FROM_HERE, signaling_thread_, [this, event] { in OnTransportCandidatePairChanged_n()
1259 invoker_.AsyncInvoke<void>(RTC_FROM_HERE, signaling_thread_, in UpdateAggregateStates_n()
1318 invoker_.AsyncInvoke<void>(RTC_FROM_HERE, signaling_thread_, [this] { in UpdateAggregateStates_n()
1325 RTC_FROM_HERE, signaling_thread_, [this, new_ice_connection_state] { in UpdateAggregateStates_n()
1378 invoker_.AsyncInvoke<void>(RTC_FROM_HERE, signaling_thread_, in UpdateAggregateStates_n()
1391 invoker_.AsyncInvoke<void>(RTC_FROM_HERE, signaling_thread_, in UpdateAggregateStates_n()
/external/webrtc/rtc_base/
Drtc_certificate_generator.cc51 : signaling_thread_(signaling_thread), in RTCCertificateGenerationTask()
56 RTC_DCHECK(signaling_thread_); in RTCCertificateGenerationTask()
72 signaling_thread_->Post(RTC_FROM_HERE, this, MSG_GENERATE_DONE, in OnMessage()
76 RTC_DCHECK(signaling_thread_->IsCurrent()); in OnMessage()
94 Thread* const signaling_thread_; member in rtc::__anon138cbc250111::RTCCertificateGenerationTask
136 : signaling_thread_(signaling_thread), worker_thread_(worker_thread) { in RTCCertificateGenerator()
137 RTC_DCHECK(signaling_thread_); in RTCCertificateGenerator()
145 RTC_DCHECK(signaling_thread_->IsCurrent()); in GenerateCertificateAsync()
154 signaling_thread_, worker_thread_, key_params, expires_ms, in GenerateCertificateAsync()
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 OnSuccess()
47 RTC_CHECK(signaling_thread_->IsCurrent()); in OnFailure()
53 RTC_CHECK(signaling_thread_->IsCurrent()); in GenerateAsyncCompleted()
63 Thread* const signaling_thread_; member in rtc::RTCCertificateGeneratorFixture
/external/webrtc/test/peer_scenario/
Dpeer_scenario_client.cc159 signaling_thread_(signaling_thread), in PeerScenarioClient()
169 RTC_DCHECK_RUN_ON(signaling_thread_); in PeerScenarioClient()
177 RTC_DCHECK_RUN_ON(signaling_thread_); in PeerScenarioClient()
194 pcf_deps.signaling_thread = signaling_thread_; in PeerScenarioClient()
255 RTC_DCHECK_RUN_ON(signaling_thread_); in CreateAudio()
267 RTC_DCHECK_RUN_ON(signaling_thread_); in CreateVideo()
285 RTC_DCHECK_RUN_ON(signaling_thread_); in AddVideoReceiveSink()
291 RTC_DCHECK_RUN_ON(signaling_thread_); in CreateAndSetSdp()
294 RTC_DCHECK_RUN_ON(signaling_thread_); in CreateAndSetSdp()
309 if (!signaling_thread_->IsCurrent()) { in SetSdpOfferAndGetAnswer()
[all …]
Dpeer_scenario_client.h120 RTC_DCHECK_RUN_ON(signaling_thread_); in pc()
123 rtc::Thread* thread() { return signaling_thread_; } in thread()
155 rtc::Thread* const signaling_thread_; variable
158 CallbackHandlers handlers_ RTC_GUARDED_BY(signaling_thread_);
161 track_id_to_video_sinks_ RTC_GUARDED_BY(signaling_thread_);
163 RTC_GUARDED_BY(signaling_thread_);
167 RTC_GUARDED_BY(signaling_thread_);
Dscenario_connection.cc56 rtc::Thread* const signaling_thread_; member in webrtc::ScenarioIceConnectionImpl
61 RTC_GUARDED_BY(signaling_thread_);
68 RTC_GUARDED_BY(signaling_thread_);
70 RTC_GUARDED_BY(signaling_thread_);
85 signaling_thread_(rtc::Thread::Current()),
100 new JsepTransportController(signaling_thread_,
166 RTC_DCHECK_RUN_ON(signaling_thread_); in SetRemoteSdp()
198 RTC_DCHECK_RUN_ON(signaling_thread_); in SetLocalSdp()
234 RTC_DCHECK_RUN_ON(signaling_thread_); in OnCandidates()
Dpeer_scenario.cc59 signaling_thread_(net_.time_controller()->GetMainThread()) {} in PeerScenario()
70 peer_clients_.emplace_back(net(), signaling_thread_, in CreateClient()
/external/webrtc/api/
Dproxy.h198 : signaling_thread_(signaling_thread), c_(c) {} \
201 mutable rtc::Thread* signaling_thread_;
207 : signaling_thread_(signaling_thread), \
212 mutable rtc::Thread* signaling_thread_; \
283 rtc::Thread* destructor_thread() const { return signaling_thread_; } \
296 return call.Marshal(RTC_FROM_HERE, signaling_thread_); \
302 return call.Marshal(RTC_FROM_HERE, signaling_thread_); \
308 return call.Marshal(RTC_FROM_HERE, signaling_thread_); \
314 return call.Marshal(RTC_FROM_HERE, signaling_thread_); \
321 return call.Marshal(RTC_FROM_HERE, signaling_thread_); \
[all …]
/external/webrtc/pc/test/
Dfake_peer_connection_for_stats.h88 signaling_thread_(rtc::Thread::Current()), in FakePeerConnectionForStats()
104 signaling_thread_, sender); in AddSender()
122 signaling_thread_, receiver); in AddReceiver()
143 worker_thread_, network_thread_, signaling_thread_, in AddVoiceChannel()
161 worker_thread_, network_thread_, signaling_thread_, in AddVideoChannel()
254 rtc::Thread* signaling_thread() const override { return signaling_thread_; } in signaling_thread()
346 signaling_thread_, new RtpTransceiver(media_type)); in GetOrCreateFirstTransceiverOfType()
353 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/pc/
Downed_factory_and_threads.h43 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.h60 : signaling_thread_(signaling_thread), in TestPeerFactory()
78 rtc::Thread* signaling_thread_;
/external/webrtc/sdk/android/src/jni/
Dandroid_video_track_source.cc47 signaling_thread_(signaling_thread), in AndroidVideoTrackSource()
66 if (rtc::Thread::Current() == signaling_thread_) { in SetState()
71 signaling_thread_->PostTask( in SetState()
/external/webrtc/examples/objcnativeapi/objc/
Dobjc_call_client.mm81 webrtc::ObjCToNativeVideoCapturer(capturer, signaling_thread_.get(), worker_thread_.get());
113 signaling_thread_ = rtc::Thread::Create();
114 signaling_thread_->SetName("signaling_thread", nullptr);
115 RTC_CHECK(signaling_thread_->Start()) << "Failed to start thread";
120 dependencies.signaling_thread = signaling_thread_.get();

12