OLD | NEW |
1 /* | 1 /* |
2 * Copyright (c) 2015 The WebRTC project authors. All Rights Reserved. | 2 * Copyright (c) 2015 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 |
11 #include "testing/gtest/include/gtest/gtest.h" | 11 #include "testing/gtest/include/gtest/gtest.h" |
12 | 12 |
13 #include "webrtc/audio/audio_send_stream.h" | 13 #include "webrtc/audio/audio_send_stream.h" |
| 14 #include "webrtc/audio/audio_state.h" |
14 #include "webrtc/audio/conversion.h" | 15 #include "webrtc/audio/conversion.h" |
15 #include "webrtc/test/mock_voice_engine.h" | 16 #include "webrtc/test/mock_voice_engine.h" |
16 | 17 |
17 namespace webrtc { | 18 namespace webrtc { |
18 namespace test { | 19 namespace test { |
19 namespace { | 20 namespace { |
20 | 21 |
21 const int kChannelId = 1; | 22 const int kChannelId = 1; |
22 const uint32_t kSsrc = 1234; | 23 const uint32_t kSsrc = 1234; |
| 24 const int kEchoDelayMedian = 254; |
| 25 const int kEchoDelayStdDev = -3; |
| 26 const int kEchoReturnLoss = -65; |
| 27 const int kEchoReturnLossEnhancement = 101; |
| 28 const unsigned int kSpeechInputLevel = 96; |
| 29 const CallStatistics kCallStats = { |
| 30 1345, 1678, 1901, 1234, 112, 13456, 17890, 1567, -1890, -1123}; |
| 31 const CodecInst kCodecInst = {-121, "codec_name_send", 48000, -231, -451, -671}; |
| 32 const ReportBlock kReportBlock = {456, 780, 123, 567, 890, 132, 143, 13354}; |
| 33 |
| 34 struct ConfigHelper { |
| 35 ConfigHelper() : stream_config_(nullptr) { |
| 36 EXPECT_CALL(voice_engine_, |
| 37 RegisterVoiceEngineObserver(testing::_)).WillOnce(testing::Return(0)); |
| 38 EXPECT_CALL(voice_engine_, |
| 39 DeRegisterVoiceEngineObserver()).WillOnce(testing::Return(0)); |
| 40 AudioState::Config config; |
| 41 config.voice_engine = &voice_engine_; |
| 42 audio_state_ = AudioState::Create(config); |
| 43 stream_config_.voe_channel_id = kChannelId; |
| 44 stream_config_.rtp.ssrc = kSsrc; |
| 45 } |
| 46 |
| 47 AudioSendStream::Config& config() { return stream_config_; } |
| 48 rtc::scoped_refptr<AudioState> audio_state() { return audio_state_; } |
| 49 |
| 50 void SetupMockForGetStats() { |
| 51 std::vector<ReportBlock> report_blocks; |
| 52 webrtc::ReportBlock block = kReportBlock; |
| 53 report_blocks.push_back(block); // Has wrong SSRC. |
| 54 block.source_SSRC = kSsrc; |
| 55 report_blocks.push_back(block); // Correct block. |
| 56 block.fraction_lost = 0; |
| 57 report_blocks.push_back(block); // Duplicate SSRC, bad fraction_lost. |
| 58 |
| 59 using testing::_; |
| 60 using testing::DoAll; |
| 61 using testing::Return; |
| 62 using testing::SetArgPointee; |
| 63 using testing::SetArgReferee; |
| 64 EXPECT_CALL(voice_engine_, GetLocalSSRC(kChannelId, _)) |
| 65 .WillRepeatedly(DoAll(SetArgReferee<1>(0), Return(0))); |
| 66 EXPECT_CALL(voice_engine_, GetRTCPStatistics(kChannelId, _)) |
| 67 .WillRepeatedly(DoAll(SetArgReferee<1>(kCallStats), Return(0))); |
| 68 EXPECT_CALL(voice_engine_, GetSendCodec(kChannelId, _)) |
| 69 .WillRepeatedly(DoAll(SetArgReferee<1>(kCodecInst), Return(0))); |
| 70 EXPECT_CALL(voice_engine_, GetRemoteRTCPReportBlocks(kChannelId, _)) |
| 71 .WillRepeatedly(DoAll(SetArgPointee<1>(report_blocks), Return(0))); |
| 72 EXPECT_CALL(voice_engine_, GetSpeechInputLevelFullRange(_)) |
| 73 .WillRepeatedly(DoAll(SetArgReferee<0>(kSpeechInputLevel), Return(0))); |
| 74 EXPECT_CALL(voice_engine_, GetEcMetricsStatus(_)) |
| 75 .WillRepeatedly(DoAll(SetArgReferee<0>(true), Return(0))); |
| 76 EXPECT_CALL(voice_engine_, GetEchoMetrics(_, _, _, _)) |
| 77 .WillRepeatedly(DoAll(SetArgReferee<0>(kEchoReturnLoss), |
| 78 SetArgReferee<1>(kEchoReturnLossEnhancement), |
| 79 Return(0))); |
| 80 EXPECT_CALL(voice_engine_, GetEcDelayMetrics(_, _, _)) |
| 81 .WillRepeatedly(DoAll(SetArgReferee<0>(kEchoDelayMedian), |
| 82 SetArgReferee<1>(kEchoDelayStdDev), Return(0))); |
| 83 } |
| 84 |
| 85 private: |
| 86 MockVoiceEngine voice_engine_; |
| 87 rtc::scoped_refptr<AudioState> audio_state_; |
| 88 AudioSendStream::Config stream_config_; |
| 89 }; |
23 } // namespace | 90 } // namespace |
24 | 91 |
25 TEST(AudioSendStreamTest, ConfigToString) { | 92 TEST(AudioSendStreamTest, ConfigToString) { |
26 const int kAbsSendTimeId = 3; | 93 const int kAbsSendTimeId = 3; |
27 AudioSendStream::Config config(nullptr); | 94 AudioSendStream::Config config(nullptr); |
28 config.rtp.ssrc = kSsrc; | 95 config.rtp.ssrc = kSsrc; |
29 config.rtp.extensions.push_back( | 96 config.rtp.extensions.push_back( |
30 RtpExtension(RtpExtension::kAbsSendTime, kAbsSendTimeId)); | 97 RtpExtension(RtpExtension::kAbsSendTime, kAbsSendTimeId)); |
31 config.voe_channel_id = kChannelId; | 98 config.voe_channel_id = kChannelId; |
32 config.cng_payload_type = 42; | 99 config.cng_payload_type = 42; |
33 config.red_payload_type = 17; | 100 config.red_payload_type = 17; |
34 EXPECT_EQ( | 101 EXPECT_EQ( |
35 "{rtp: {ssrc: 1234, extensions: [{name: " | 102 "{rtp: {ssrc: 1234, extensions: [{name: " |
36 "http://www.webrtc.org/experiments/rtp-hdrext/abs-send-time, id: 3}]}, " | 103 "http://www.webrtc.org/experiments/rtp-hdrext/abs-send-time, id: 3}]}, " |
37 "voe_channel_id: 1, cng_payload_type: 42, red_payload_type: 17}", | 104 "voe_channel_id: 1, cng_payload_type: 42, red_payload_type: 17}", |
38 config.ToString()); | 105 config.ToString()); |
39 } | 106 } |
40 | 107 |
41 TEST(AudioSendStreamTest, ConstructDestruct) { | 108 TEST(AudioSendStreamTest, ConstructDestruct) { |
42 MockVoiceEngine voice_engine; | 109 ConfigHelper helper; |
43 AudioSendStream::Config config(nullptr); | 110 internal::AudioSendStream send_stream(helper.config(), helper.audio_state()); |
44 config.voe_channel_id = kChannelId; | |
45 internal::AudioSendStream send_stream(config, &voice_engine); | |
46 } | 111 } |
47 | 112 |
48 TEST(AudioSendStreamTest, GetStats) { | 113 TEST(AudioSendStreamTest, GetStats) { |
49 const int kEchoDelayMedian = 254; | 114 ConfigHelper helper; |
50 const int kEchoDelayStdDev = -3; | 115 internal::AudioSendStream send_stream(helper.config(), helper.audio_state()); |
51 const int kEchoReturnLoss = -65; | 116 helper.SetupMockForGetStats(); |
52 const int kEchoReturnLossEnhancement = 101; | |
53 const unsigned int kSpeechInputLevel = 96; | |
54 | |
55 const CallStatistics kCallStats = {1345, 1678, 1901, 1234, 112, | |
56 13456, 17890, 1567, -1890, -1123}; | |
57 | |
58 const CodecInst kCodecInst = {-121, "codec_name_send", 48000, -231, -451, | |
59 -671}; | |
60 | |
61 const ReportBlock kReportBlock = {456, 780, 123, 567, 890, 132, 143, 13354}; | |
62 | |
63 std::vector<ReportBlock> report_blocks; | |
64 { | |
65 webrtc::ReportBlock block = kReportBlock; | |
66 report_blocks.push_back(block); // Has wrong SSRC. | |
67 block.source_SSRC = kSsrc; | |
68 report_blocks.push_back(block); // Correct block. | |
69 block.fraction_lost = 0; | |
70 report_blocks.push_back(block); // Duplicate SSRC, bad fraction_lost. | |
71 } | |
72 | |
73 MockVoiceEngine voice_engine; | |
74 AudioSendStream::Config config(nullptr); | |
75 config.rtp.ssrc = kSsrc; | |
76 config.voe_channel_id = kChannelId; | |
77 internal::AudioSendStream send_stream(config, &voice_engine); | |
78 | |
79 using testing::_; | |
80 using testing::DoAll; | |
81 using testing::Return; | |
82 using testing::SetArgPointee; | |
83 using testing::SetArgReferee; | |
84 EXPECT_CALL(voice_engine, GetLocalSSRC(kChannelId, _)) | |
85 .WillOnce(DoAll(SetArgReferee<1>(0), Return(0))); | |
86 EXPECT_CALL(voice_engine, GetRTCPStatistics(kChannelId, _)) | |
87 .WillOnce(DoAll(SetArgReferee<1>(kCallStats), Return(0))); | |
88 EXPECT_CALL(voice_engine, GetSendCodec(kChannelId, _)) | |
89 .WillOnce(DoAll(SetArgReferee<1>(kCodecInst), Return(0))); | |
90 EXPECT_CALL(voice_engine, GetRemoteRTCPReportBlocks(kChannelId, _)) | |
91 .WillOnce(DoAll(SetArgPointee<1>(report_blocks), Return(0))); | |
92 EXPECT_CALL(voice_engine, GetSpeechInputLevelFullRange(_)) | |
93 .WillOnce(DoAll(SetArgReferee<0>(kSpeechInputLevel), Return(0))); | |
94 EXPECT_CALL(voice_engine, GetEcMetricsStatus(_)) | |
95 .WillOnce(DoAll(SetArgReferee<0>(true), Return(0))); | |
96 EXPECT_CALL(voice_engine, GetEchoMetrics(_, _, _, _)) | |
97 .WillOnce(DoAll(SetArgReferee<0>(kEchoReturnLoss), | |
98 SetArgReferee<1>(kEchoReturnLossEnhancement), Return(0))); | |
99 EXPECT_CALL(voice_engine, GetEcDelayMetrics(_, _, _)) | |
100 .WillOnce(DoAll(SetArgReferee<0>(kEchoDelayMedian), | |
101 SetArgReferee<1>(kEchoDelayStdDev), Return(0))); | |
102 | |
103 AudioSendStream::Stats stats = send_stream.GetStats(); | 117 AudioSendStream::Stats stats = send_stream.GetStats(); |
104 EXPECT_EQ(kSsrc, stats.local_ssrc); | 118 EXPECT_EQ(kSsrc, stats.local_ssrc); |
105 EXPECT_EQ(static_cast<int64_t>(kCallStats.bytesSent), stats.bytes_sent); | 119 EXPECT_EQ(static_cast<int64_t>(kCallStats.bytesSent), stats.bytes_sent); |
106 EXPECT_EQ(kCallStats.packetsSent, stats.packets_sent); | 120 EXPECT_EQ(kCallStats.packetsSent, stats.packets_sent); |
107 EXPECT_EQ(static_cast<int32_t>(kReportBlock.cumulative_num_packets_lost), | 121 EXPECT_EQ(static_cast<int32_t>(kReportBlock.cumulative_num_packets_lost), |
108 stats.packets_lost); | 122 stats.packets_lost); |
109 EXPECT_EQ(Q8ToFloat(kReportBlock.fraction_lost), stats.fraction_lost); | 123 EXPECT_EQ(Q8ToFloat(kReportBlock.fraction_lost), stats.fraction_lost); |
110 EXPECT_EQ(std::string(kCodecInst.plname), stats.codec_name); | 124 EXPECT_EQ(std::string(kCodecInst.plname), stats.codec_name); |
111 EXPECT_EQ(static_cast<int32_t>(kReportBlock.extended_highest_sequence_number), | 125 EXPECT_EQ(static_cast<int32_t>(kReportBlock.extended_highest_sequence_number), |
112 stats.ext_seqnum); | 126 stats.ext_seqnum); |
113 EXPECT_EQ(static_cast<int32_t>(kReportBlock.interarrival_jitter / | 127 EXPECT_EQ(static_cast<int32_t>(kReportBlock.interarrival_jitter / |
114 (kCodecInst.plfreq / 1000)), | 128 (kCodecInst.plfreq / 1000)), |
115 stats.jitter_ms); | 129 stats.jitter_ms); |
116 EXPECT_EQ(kCallStats.rttMs, stats.rtt_ms); | 130 EXPECT_EQ(kCallStats.rttMs, stats.rtt_ms); |
117 EXPECT_EQ(static_cast<int32_t>(kSpeechInputLevel), stats.audio_level); | 131 EXPECT_EQ(static_cast<int32_t>(kSpeechInputLevel), stats.audio_level); |
118 EXPECT_EQ(-1, stats.aec_quality_min); | 132 EXPECT_EQ(-1, stats.aec_quality_min); |
119 EXPECT_EQ(kEchoDelayMedian, stats.echo_delay_median_ms); | 133 EXPECT_EQ(kEchoDelayMedian, stats.echo_delay_median_ms); |
120 EXPECT_EQ(kEchoDelayStdDev, stats.echo_delay_std_ms); | 134 EXPECT_EQ(kEchoDelayStdDev, stats.echo_delay_std_ms); |
121 EXPECT_EQ(kEchoReturnLoss, stats.echo_return_loss); | 135 EXPECT_EQ(kEchoReturnLoss, stats.echo_return_loss); |
122 EXPECT_EQ(kEchoReturnLossEnhancement, stats.echo_return_loss_enhancement); | 136 EXPECT_EQ(kEchoReturnLossEnhancement, stats.echo_return_loss_enhancement); |
123 EXPECT_FALSE(stats.typing_noise_detected); | 137 EXPECT_FALSE(stats.typing_noise_detected); |
124 } | 138 } |
| 139 |
| 140 TEST(AudioSendStreamTest, GetStatsTypingNoiseDetected) { |
| 141 ConfigHelper helper; |
| 142 internal::AudioSendStream send_stream(helper.config(), helper.audio_state()); |
| 143 helper.SetupMockForGetStats(); |
| 144 EXPECT_FALSE(send_stream.GetStats().typing_noise_detected); |
| 145 |
| 146 internal::AudioState* internal_audio_state = |
| 147 static_cast<internal::AudioState*>(helper.audio_state().get()); |
| 148 VoiceEngineObserver* voe_observer = |
| 149 static_cast<VoiceEngineObserver*>(internal_audio_state); |
| 150 voe_observer->CallbackOnError(-1, VE_TYPING_NOISE_WARNING); |
| 151 EXPECT_TRUE(send_stream.GetStats().typing_noise_detected); |
| 152 voe_observer->CallbackOnError(-1, VE_TYPING_NOISE_OFF_WARNING); |
| 153 EXPECT_FALSE(send_stream.GetStats().typing_noise_detected); |
| 154 } |
125 } // namespace test | 155 } // namespace test |
126 } // namespace webrtc | 156 } // namespace webrtc |
OLD | NEW |