| Index: webrtc/api/quicdatatransport.cc
|
| diff --git a/webrtc/api/quicdatatransport.cc b/webrtc/api/quicdatatransport.cc
|
| index ff3ac09335320082edeb832ec579e893c254f7b9..c1caf54067ebbfeb6e084b23e69ca679aa5a7cba 100644
|
| --- a/webrtc/api/quicdatatransport.cc
|
| +++ b/webrtc/api/quicdatatransport.cc
|
| @@ -10,48 +10,24 @@
|
|
|
| #include "webrtc/api/quicdatatransport.h"
|
|
|
| -#include "webrtc/base/bind.h"
|
| #include "webrtc/base/logging.h"
|
| #include "webrtc/p2p/quic/quictransportchannel.h"
|
| #include "webrtc/p2p/quic/reliablequicstream.h"
|
|
|
| namespace webrtc {
|
|
|
| -QuicDataTransport::QuicDataTransport(
|
| - rtc::Thread* signaling_thread,
|
| - rtc::Thread* worker_thread,
|
| - rtc::Thread* network_thread,
|
| - cricket::TransportController* transport_controller)
|
| +QuicDataTransport::QuicDataTransport(rtc::Thread* signaling_thread,
|
| + rtc::Thread* worker_thread,
|
| + rtc::Thread* network_thread)
|
| : signaling_thread_(signaling_thread),
|
| worker_thread_(worker_thread),
|
| - network_thread_(network_thread),
|
| - transport_controller_(transport_controller) {
|
| + network_thread_(network_thread) {
|
| RTC_DCHECK(signaling_thread_);
|
| RTC_DCHECK(worker_thread_);
|
| RTC_DCHECK(network_thread_);
|
| }
|
|
|
| -QuicDataTransport::~QuicDataTransport() {
|
| - DestroyTransportChannel(quic_transport_channel_);
|
| - LOG(LS_INFO) << "Destroyed the QUIC data transport.";
|
| -}
|
| -
|
| -bool QuicDataTransport::SetTransport(const std::string& transport_name) {
|
| - if (transport_name_ == transport_name) {
|
| - // Nothing to do if transport name isn't changing
|
| - return true;
|
| - }
|
| -
|
| - cricket::QuicTransportChannel* transport_channel =
|
| - CreateTransportChannel(transport_name);
|
| - if (!SetTransportChannel(transport_channel)) {
|
| - DestroyTransportChannel(transport_channel);
|
| - return false;
|
| - }
|
| -
|
| - transport_name_ = transport_name;
|
| - return true;
|
| -}
|
| +QuicDataTransport::~QuicDataTransport() {}
|
|
|
| bool QuicDataTransport::SetTransportChannel(
|
| cricket::QuicTransportChannel* channel) {
|
| @@ -72,6 +48,7 @@
|
| quic_transport_channel_ = channel;
|
| quic_transport_channel_->SignalIncomingStream.connect(
|
| this, &QuicDataTransport::OnIncomingStream);
|
| +
|
| bool success = true;
|
| for (const auto& kv : data_channel_by_id_) {
|
| rtc::scoped_refptr<QuicDataChannel> data_channel = kv.second;
|
| @@ -170,28 +147,4 @@
|
| data_channel->OnIncomingMessage(std::move(message));
|
| }
|
|
|
| -cricket::QuicTransportChannel* QuicDataTransport::CreateTransportChannel(
|
| - const std::string& transport_name) {
|
| - DCHECK(transport_controller_->quic());
|
| -
|
| - cricket::TransportChannel* transport_channel =
|
| - network_thread_->Invoke<cricket::TransportChannel*>(
|
| - RTC_FROM_HERE,
|
| - rtc::Bind(&cricket::TransportController::CreateTransportChannel_n,
|
| - transport_controller_, transport_name,
|
| - cricket::ICE_CANDIDATE_COMPONENT_DEFAULT));
|
| - return static_cast<cricket::QuicTransportChannel*>(transport_channel);
|
| -}
|
| -
|
| -void QuicDataTransport::DestroyTransportChannel(
|
| - cricket::TransportChannel* transport_channel) {
|
| - if (transport_channel) {
|
| - network_thread_->Invoke<void>(
|
| - RTC_FROM_HERE,
|
| - rtc::Bind(&cricket::TransportController::DestroyTransportChannel_n,
|
| - transport_controller_, transport_channel->transport_name(),
|
| - cricket::ICE_CANDIDATE_COMPONENT_DEFAULT));
|
| - }
|
| -}
|
| -
|
| } // namespace webrtc
|
|
|