Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(2005)

Side by Side Diff: webrtc/api/rtcstatscollector_unittest.cc

Issue 2614263002: Remove BaseChannel's dependency on TransportController. (Closed)
Patch Set: cr comments Created 3 years, 11 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
« no previous file with comments | « no previous file | webrtc/api/rtpsenderreceiver_unittest.cc » ('j') | webrtc/api/webrtcsession.cc » ('J')
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
1 /* 1 /*
2 * Copyright 2016 The WebRTC project authors. All Rights Reserved. 2 * Copyright 2016 The WebRTC project authors. All Rights Reserved.
3 * 3 *
4 * Use of this source code is governed by a BSD-style license 4 * Use of this source code is governed by a BSD-style license
5 * that can be found in the LICENSE file in the root of the source 5 * that can be found in the LICENSE file in the root of the source
6 * tree. An additional intellectual property rights grant can be found 6 * tree. An additional intellectual property rights grant can be found
7 * in the file PATENTS. All contributing project authors may 7 * in the file PATENTS. All contributing project authors may
8 * be found in the AUTHORS file in the root of the source tree. 8 * be found in the AUTHORS file in the root of the source tree.
9 */ 9 */
10 10
(...skipping 578 matching lines...) Expand 10 before | Expand all | Expand 10 after
589 })); 589 }));
590 590
591 rtc::scoped_refptr<const RTCStatsReport> report = GetStatsReport(); 591 rtc::scoped_refptr<const RTCStatsReport> report = GetStatsReport();
592 ExpectReportContainsCertificateInfo(report, *local_certinfo); 592 ExpectReportContainsCertificateInfo(report, *local_certinfo);
593 ExpectReportContainsCertificateInfo(report, *remote_certinfo); 593 ExpectReportContainsCertificateInfo(report, *remote_certinfo);
594 } 594 }
595 595
596 TEST_F(RTCStatsCollectorTest, CollectRTCCodecStats) { 596 TEST_F(RTCStatsCollectorTest, CollectRTCCodecStats) {
597 MockVoiceMediaChannel* voice_media_channel = new MockVoiceMediaChannel(); 597 MockVoiceMediaChannel* voice_media_channel = new MockVoiceMediaChannel();
598 cricket::VoiceChannel voice_channel( 598 cricket::VoiceChannel voice_channel(
599 test_->worker_thread(), test_->network_thread(), test_->media_engine(), 599 test_->worker_thread(), test_->network_thread(), nullptr,
pthatcher1 2017/01/13 21:51:07 I'd prefer we define a signaling thread for all of
Taylor Brandstetter 2017/01/13 23:46:47 Fixed in new CL
600 voice_media_channel, nullptr, "VoiceContentName", kDefaultRtcpEnabled, 600 test_->media_engine(), voice_media_channel, "VoiceContentName",
601 kDefaultSrtpRequired); 601 kDefaultRtcpEnabled, kDefaultSrtpRequired);
602 602
603 MockVideoMediaChannel* video_media_channel = new MockVideoMediaChannel(); 603 MockVideoMediaChannel* video_media_channel = new MockVideoMediaChannel();
604 cricket::VideoChannel video_channel( 604 cricket::VideoChannel video_channel(
605 test_->worker_thread(), test_->network_thread(), video_media_channel, 605 test_->worker_thread(), test_->network_thread(), nullptr,
606 nullptr, "VideoContentName", kDefaultRtcpEnabled, kDefaultSrtpRequired); 606 video_media_channel, "VideoContentName", kDefaultRtcpEnabled,
607 kDefaultSrtpRequired);
607 608
608 // Audio 609 // Audio
609 cricket::VoiceMediaInfo voice_media_info; 610 cricket::VoiceMediaInfo voice_media_info;
610 611
611 RtpCodecParameters inbound_audio_codec; 612 RtpCodecParameters inbound_audio_codec;
612 inbound_audio_codec.payload_type = 1; 613 inbound_audio_codec.payload_type = 1;
613 inbound_audio_codec.mime_type = "opus"; 614 inbound_audio_codec.mime_type = "opus";
614 inbound_audio_codec.clock_rate = 1337; 615 inbound_audio_codec.clock_rate = 1337;
615 voice_media_info.receive_codecs.insert( 616 voice_media_info.receive_codecs.insert(
616 std::make_pair(inbound_audio_codec.payload_type, inbound_audio_codec)); 617 std::make_pair(inbound_audio_codec.payload_type, inbound_audio_codec));
(...skipping 819 matching lines...) Expand 10 before | Expand all | Expand 10 after
1436 expected_remote_video_track.frame_height = 4321; 1437 expected_remote_video_track.frame_height = 4321;
1437 ASSERT_TRUE(report->Get(expected_remote_video_track.id())); 1438 ASSERT_TRUE(report->Get(expected_remote_video_track.id()));
1438 EXPECT_EQ(expected_remote_video_track, 1439 EXPECT_EQ(expected_remote_video_track,
1439 report->Get(expected_remote_video_track.id())->cast_to< 1440 report->Get(expected_remote_video_track.id())->cast_to<
1440 RTCMediaStreamTrackStats>()); 1441 RTCMediaStreamTrackStats>());
1441 } 1442 }
1442 1443
1443 TEST_F(RTCStatsCollectorTest, CollectRTCInboundRTPStreamStats_Audio) { 1444 TEST_F(RTCStatsCollectorTest, CollectRTCInboundRTPStreamStats_Audio) {
1444 MockVoiceMediaChannel* voice_media_channel = new MockVoiceMediaChannel(); 1445 MockVoiceMediaChannel* voice_media_channel = new MockVoiceMediaChannel();
1445 cricket::VoiceChannel voice_channel( 1446 cricket::VoiceChannel voice_channel(
1446 test_->worker_thread(), test_->network_thread(), test_->media_engine(), 1447 test_->worker_thread(), test_->network_thread(), nullptr,
1447 voice_media_channel, nullptr, "VoiceContentName", kDefaultRtcpEnabled, 1448 test_->media_engine(), voice_media_channel, "VoiceContentName",
1448 kDefaultSrtpRequired); 1449 kDefaultRtcpEnabled, kDefaultSrtpRequired);
1449 1450
1450 cricket::VoiceMediaInfo voice_media_info; 1451 cricket::VoiceMediaInfo voice_media_info;
1451 1452
1452 voice_media_info.receivers.push_back(cricket::VoiceReceiverInfo()); 1453 voice_media_info.receivers.push_back(cricket::VoiceReceiverInfo());
1453 voice_media_info.receivers[0].local_stats.push_back( 1454 voice_media_info.receivers[0].local_stats.push_back(
1454 cricket::SsrcReceiverInfo()); 1455 cricket::SsrcReceiverInfo());
1455 voice_media_info.receivers[0].local_stats[0].ssrc = 1; 1456 voice_media_info.receivers[0].local_stats[0].ssrc = 1;
1456 voice_media_info.receivers[0].packets_lost = 42; 1457 voice_media_info.receivers[0].packets_lost = 42;
1457 voice_media_info.receivers[0].packets_rcvd = 2; 1458 voice_media_info.receivers[0].packets_rcvd = 2;
1458 voice_media_info.receivers[0].bytes_rcvd = 3; 1459 voice_media_info.receivers[0].bytes_rcvd = 3;
(...skipping 50 matching lines...) Expand 10 before | Expand all | Expand 10 after
1509 expected_audio.id())->cast_to<RTCInboundRTPStreamStats>(); 1510 expected_audio.id())->cast_to<RTCInboundRTPStreamStats>();
1510 EXPECT_EQ(audio, expected_audio); 1511 EXPECT_EQ(audio, expected_audio);
1511 1512
1512 ASSERT_TRUE(report->Get(*expected_audio.transport_id)); 1513 ASSERT_TRUE(report->Get(*expected_audio.transport_id));
1513 ASSERT_TRUE(report->Get(*expected_audio.codec_id)); 1514 ASSERT_TRUE(report->Get(*expected_audio.codec_id));
1514 } 1515 }
1515 1516
1516 TEST_F(RTCStatsCollectorTest, CollectRTCInboundRTPStreamStats_Video) { 1517 TEST_F(RTCStatsCollectorTest, CollectRTCInboundRTPStreamStats_Video) {
1517 MockVideoMediaChannel* video_media_channel = new MockVideoMediaChannel(); 1518 MockVideoMediaChannel* video_media_channel = new MockVideoMediaChannel();
1518 cricket::VideoChannel video_channel( 1519 cricket::VideoChannel video_channel(
1519 test_->worker_thread(), test_->network_thread(), video_media_channel, 1520 test_->worker_thread(), test_->network_thread(), nullptr,
1520 nullptr, "VideoContentName", kDefaultRtcpEnabled, kDefaultSrtpRequired); 1521 video_media_channel, "VideoContentName", kDefaultRtcpEnabled,
1522 kDefaultSrtpRequired);
1521 1523
1522 cricket::VideoMediaInfo video_media_info; 1524 cricket::VideoMediaInfo video_media_info;
1523 1525
1524 video_media_info.receivers.push_back(cricket::VideoReceiverInfo()); 1526 video_media_info.receivers.push_back(cricket::VideoReceiverInfo());
1525 video_media_info.receivers[0].local_stats.push_back( 1527 video_media_info.receivers[0].local_stats.push_back(
1526 cricket::SsrcReceiverInfo()); 1528 cricket::SsrcReceiverInfo());
1527 video_media_info.receivers[0].local_stats[0].ssrc = 1; 1529 video_media_info.receivers[0].local_stats[0].ssrc = 1;
1528 video_media_info.receivers[0].packets_rcvd = 2; 1530 video_media_info.receivers[0].packets_rcvd = 2;
1529 video_media_info.receivers[0].packets_lost = 42; 1531 video_media_info.receivers[0].packets_lost = 42;
1530 video_media_info.receivers[0].bytes_rcvd = 3; 1532 video_media_info.receivers[0].bytes_rcvd = 3;
(...skipping 56 matching lines...) Expand 10 before | Expand all | Expand 10 after
1587 expected_video.id())->cast_to<RTCInboundRTPStreamStats>(); 1589 expected_video.id())->cast_to<RTCInboundRTPStreamStats>();
1588 EXPECT_EQ(video, expected_video); 1590 EXPECT_EQ(video, expected_video);
1589 1591
1590 ASSERT_TRUE(report->Get(*expected_video.transport_id)); 1592 ASSERT_TRUE(report->Get(*expected_video.transport_id));
1591 ASSERT_TRUE(report->Get(*video.codec_id)); 1593 ASSERT_TRUE(report->Get(*video.codec_id));
1592 } 1594 }
1593 1595
1594 TEST_F(RTCStatsCollectorTest, CollectRTCOutboundRTPStreamStats_Audio) { 1596 TEST_F(RTCStatsCollectorTest, CollectRTCOutboundRTPStreamStats_Audio) {
1595 MockVoiceMediaChannel* voice_media_channel = new MockVoiceMediaChannel(); 1597 MockVoiceMediaChannel* voice_media_channel = new MockVoiceMediaChannel();
1596 cricket::VoiceChannel voice_channel( 1598 cricket::VoiceChannel voice_channel(
1597 test_->worker_thread(), test_->network_thread(), test_->media_engine(), 1599 test_->worker_thread(), test_->network_thread(), nullptr,
1598 voice_media_channel, nullptr, "VoiceContentName", kDefaultRtcpEnabled, 1600 test_->media_engine(), voice_media_channel, "VoiceContentName",
1599 kDefaultSrtpRequired); 1601 kDefaultRtcpEnabled, kDefaultSrtpRequired);
1600 1602
1601 cricket::VoiceMediaInfo voice_media_info; 1603 cricket::VoiceMediaInfo voice_media_info;
1602 1604
1603 voice_media_info.senders.push_back(cricket::VoiceSenderInfo()); 1605 voice_media_info.senders.push_back(cricket::VoiceSenderInfo());
1604 voice_media_info.senders[0].local_stats.push_back(cricket::SsrcSenderInfo()); 1606 voice_media_info.senders[0].local_stats.push_back(cricket::SsrcSenderInfo());
1605 voice_media_info.senders[0].local_stats[0].ssrc = 1; 1607 voice_media_info.senders[0].local_stats[0].ssrc = 1;
1606 voice_media_info.senders[0].packets_sent = 2; 1608 voice_media_info.senders[0].packets_sent = 2;
1607 voice_media_info.senders[0].bytes_sent = 3; 1609 voice_media_info.senders[0].bytes_sent = 3;
1608 voice_media_info.senders[0].rtt_ms = 4500; 1610 voice_media_info.senders[0].rtt_ms = 4500;
1609 voice_media_info.senders[0].codec_payload_type = rtc::Optional<int>(42); 1611 voice_media_info.senders[0].codec_payload_type = rtc::Optional<int>(42);
(...skipping 45 matching lines...) Expand 10 before | Expand all | Expand 10 after
1655 expected_audio.id())->cast_to<RTCOutboundRTPStreamStats>(); 1657 expected_audio.id())->cast_to<RTCOutboundRTPStreamStats>();
1656 EXPECT_EQ(audio, expected_audio); 1658 EXPECT_EQ(audio, expected_audio);
1657 1659
1658 ASSERT_TRUE(report->Get(*expected_audio.transport_id)); 1660 ASSERT_TRUE(report->Get(*expected_audio.transport_id));
1659 ASSERT_TRUE(report->Get(*expected_audio.codec_id)); 1661 ASSERT_TRUE(report->Get(*expected_audio.codec_id));
1660 } 1662 }
1661 1663
1662 TEST_F(RTCStatsCollectorTest, CollectRTCOutboundRTPStreamStats_Video) { 1664 TEST_F(RTCStatsCollectorTest, CollectRTCOutboundRTPStreamStats_Video) {
1663 MockVideoMediaChannel* video_media_channel = new MockVideoMediaChannel(); 1665 MockVideoMediaChannel* video_media_channel = new MockVideoMediaChannel();
1664 cricket::VideoChannel video_channel( 1666 cricket::VideoChannel video_channel(
1665 test_->worker_thread(), test_->network_thread(), video_media_channel, 1667 test_->worker_thread(), test_->network_thread(), nullptr,
1666 nullptr, "VideoContentName", kDefaultRtcpEnabled, kDefaultSrtpRequired); 1668 video_media_channel, "VideoContentName", kDefaultRtcpEnabled,
1669 kDefaultSrtpRequired);
1667 1670
1668 cricket::VideoMediaInfo video_media_info; 1671 cricket::VideoMediaInfo video_media_info;
1669 1672
1670 video_media_info.senders.push_back(cricket::VideoSenderInfo()); 1673 video_media_info.senders.push_back(cricket::VideoSenderInfo());
1671 video_media_info.senders[0].local_stats.push_back(cricket::SsrcSenderInfo()); 1674 video_media_info.senders[0].local_stats.push_back(cricket::SsrcSenderInfo());
1672 video_media_info.senders[0].local_stats[0].ssrc = 1; 1675 video_media_info.senders[0].local_stats[0].ssrc = 1;
1673 video_media_info.senders[0].firs_rcvd = 2; 1676 video_media_info.senders[0].firs_rcvd = 2;
1674 video_media_info.senders[0].plis_rcvd = 3; 1677 video_media_info.senders[0].plis_rcvd = 3;
1675 video_media_info.senders[0].nacks_rcvd = 4; 1678 video_media_info.senders[0].nacks_rcvd = 4;
1676 video_media_info.senders[0].packets_sent = 5; 1679 video_media_info.senders[0].packets_sent = 5;
(...skipping 55 matching lines...) Expand 10 before | Expand all | Expand 10 after
1732 expected_video.id())->cast_to<RTCOutboundRTPStreamStats>(); 1735 expected_video.id())->cast_to<RTCOutboundRTPStreamStats>();
1733 EXPECT_EQ(video, expected_video); 1736 EXPECT_EQ(video, expected_video);
1734 1737
1735 ASSERT_TRUE(report->Get(*expected_video.transport_id)); 1738 ASSERT_TRUE(report->Get(*expected_video.transport_id));
1736 ASSERT_TRUE(report->Get(*expected_video.codec_id)); 1739 ASSERT_TRUE(report->Get(*expected_video.codec_id));
1737 } 1740 }
1738 1741
1739 TEST_F(RTCStatsCollectorTest, CollectRTCOutboundRTPStreamStats_Default) { 1742 TEST_F(RTCStatsCollectorTest, CollectRTCOutboundRTPStreamStats_Default) {
1740 MockVoiceMediaChannel* voice_media_channel = new MockVoiceMediaChannel(); 1743 MockVoiceMediaChannel* voice_media_channel = new MockVoiceMediaChannel();
1741 cricket::VoiceChannel voice_channel( 1744 cricket::VoiceChannel voice_channel(
1742 test_->worker_thread(), test_->network_thread(), test_->media_engine(), 1745 test_->worker_thread(), test_->network_thread(), nullptr,
1743 voice_media_channel, nullptr, "VoiceContentName", kDefaultRtcpEnabled, 1746 test_->media_engine(), voice_media_channel, "VoiceContentName",
1744 kDefaultSrtpRequired); 1747 kDefaultRtcpEnabled, kDefaultSrtpRequired);
1745 MockVideoMediaChannel* video_media_channel = new MockVideoMediaChannel(); 1748 MockVideoMediaChannel* video_media_channel = new MockVideoMediaChannel();
1746 cricket::VideoChannel video_channel( 1749 cricket::VideoChannel video_channel(
1747 test_->worker_thread(), test_->network_thread(), video_media_channel, 1750 test_->worker_thread(), test_->network_thread(), nullptr,
1748 nullptr, "VideoContentName", kDefaultRtcpEnabled, kDefaultSrtpRequired); 1751 video_media_channel, "VideoContentName", kDefaultRtcpEnabled,
1752 kDefaultSrtpRequired);
1749 1753
1750 cricket::VoiceMediaInfo voice_media_info; 1754 cricket::VoiceMediaInfo voice_media_info;
1751 voice_media_info.senders.push_back(cricket::VoiceSenderInfo()); 1755 voice_media_info.senders.push_back(cricket::VoiceSenderInfo());
1752 voice_media_info.senders[0].local_stats.push_back(cricket::SsrcSenderInfo()); 1756 voice_media_info.senders[0].local_stats.push_back(cricket::SsrcSenderInfo());
1753 voice_media_info.senders[0].local_stats[0].ssrc = 1; 1757 voice_media_info.senders[0].local_stats[0].ssrc = 1;
1754 voice_media_info.senders[0].packets_sent = 2; 1758 voice_media_info.senders[0].packets_sent = 2;
1755 voice_media_info.senders[0].bytes_sent = 3; 1759 voice_media_info.senders[0].bytes_sent = 3;
1756 voice_media_info.senders[0].rtt_ms = -1; 1760 voice_media_info.senders[0].rtt_ms = -1;
1757 voice_media_info.senders[0].codec_payload_type = rtc::Optional<int>(42); 1761 voice_media_info.senders[0].codec_payload_type = rtc::Optional<int>(42);
1758 1762
(...skipping 248 matching lines...) Expand 10 before | Expand all | Expand 10 after
2007 rtc::scoped_refptr<FakeRTCStatsCollector> collector_; 2011 rtc::scoped_refptr<FakeRTCStatsCollector> collector_;
2008 }; 2012 };
2009 2013
2010 TEST_F(RTCStatsCollectorTestWithFakeCollector, ThreadUsageAndResultsMerging) { 2014 TEST_F(RTCStatsCollectorTestWithFakeCollector, ThreadUsageAndResultsMerging) {
2011 collector_->VerifyThreadUsageAndResultsMerging(); 2015 collector_->VerifyThreadUsageAndResultsMerging();
2012 } 2016 }
2013 2017
2014 } // namespace 2018 } // namespace
2015 2019
2016 } // namespace webrtc 2020 } // namespace webrtc
OLDNEW
« no previous file with comments | « no previous file | webrtc/api/rtpsenderreceiver_unittest.cc » ('j') | webrtc/api/webrtcsession.cc » ('J')

Powered by Google App Engine
This is Rietveld 408576698