Home
last modified time | relevance | path

Searched refs:network_thread_ (Results 1 – 25 of 48) sorted by relevance

12

/external/webrtc/p2p/base/
Dp2p_transport_channel.h147 RTC_DCHECK_RUN_ON(network_thread_); in best_connection()
152 RTC_DCHECK_RUN_ON(network_thread_); in set_incoming_only()
159 RTC_DCHECK_RUN_ON(network_thread_); in ports()
163 RTC_DCHECK_RUN_ON(network_thread_); in pruned_ports()
168 RTC_DCHECK_RUN_ON(network_thread_); in remote_ice_mode()
188 RTC_DCHECK_RUN_ON(network_thread_); in allocator_session()
197 RTC_DCHECK_RUN_ON(network_thread_); in remote_candidates()
202 RTC_DCHECK_RUN_ON(network_thread_); in ToString()
212 rtc::Thread* thread() const { return network_thread_; } in thread()
215 RTC_DCHECK_RUN_ON(network_thread_); in IsGettingPorts()
[all …]
Dp2p_transport_channel.cc144 network_thread_(rtc::Thread::Current()), in P2PTransportChannel()
170 regathering_config, this, network_thread_); in P2PTransportChannel()
203 RTC_DCHECK_RUN_ON(network_thread_); in ~P2PTransportChannel()
210 RTC_DCHECK_RUN_ON(network_thread_); in AddAllocatorSession()
236 RTC_DCHECK_RUN_ON(network_thread_); in AddConnection()
265 RTC_DCHECK_RUN_ON(network_thread_); in MaybeSwitchSelectedConnection()
274 RTC_DCHECK_RUN_ON(network_thread_); in MaybeSwitchSelectedConnection()
301 RTC_DCHECK_RUN_ON(network_thread_); in SetIceRole()
316 RTC_DCHECK_RUN_ON(network_thread_); in GetIceRole()
321 RTC_DCHECK_RUN_ON(network_thread_); in SetIceTiebreaker()
[all …]
Dfake_port_allocator.h90 network_thread_(network_thread), in FakePortAllocatorSession()
118 port_.reset(TestUDPPort::Create(network_thread_, factory_, &network, 0, 0, in StartGettingPorts()
193 rtc::Thread* network_thread_; variable
214 : network_thread_(network_thread), factory_(factory) { in FakePortAllocator()
216 owned_factory_.reset(new rtc::BasicPacketSocketFactory(network_thread_)); in FakePortAllocator()
220 if (network_thread_ == nullptr) { in FakePortAllocator()
221 network_thread_ = rtc::Thread::Current(); in FakePortAllocator()
225 network_thread_->Invoke<void>(RTC_FROM_HERE, in FakePortAllocator()
237 return new FakePortAllocatorSession(this, network_thread_, factory_, in CreateSessionInternal()
245 rtc::Thread* network_thread_;
/external/webrtc/test/peer_scenario/
Dscenario_connection.cc57 rtc::Thread* const network_thread_; member in webrtc::ScenarioIceConnectionImpl
59 RTC_GUARDED_BY(network_thread_);
63 RTC_GUARDED_BY(network_thread_);
65 RtpTransportInternal* rtp_transport_ RTC_GUARDED_BY(network_thread_) =
86 network_thread_(manager_->network_thread()),
101 network_thread_,
105 network_thread_->Invoke<void>(RTC_FROM_HERE, [this] { in __anon82eab2e20102()
106 RTC_DCHECK_RUN_ON(network_thread_); in __anon82eab2e20102()
118 network_thread_->Invoke<void>(RTC_FROM_HERE, [this] { in ~ScenarioIceConnectionImpl()
119 RTC_DCHECK_RUN_ON(network_thread_); in ~ScenarioIceConnectionImpl()
[all …]
/external/webrtc/test/network/
Demulated_network_manager.cc28 network_thread_(time_controller->CreateThread( in EmulatedNetworkManager()
37 network_thread_->PostTask(RTC_FROM_HERE, [this, endpoint]() { in EnableEndpoint()
46 network_thread_->PostTask(RTC_FROM_HERE, [this, endpoint]() { in DisableEndpoint()
55 RTC_DCHECK_RUN_ON(network_thread_.get()); in StartUpdating()
62 network_thread_->PostTask(RTC_FROM_HERE, in StartUpdating()
65 network_thread_->PostTask(RTC_FROM_HERE, in StartUpdating()
72 RTC_DCHECK_RUN_ON(network_thread_.get()); in StopUpdating()
90 RTC_DCHECK_RUN_ON(network_thread_.get()); in UpdateNetworksOnce()
108 RTC_DCHECK_RUN_ON(network_thread_.get()); in MaybeSignalNetworksChanged()
Demulated_network_manager.h50 rtc::Thread* network_thread() override { return network_thread_.get(); } in network_thread()
61 std::unique_ptr<rtc::Thread> network_thread_; variable
63 bool sent_first_update_ RTC_GUARDED_BY(network_thread_);
64 int start_count_ RTC_GUARDED_BY(network_thread_);
/external/webrtc/p2p/client/
Dbasic_port_allocator.cc265 network_thread_(rtc::Thread::Current()), in BasicPortAllocatorSession()
277 RTC_DCHECK_RUN_ON(network_thread_); in ~BasicPortAllocatorSession()
279 if (network_thread_ != NULL) in ~BasicPortAllocatorSession()
280 network_thread_->Clear(this); in ~BasicPortAllocatorSession()
300 RTC_DCHECK_RUN_ON(network_thread_); in allocator()
305 RTC_DCHECK_RUN_ON(network_thread_); in SetCandidateFilter()
365 RTC_DCHECK_RUN_ON(network_thread_); in StartGettingPorts()
369 new rtc::BasicPacketSocketFactory(network_thread_)); in StartGettingPorts()
373 network_thread_->Post(RTC_FROM_HERE, this, MSG_CONFIG_START); in StartGettingPorts()
380 RTC_DCHECK_RUN_ON(network_thread_); in StopGettingPorts()
[all …]
/external/webrtc/pc/
Djsep_transport_controller.cc83 network_thread_(network_thread), in JsepTransportController()
96 network_thread_->Invoke<void>( in ~JsepTransportController()
104 if (!network_thread_->IsCurrent()) { in SetLocalDescription()
105 return network_thread_->Invoke<RTCError>( in SetLocalDescription()
123 if (!network_thread_->IsCurrent()) { in SetRemoteDescription()
124 return network_thread_->Invoke<RTCError>( in SetRemoteDescription()
186 if (!network_thread_->IsCurrent()) { in SetIceConfig()
187 network_thread_->Invoke<void>(RTC_FROM_HERE, [&] { SetIceConfig(config); }); in SetIceConfig()
215 if (!network_thread_->IsCurrent()) { in GetDtlsRole()
216 return network_thread_->Invoke<absl::optional<rtc::SSLRole>>( in GetDtlsRole()
[all …]
Djsep_transport.h106 RTC_DCHECK_RUN_ON(network_thread_); in SetLocalCertificate()
112 RTC_DCHECK_RUN_ON(network_thread_); in GetLocalCertificate()
152 RTC_DCHECK_RUN_ON(network_thread_); in local_description()
157 RTC_DCHECK_RUN_ON(network_thread_); in remote_description()
316 const rtc::Thread* const network_thread_; variable
324 RTC_GUARDED_BY(network_thread_);
326 RTC_GUARDED_BY(network_thread_);
328 RTC_GUARDED_BY(network_thread_);
363 SrtpFilter sdes_negotiator_ RTC_GUARDED_BY(network_thread_);
364 RtcpMuxFilter rtcp_mux_negotiator_ RTC_GUARDED_BY(network_thread_);
[all …]
Dpeer_connection_factory.cc73 network_thread_(dependencies.network_thread), in PeerConnectionFactory()
88 if (!network_thread_) { in PeerConnectionFactory()
92 network_thread_ = owned_network_thread_.get(); in PeerConnectionFactory()
112 signaling_thread_->AllowInvokesToThread(network_thread_); in PeerConnectionFactory()
113 worker_thread_->AllowInvokesToThread(network_thread_); in PeerConnectionFactory()
114 network_thread_->DisallowAllInvokes(); in PeerConnectionFactory()
140 new rtc::BasicPacketSocketFactory(network_thread_)); in Initialize()
147 worker_thread_, network_thread_); in Initialize()
256 network_thread_); in CreatePeerConnection()
265 network_thread_->Invoke<void>(RTC_FROM_HERE, [this, &configuration, in CreatePeerConnection()
[all …]
Dchannel.cc134 network_thread_(network_thread), in BaseChannel()
200 network_thread_->Invoke<void>( in Init_w()
214 network_thread_->Invoke<void>(RTC_FROM_HERE, [&] { in Deinit()
221 network_thread_->Clear(&invoker_); in Deinit()
222 network_thread_->Clear(this); in Deinit()
231 if (!network_thread_->IsCurrent()) { in SetRtpTransport()
232 return network_thread_->Invoke<bool>(RTC_FROM_HERE, [this, rtp_transport] { in SetRtpTransport()
300 return network_thread_->Invoke<bool>( in IsReadyToSendMedia_w()
326 return network_thread_->Invoke<int>( in SetOption()
333 RTC_DCHECK(network_thread_->IsCurrent()); in SetOption_n()
[all …]
Dchannel_manager.cc36 network_thread_(network_thread) { in ChannelManager()
39 RTC_DCHECK(network_thread_); in ChannelManager()
126 RTC_DCHECK(network_thread_); in Init()
128 if (!network_thread_->IsCurrent()) { in Init()
130 network_thread_->Invoke<void>( in Init()
131 RTC_FROM_HERE, [&] { network_thread_->DisallowBlockingCalls(); }); in Init()
218 worker_thread_, network_thread_, signaling_thread, in CreateVoiceChannel()
289 worker_thread_, network_thread_, signaling_thread, in CreateVideoChannel()
350 worker_thread_, network_thread_, signaling_thread, in CreateRtpDataChannel()
Djsep_transport.cc84 : network_thread_(rtc::Thread::Current()), in JsepTransport()
159 RTC_DCHECK_RUN_ON(network_thread_); in SetLocalJsepTransportDescription()
252 RTC_DCHECK_RUN_ON(network_thread_); in SetRemoteJsepTransportDescription()
317 RTC_DCHECK_RUN_ON(network_thread_); in AddRemoteCandidates()
352 RTC_DCHECK_RUN_ON(network_thread_); in GetDtlsRole()
365 RTC_DCHECK_RUN_ON(network_thread_); in GetStats()
381 RTC_DCHECK_RUN_ON(network_thread_); in VerifyCertificateFingerprint()
407 RTC_DCHECK_RUN_ON(network_thread_); in SetActiveResetSrtpParams()
420 RTC_DCHECK_RUN_ON(network_thread_); in SetRemoteIceParameters()
452 RTC_DCHECK_RUN_ON(network_thread_); in SetRtcpMux()
[all …]
Dpeer_connection_adaptation_integrationtest.cc77 network_thread_(new rtc::Thread(&virtual_socket_server_)), in PeerConnectionAdaptationIntegrationTest()
79 RTC_CHECK(network_thread_->Start()); in PeerConnectionAdaptationIntegrationTest()
87 name, network_thread_.get(), worker_thread_.get()); in CreatePcWrapper()
97 std::unique_ptr<rtc::Thread> network_thread_; member in webrtc::PeerConnectionAdaptationIntegrationTest
Dpeer_connection_rampup_tests.cc151 network_thread_(new rtc::Thread(firewall_socket_server_.get())), in PeerConnectionRampUpTest()
153 network_thread_->SetName("PCNetworkThread", this); in PeerConnectionRampUpTest()
155 RTC_CHECK(network_thread_->Start()); in PeerConnectionRampUpTest()
160 network_thread_.get(), worker_thread_.get(), rtc::Thread::Current(), in PeerConnectionRampUpTest()
237 network_thread_->Invoke<std::unique_ptr<cricket::TestTurnServer>>( in CreateTurnServer()
272 rtc::Thread* network_thread() { return network_thread_.get(); } in network_thread()
326 std::unique_ptr<rtc::Thread> network_thread_; member in webrtc::PeerConnectionRampUpTest
Dchannel_manager.h62 rtc::Thread* network_thread() const { return network_thread_; } in network_thread()
67 network_thread_ = thread; in set_network_thread()
169 rtc::Thread* network_thread_; variable
Dpeer_connection_factory.h85 rtc::Thread* network_thread() { return network_thread_; } in network_thread()
108 rtc::Thread* network_thread_; variable
/external/webrtc/media/sctp/
Dsctp_transport.cc380 RTC_FROM_HERE, transport->network_thread_, in OnSctpOutboundPacket()
447 : network_thread_(network_thread), in SctpTransport()
450 RTC_DCHECK(network_thread_); in SctpTransport()
451 RTC_DCHECK_RUN_ON(network_thread_); in SctpTransport()
469 network_thread_ = nullptr; in ~SctpTransport()
474 RTC_DCHECK_RUN_ON(network_thread_); in SetDtlsTransport()
492 RTC_DCHECK_RUN_ON(network_thread_); in Start()
534 RTC_DCHECK_RUN_ON(network_thread_); in OpenStream()
566 RTC_DCHECK_RUN_ON(network_thread_); in ResetStream()
590 RTC_DCHECK_RUN_ON(network_thread_); in SendData()
[all …]
Dsctp_transport.h105 rtc::Thread* network_thread() const { return network_thread_; } in network_thread()
199 rtc::Thread* network_thread_; variable
289 : network_thread_(network_thread) {} in SctpTransportFactory()
294 new SctpTransport(network_thread_, transport)); in CreateSctpTransport()
298 rtc::Thread* network_thread_;
/external/webrtc/sdk/android/src/jni/pc/
Downed_factory_and_threads.h42 rtc::Thread* network_thread() { return network_thread_.get(); } in network_thread()
51 const std::unique_ptr<rtc::Thread> network_thread_;
/external/webrtc/pc/test/
Dfake_peer_connection_for_stats.h86 : network_thread_(rtc::Thread::Current()), in FakePeerConnectionForStats()
143 worker_thread_, network_thread_, signaling_thread_, in AddVoiceChannel()
161 worker_thread_, network_thread_, signaling_thread_, in AddVideoChannel()
250 rtc::Thread* network_thread() const override { return network_thread_; } in network_thread()
351 rtc::Thread* const network_thread_; variable
Dpeer_connection_test_wrapper.cc82 network_thread_(network_thread), in PeerConnectionTestWrapper()
104 new cricket::FakePortAllocator(network_thread_, nullptr)); in CreatePc()
114 network_thread_, worker_thread_, rtc::Thread::Current(), in CreatePc()
/external/webrtc/examples/androidnativeapi/jni/
Dandroid_call_client.cc141 network_thread_ = rtc::Thread::CreateWithSocketServer(); in CreatePeerConnectionFactory()
142 network_thread_->SetName("network_thread", nullptr); in CreatePeerConnectionFactory()
143 RTC_CHECK(network_thread_->Start()) << "Failed to start thread"; in CreatePeerConnectionFactory()
154 pcf_deps.network_thread = network_thread_.get(); in CreatePeerConnectionFactory()
/external/webrtc/video/
Drtp_video_stream_receiver_frame_transformer_delegate.cc77 network_thread_(network_thread), in RtpVideoStreamReceiverFrameTransformerDelegate()
105 network_thread_->PostTask(ToQueuedTask( in OnTransformedFrame()
/external/webrtc/examples/objcnativeapi/objc/
Dobjc_call_client.mm105 network_thread_ = rtc::Thread::CreateWithSocketServer();
106 network_thread_->SetName("network_thread", nullptr);
107 RTC_CHECK(network_thread_->Start()) << "Failed to start thread";
118 dependencies.network_thread = network_thread_.get();

12