OLD | NEW |
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 1702 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1713 EXPECT_CALL(test_->session(), voice_channel()) | 1713 EXPECT_CALL(test_->session(), voice_channel()) |
1714 .WillRepeatedly(Return(&voice_channel)); | 1714 .WillRepeatedly(Return(&voice_channel)); |
1715 | 1715 |
1716 rtc::scoped_refptr<const RTCStatsReport> report = GetStatsReport(); | 1716 rtc::scoped_refptr<const RTCStatsReport> report = GetStatsReport(); |
1717 | 1717 |
1718 RTCInboundRTPStreamStats expected_audio( | 1718 RTCInboundRTPStreamStats expected_audio( |
1719 "RTCInboundRTPAudioStream_1", report->timestamp_us()); | 1719 "RTCInboundRTPAudioStream_1", report->timestamp_us()); |
1720 expected_audio.ssrc = "1"; | 1720 expected_audio.ssrc = "1"; |
1721 expected_audio.is_remote = false; | 1721 expected_audio.is_remote = false; |
1722 expected_audio.media_type = "audio"; | 1722 expected_audio.media_type = "audio"; |
1723 expected_audio.media_track_id = | 1723 expected_audio.track_id = |
1724 "RTCMediaStreamTrack_remote_audio_RemoteAudioTrackID_1"; | 1724 "RTCMediaStreamTrack_remote_audio_RemoteAudioTrackID_1"; |
1725 expected_audio.transport_id = "RTCTransport_TransportName_" + | 1725 expected_audio.transport_id = "RTCTransport_TransportName_" + |
1726 rtc::ToString<>(cricket::ICE_CANDIDATE_COMPONENT_RTP); | 1726 rtc::ToString<>(cricket::ICE_CANDIDATE_COMPONENT_RTP); |
1727 expected_audio.codec_id = "RTCCodec_InboundAudio_42"; | 1727 expected_audio.codec_id = "RTCCodec_InboundAudio_42"; |
1728 expected_audio.packets_received = 2; | 1728 expected_audio.packets_received = 2; |
1729 expected_audio.bytes_received = 3; | 1729 expected_audio.bytes_received = 3; |
1730 expected_audio.packets_lost = 42; | 1730 expected_audio.packets_lost = 42; |
1731 expected_audio.jitter = 4.5; | 1731 expected_audio.jitter = 4.5; |
1732 expected_audio.fraction_lost = 5.5; | 1732 expected_audio.fraction_lost = 5.5; |
1733 | 1733 |
1734 ASSERT_TRUE(report->Get(expected_audio.id())); | 1734 ASSERT_TRUE(report->Get(expected_audio.id())); |
1735 const RTCInboundRTPStreamStats& audio = report->Get( | 1735 const RTCInboundRTPStreamStats& audio = report->Get( |
1736 expected_audio.id())->cast_to<RTCInboundRTPStreamStats>(); | 1736 expected_audio.id())->cast_to<RTCInboundRTPStreamStats>(); |
1737 EXPECT_EQ(audio, expected_audio); | 1737 EXPECT_EQ(audio, expected_audio); |
1738 | 1738 |
1739 EXPECT_TRUE(report->Get(*expected_audio.media_track_id)); | 1739 EXPECT_TRUE(report->Get(*expected_audio.track_id)); |
1740 EXPECT_TRUE(report->Get(*expected_audio.transport_id)); | 1740 EXPECT_TRUE(report->Get(*expected_audio.transport_id)); |
1741 EXPECT_TRUE(report->Get(*expected_audio.codec_id)); | 1741 EXPECT_TRUE(report->Get(*expected_audio.codec_id)); |
1742 } | 1742 } |
1743 | 1743 |
1744 TEST_F(RTCStatsCollectorTest, CollectRTCInboundRTPStreamStats_Video) { | 1744 TEST_F(RTCStatsCollectorTest, CollectRTCInboundRTPStreamStats_Video) { |
1745 MockVideoMediaChannel* video_media_channel = new MockVideoMediaChannel(); | 1745 MockVideoMediaChannel* video_media_channel = new MockVideoMediaChannel(); |
1746 cricket::VideoChannel video_channel( | 1746 cricket::VideoChannel video_channel( |
1747 test_->worker_thread(), test_->network_thread(), | 1747 test_->worker_thread(), test_->network_thread(), |
1748 test_->signaling_thread(), video_media_channel, "VideoContentName", | 1748 test_->signaling_thread(), video_media_channel, "VideoContentName", |
1749 kDefaultRtcpMuxRequired, kDefaultSrtpRequired); | 1749 kDefaultRtcpMuxRequired, kDefaultSrtpRequired); |
(...skipping 45 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1795 EXPECT_CALL(test_->session(), video_channel()) | 1795 EXPECT_CALL(test_->session(), video_channel()) |
1796 .WillRepeatedly(Return(&video_channel)); | 1796 .WillRepeatedly(Return(&video_channel)); |
1797 | 1797 |
1798 rtc::scoped_refptr<const RTCStatsReport> report = GetStatsReport(); | 1798 rtc::scoped_refptr<const RTCStatsReport> report = GetStatsReport(); |
1799 | 1799 |
1800 RTCInboundRTPStreamStats expected_video( | 1800 RTCInboundRTPStreamStats expected_video( |
1801 "RTCInboundRTPVideoStream_1", report->timestamp_us()); | 1801 "RTCInboundRTPVideoStream_1", report->timestamp_us()); |
1802 expected_video.ssrc = "1"; | 1802 expected_video.ssrc = "1"; |
1803 expected_video.is_remote = false; | 1803 expected_video.is_remote = false; |
1804 expected_video.media_type = "video"; | 1804 expected_video.media_type = "video"; |
1805 expected_video.media_track_id = | 1805 expected_video.track_id = |
1806 "RTCMediaStreamTrack_remote_video_RemoteVideoTrackID_1"; | 1806 "RTCMediaStreamTrack_remote_video_RemoteVideoTrackID_1"; |
1807 expected_video.transport_id = "RTCTransport_TransportName_" + | 1807 expected_video.transport_id = "RTCTransport_TransportName_" + |
1808 rtc::ToString<>(cricket::ICE_CANDIDATE_COMPONENT_RTP); | 1808 rtc::ToString<>(cricket::ICE_CANDIDATE_COMPONENT_RTP); |
1809 expected_video.codec_id = "RTCCodec_InboundVideo_42"; | 1809 expected_video.codec_id = "RTCCodec_InboundVideo_42"; |
1810 expected_video.fir_count = 5; | 1810 expected_video.fir_count = 5; |
1811 expected_video.pli_count = 6; | 1811 expected_video.pli_count = 6; |
1812 expected_video.nack_count = 7; | 1812 expected_video.nack_count = 7; |
1813 expected_video.packets_received = 2; | 1813 expected_video.packets_received = 2; |
1814 expected_video.bytes_received = 3; | 1814 expected_video.bytes_received = 3; |
1815 expected_video.packets_lost = 42; | 1815 expected_video.packets_lost = 42; |
1816 expected_video.fraction_lost = 4.5; | 1816 expected_video.fraction_lost = 4.5; |
1817 expected_video.frames_decoded = 8; | 1817 expected_video.frames_decoded = 8; |
1818 | 1818 |
1819 ASSERT_TRUE(report->Get(expected_video.id())); | 1819 ASSERT_TRUE(report->Get(expected_video.id())); |
1820 const RTCInboundRTPStreamStats& video = report->Get( | 1820 const RTCInboundRTPStreamStats& video = report->Get( |
1821 expected_video.id())->cast_to<RTCInboundRTPStreamStats>(); | 1821 expected_video.id())->cast_to<RTCInboundRTPStreamStats>(); |
1822 EXPECT_EQ(video, expected_video); | 1822 EXPECT_EQ(video, expected_video); |
1823 | 1823 |
1824 EXPECT_TRUE(report->Get(*expected_video.media_track_id)); | 1824 EXPECT_TRUE(report->Get(*expected_video.track_id)); |
1825 EXPECT_TRUE(report->Get(*expected_video.transport_id)); | 1825 EXPECT_TRUE(report->Get(*expected_video.transport_id)); |
1826 EXPECT_TRUE(report->Get(*video.codec_id)); | 1826 EXPECT_TRUE(report->Get(*video.codec_id)); |
1827 } | 1827 } |
1828 | 1828 |
1829 TEST_F(RTCStatsCollectorTest, CollectRTCOutboundRTPStreamStats_Audio) { | 1829 TEST_F(RTCStatsCollectorTest, CollectRTCOutboundRTPStreamStats_Audio) { |
1830 MockVoiceMediaChannel* voice_media_channel = new MockVoiceMediaChannel(); | 1830 MockVoiceMediaChannel* voice_media_channel = new MockVoiceMediaChannel(); |
1831 cricket::VoiceChannel voice_channel( | 1831 cricket::VoiceChannel voice_channel( |
1832 test_->worker_thread(), test_->network_thread(), | 1832 test_->worker_thread(), test_->network_thread(), |
1833 test_->signaling_thread(), test_->media_engine(), voice_media_channel, | 1833 test_->signaling_thread(), test_->media_engine(), voice_media_channel, |
1834 "VoiceContentName", kDefaultRtcpMuxRequired, kDefaultSrtpRequired); | 1834 "VoiceContentName", kDefaultRtcpMuxRequired, kDefaultSrtpRequired); |
(...skipping 39 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1874 EXPECT_CALL(test_->session(), voice_channel()) | 1874 EXPECT_CALL(test_->session(), voice_channel()) |
1875 .WillRepeatedly(Return(&voice_channel)); | 1875 .WillRepeatedly(Return(&voice_channel)); |
1876 | 1876 |
1877 rtc::scoped_refptr<const RTCStatsReport> report = GetStatsReport(); | 1877 rtc::scoped_refptr<const RTCStatsReport> report = GetStatsReport(); |
1878 | 1878 |
1879 RTCOutboundRTPStreamStats expected_audio( | 1879 RTCOutboundRTPStreamStats expected_audio( |
1880 "RTCOutboundRTPAudioStream_1", report->timestamp_us()); | 1880 "RTCOutboundRTPAudioStream_1", report->timestamp_us()); |
1881 expected_audio.ssrc = "1"; | 1881 expected_audio.ssrc = "1"; |
1882 expected_audio.is_remote = false; | 1882 expected_audio.is_remote = false; |
1883 expected_audio.media_type = "audio"; | 1883 expected_audio.media_type = "audio"; |
1884 expected_audio.media_track_id = | 1884 expected_audio.track_id = |
1885 "RTCMediaStreamTrack_local_audio_LocalAudioTrackID_1"; | 1885 "RTCMediaStreamTrack_local_audio_LocalAudioTrackID_1"; |
1886 expected_audio.transport_id = "RTCTransport_TransportName_" + | 1886 expected_audio.transport_id = "RTCTransport_TransportName_" + |
1887 rtc::ToString<>(cricket::ICE_CANDIDATE_COMPONENT_RTP); | 1887 rtc::ToString<>(cricket::ICE_CANDIDATE_COMPONENT_RTP); |
1888 expected_audio.codec_id = "RTCCodec_OutboundAudio_42"; | 1888 expected_audio.codec_id = "RTCCodec_OutboundAudio_42"; |
1889 expected_audio.packets_sent = 2; | 1889 expected_audio.packets_sent = 2; |
1890 expected_audio.bytes_sent = 3; | 1890 expected_audio.bytes_sent = 3; |
1891 expected_audio.round_trip_time = 4.5; | 1891 expected_audio.round_trip_time = 4.5; |
1892 | 1892 |
1893 ASSERT_TRUE(report->Get(expected_audio.id())); | 1893 ASSERT_TRUE(report->Get(expected_audio.id())); |
1894 const RTCOutboundRTPStreamStats& audio = report->Get( | 1894 const RTCOutboundRTPStreamStats& audio = report->Get( |
1895 expected_audio.id())->cast_to<RTCOutboundRTPStreamStats>(); | 1895 expected_audio.id())->cast_to<RTCOutboundRTPStreamStats>(); |
1896 EXPECT_EQ(audio, expected_audio); | 1896 EXPECT_EQ(audio, expected_audio); |
1897 | 1897 |
1898 EXPECT_TRUE(report->Get(*expected_audio.media_track_id)); | 1898 EXPECT_TRUE(report->Get(*expected_audio.track_id)); |
1899 EXPECT_TRUE(report->Get(*expected_audio.transport_id)); | 1899 EXPECT_TRUE(report->Get(*expected_audio.transport_id)); |
1900 EXPECT_TRUE(report->Get(*expected_audio.codec_id)); | 1900 EXPECT_TRUE(report->Get(*expected_audio.codec_id)); |
1901 } | 1901 } |
1902 | 1902 |
1903 TEST_F(RTCStatsCollectorTest, CollectRTCOutboundRTPStreamStats_Video) { | 1903 TEST_F(RTCStatsCollectorTest, CollectRTCOutboundRTPStreamStats_Video) { |
1904 MockVideoMediaChannel* video_media_channel = new MockVideoMediaChannel(); | 1904 MockVideoMediaChannel* video_media_channel = new MockVideoMediaChannel(); |
1905 cricket::VideoChannel video_channel( | 1905 cricket::VideoChannel video_channel( |
1906 test_->worker_thread(), test_->network_thread(), | 1906 test_->worker_thread(), test_->network_thread(), |
1907 test_->signaling_thread(), video_media_channel, "VideoContentName", | 1907 test_->signaling_thread(), video_media_channel, "VideoContentName", |
1908 kDefaultRtcpMuxRequired, kDefaultSrtpRequired); | 1908 kDefaultRtcpMuxRequired, kDefaultSrtpRequired); |
(...skipping 44 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1953 EXPECT_CALL(test_->session(), video_channel()) | 1953 EXPECT_CALL(test_->session(), video_channel()) |
1954 .WillRepeatedly(Return(&video_channel)); | 1954 .WillRepeatedly(Return(&video_channel)); |
1955 | 1955 |
1956 rtc::scoped_refptr<const RTCStatsReport> report = GetStatsReport(); | 1956 rtc::scoped_refptr<const RTCStatsReport> report = GetStatsReport(); |
1957 | 1957 |
1958 RTCOutboundRTPStreamStats expected_video( | 1958 RTCOutboundRTPStreamStats expected_video( |
1959 "RTCOutboundRTPVideoStream_1", report->timestamp_us()); | 1959 "RTCOutboundRTPVideoStream_1", report->timestamp_us()); |
1960 expected_video.ssrc = "1"; | 1960 expected_video.ssrc = "1"; |
1961 expected_video.is_remote = false; | 1961 expected_video.is_remote = false; |
1962 expected_video.media_type = "video"; | 1962 expected_video.media_type = "video"; |
1963 expected_video.media_track_id = | 1963 expected_video.track_id = |
1964 "RTCMediaStreamTrack_local_video_LocalVideoTrackID_1"; | 1964 "RTCMediaStreamTrack_local_video_LocalVideoTrackID_1"; |
1965 expected_video.transport_id = "RTCTransport_TransportName_" + | 1965 expected_video.transport_id = "RTCTransport_TransportName_" + |
1966 rtc::ToString<>(cricket::ICE_CANDIDATE_COMPONENT_RTP); | 1966 rtc::ToString<>(cricket::ICE_CANDIDATE_COMPONENT_RTP); |
1967 expected_video.codec_id = "RTCCodec_OutboundVideo_42"; | 1967 expected_video.codec_id = "RTCCodec_OutboundVideo_42"; |
1968 expected_video.fir_count = 2; | 1968 expected_video.fir_count = 2; |
1969 expected_video.pli_count = 3; | 1969 expected_video.pli_count = 3; |
1970 expected_video.nack_count = 4; | 1970 expected_video.nack_count = 4; |
1971 expected_video.packets_sent = 5; | 1971 expected_video.packets_sent = 5; |
1972 expected_video.bytes_sent = 6; | 1972 expected_video.bytes_sent = 6; |
1973 expected_video.round_trip_time = 7.5; | 1973 expected_video.round_trip_time = 7.5; |
1974 expected_video.frames_encoded = 8; | 1974 expected_video.frames_encoded = 8; |
1975 expected_video.qp_sum = 16; | 1975 expected_video.qp_sum = 16; |
1976 | 1976 |
1977 ASSERT_TRUE(report->Get(expected_video.id())); | 1977 ASSERT_TRUE(report->Get(expected_video.id())); |
1978 const RTCOutboundRTPStreamStats& video = report->Get( | 1978 const RTCOutboundRTPStreamStats& video = report->Get( |
1979 expected_video.id())->cast_to<RTCOutboundRTPStreamStats>(); | 1979 expected_video.id())->cast_to<RTCOutboundRTPStreamStats>(); |
1980 EXPECT_EQ(video, expected_video); | 1980 EXPECT_EQ(video, expected_video); |
1981 | 1981 |
1982 EXPECT_TRUE(report->Get(*expected_video.media_track_id)); | 1982 EXPECT_TRUE(report->Get(*expected_video.track_id)); |
1983 EXPECT_TRUE(report->Get(*expected_video.transport_id)); | 1983 EXPECT_TRUE(report->Get(*expected_video.transport_id)); |
1984 EXPECT_TRUE(report->Get(*expected_video.codec_id)); | 1984 EXPECT_TRUE(report->Get(*expected_video.codec_id)); |
1985 } | 1985 } |
1986 | 1986 |
1987 TEST_F(RTCStatsCollectorTest, CollectRTCOutboundRTPStreamStats_Default) { | 1987 TEST_F(RTCStatsCollectorTest, CollectRTCOutboundRTPStreamStats_Default) { |
1988 MockVoiceMediaChannel* voice_media_channel = new MockVoiceMediaChannel(); | 1988 MockVoiceMediaChannel* voice_media_channel = new MockVoiceMediaChannel(); |
1989 cricket::VoiceChannel voice_channel( | 1989 cricket::VoiceChannel voice_channel( |
1990 test_->worker_thread(), test_->network_thread(), | 1990 test_->worker_thread(), test_->network_thread(), |
1991 test_->signaling_thread(), test_->media_engine(), voice_media_channel, | 1991 test_->signaling_thread(), test_->media_engine(), voice_media_channel, |
1992 "VoiceContentName", kDefaultRtcpMuxRequired, kDefaultSrtpRequired); | 1992 "VoiceContentName", kDefaultRtcpMuxRequired, kDefaultSrtpRequired); |
(...skipping 264 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
2257 rtc::scoped_refptr<FakeRTCStatsCollector> collector_; | 2257 rtc::scoped_refptr<FakeRTCStatsCollector> collector_; |
2258 }; | 2258 }; |
2259 | 2259 |
2260 TEST_F(RTCStatsCollectorTestWithFakeCollector, ThreadUsageAndResultsMerging) { | 2260 TEST_F(RTCStatsCollectorTestWithFakeCollector, ThreadUsageAndResultsMerging) { |
2261 collector_->VerifyThreadUsageAndResultsMerging(); | 2261 collector_->VerifyThreadUsageAndResultsMerging(); |
2262 } | 2262 } |
2263 | 2263 |
2264 } // namespace | 2264 } // namespace |
2265 | 2265 |
2266 } // namespace webrtc | 2266 } // namespace webrtc |
OLD | NEW |