| Index: webrtc/pc/channel_unittest.cc
|
| diff --git a/webrtc/pc/channel_unittest.cc b/webrtc/pc/channel_unittest.cc
|
| index 589ebd54d17342648a26f4b93187a0588643256d..1f93f682d6a89e0f8ff5343c172d3e735d782cfb 100644
|
| --- a/webrtc/pc/channel_unittest.cc
|
| +++ b/webrtc/pc/channel_unittest.cc
|
| @@ -20,8 +20,8 @@
|
| #include "webrtc/media/base/fakertp.h"
|
| #include "webrtc/media/base/mediachannel.h"
|
| #include "webrtc/media/base/testutils.h"
|
| +#include "webrtc/p2p/base/dtlstransportinternal.h"
|
| #include "webrtc/p2p/base/faketransportcontroller.h"
|
| -#include "webrtc/p2p/base/transportchannelimpl.h"
|
| #include "webrtc/pc/channel.h"
|
|
|
| #define MAYBE_SKIP_TEST(feature) \
|
| @@ -34,9 +34,9 @@ using cricket::CA_OFFER;
|
| using cricket::CA_PRANSWER;
|
| using cricket::CA_ANSWER;
|
| using cricket::CA_UPDATE;
|
| +using cricket::DtlsTransportInternal;
|
| using cricket::FakeVoiceMediaChannel;
|
| using cricket::StreamParams;
|
| -using cricket::TransportChannel;
|
|
|
| namespace {
|
| const cricket::AudioCodec kPcmuCodec(0, "PCMU", 64000, 8000, 1);
|
| @@ -271,21 +271,21 @@ class ChannelTest : public testing::Test, public sigslot::has_slots<> {
|
| return channel1_->RemoveRecvStream(id);
|
| }
|
|
|
| - std::vector<cricket::TransportChannelImpl*> GetChannels1() {
|
| + std::vector<cricket::DtlsTransportInternal*> GetChannels1() {
|
| return transport_controller1_->channels_for_testing();
|
| }
|
|
|
| - std::vector<cricket::TransportChannelImpl*> GetChannels2() {
|
| + std::vector<cricket::DtlsTransportInternal*> GetChannels2() {
|
| return transport_controller2_->channels_for_testing();
|
| }
|
|
|
| - cricket::FakeTransportChannel* GetFakeChannel1(int component) {
|
| - return transport_controller1_->GetFakeTransportChannel_n(
|
| + cricket::FakeDtlsTransport* GetFakeChannel1(int component) {
|
| + return transport_controller1_->GetFakeDtlsTransport_n(
|
| channel1_->content_name(), component);
|
| }
|
|
|
| - cricket::FakeTransportChannel* GetFakeChannel2(int component) {
|
| - return transport_controller2_->GetFakeTransportChannel_n(
|
| + cricket::FakeDtlsTransport* GetFakeChannel2(int component) {
|
| + return transport_controller2_->GetFakeDtlsTransport_n(
|
| channel2_->content_name(), component);
|
| }
|
|
|
| @@ -931,7 +931,7 @@ class ChannelTest : public testing::Test, public sigslot::has_slots<> {
|
|
|
| CreateChannels(0, 0);
|
|
|
| - cricket::TransportChannel* transport_channel1 =
|
| + cricket::DtlsTransportInternal* transport_channel1 =
|
| channel1_->transport_channel();
|
| ASSERT_TRUE(transport_channel1);
|
| typename T::MediaChannel* media_channel1 =
|
| @@ -941,8 +941,8 @@ class ChannelTest : public testing::Test, public sigslot::has_slots<> {
|
| media_channel1->set_num_network_route_changes(0);
|
| network_thread_->Invoke<void>(RTC_FROM_HERE, [transport_channel1] {
|
| // The transport channel becomes disconnected.
|
| - transport_channel1->SignalSelectedCandidatePairChanged(
|
| - transport_channel1, nullptr, -1, false);
|
| + transport_channel1->ice_transport()->SignalSelectedCandidatePairChanged(
|
| + transport_channel1->ice_transport(), nullptr, -1, false);
|
| });
|
| WaitForThreads();
|
| EXPECT_EQ(1, media_channel1->num_network_route_changes());
|
| @@ -958,8 +958,9 @@ class ChannelTest : public testing::Test, public sigslot::has_slots<> {
|
| std::unique_ptr<cricket::CandidatePairInterface> candidate_pair(
|
| transport_controller1_->CreateFakeCandidatePair(
|
| local_address, kLocalNetId, remote_address, kRemoteNetId));
|
| - transport_channel1->SignalSelectedCandidatePairChanged(
|
| - transport_channel1, candidate_pair.get(), kLastPacketId, true);
|
| + transport_channel1->ice_transport()->SignalSelectedCandidatePairChanged(
|
| + transport_channel1->ice_transport(), candidate_pair.get(),
|
| + kLastPacketId, true);
|
| });
|
| WaitForThreads();
|
| EXPECT_EQ(1, media_channel1->num_network_route_changes());
|
| @@ -1495,6 +1496,7 @@ class ChannelTest : public testing::Test, public sigslot::has_slots<> {
|
| WaitForThreads();
|
| EXPECT_TRUE(CheckRtp1());
|
| EXPECT_TRUE(CheckNoRtp2());
|
| + EXPECT_TRUE(CheckNoRtp1());
|
|
|
| // Gain writability back
|
| network_thread_->Invoke<void>(RTC_FROM_HERE, [this] {
|
| @@ -1804,7 +1806,7 @@ class ChannelTest : public testing::Test, public sigslot::has_slots<> {
|
| error_handler.mode_ = cricket::SrtpFilter::UNPROTECT;
|
|
|
| network_thread_->Invoke<void>(RTC_FROM_HERE, [this] {
|
| - cricket::TransportChannel* transport_channel =
|
| + cricket::DtlsTransportInternal* transport_channel =
|
| channel2_->transport_channel();
|
| transport_channel->SignalReadPacket(
|
| transport_channel, reinterpret_cast<const char*>(kBadPacket),
|
| @@ -1818,8 +1820,8 @@ class ChannelTest : public testing::Test, public sigslot::has_slots<> {
|
|
|
| void TestOnReadyToSend() {
|
| CreateChannels(RTCP, RTCP);
|
| - TransportChannel* rtp = channel1_->transport_channel();
|
| - TransportChannel* rtcp = channel1_->rtcp_transport_channel();
|
| + DtlsTransportInternal* rtp = channel1_->transport_channel();
|
| + DtlsTransportInternal* rtcp = channel1_->rtcp_transport_channel();
|
| EXPECT_FALSE(media_channel1_->ready_to_send());
|
|
|
| network_thread_->Invoke<void>(RTC_FROM_HERE,
|
| @@ -1870,7 +1872,7 @@ class ChannelTest : public testing::Test, public sigslot::has_slots<> {
|
| EXPECT_TRUE(channel1_->SetLocalContent(&content, CA_OFFER, NULL));
|
| EXPECT_TRUE(channel1_->SetRemoteContent(&content, CA_ANSWER, NULL));
|
| EXPECT_TRUE(channel1_->rtcp_transport_channel() == NULL);
|
| - TransportChannel* rtp = channel1_->transport_channel();
|
| + DtlsTransportInternal* rtp = channel1_->transport_channel();
|
| EXPECT_FALSE(media_channel1_->ready_to_send());
|
| // In the case of rtcp mux, the SignalReadyToSend() from rtp channel
|
| // should trigger the MediaChannel's OnReadyToSend.
|
|
|