Index: webrtc/modules/audio_coding/neteq/neteq_unittest.cc |
diff --git a/webrtc/modules/audio_coding/neteq/neteq_unittest.cc b/webrtc/modules/audio_coding/neteq/neteq_unittest.cc |
index 1a54c54c39453e0faefe821c62738348cfd97a03..33b4005293a41ee5478959bd1da8f668837edb02 100644 |
--- a/webrtc/modules/audio_coding/neteq/neteq_unittest.cc |
+++ b/webrtc/modules/audio_coding/neteq/neteq_unittest.cc |
@@ -324,13 +324,12 @@ |
// Ignore payload type 104 (iSAC-swb) if ISAC is not supported. |
if (rtp_header.header.payloadType != 104) |
#endif |
- ASSERT_EQ(0, |
- neteq_->InsertPacket( |
- rtp_header.header, |
- rtc::ArrayView<const uint8_t>( |
- packet_->payload(), packet_->payload_length_bytes()), |
- static_cast<uint32_t>(packet_->time_ms() * |
- (output_sample_rate_ / 1000)))); |
+ ASSERT_EQ(0, neteq_->InsertPacket( |
+ rtp_header, |
+ rtc::ArrayView<const uint8_t>( |
+ packet_->payload(), packet_->payload_length_bytes()), |
+ static_cast<uint32_t>(packet_->time_ms() * |
+ (output_sample_rate_ / 1000)))); |
} |
// Get next packet. |
packet_ = rtp_source_->NextPacket(); |
@@ -527,7 +526,7 @@ |
rtp_info.header.ssrc = 0x1234; // Just an arbitrary SSRC. |
rtp_info.header.payloadType = 94; // PCM16b WB codec. |
rtp_info.header.markerBit = 0; |
- ASSERT_EQ(0, neteq_->InsertPacket(rtp_info.header, payload, 0)); |
+ ASSERT_EQ(0, neteq_->InsertPacket(rtp_info, payload, 0)); |
} |
// Pull out all data. |
for (size_t i = 0; i < num_frames; ++i) { |
@@ -568,7 +567,7 @@ |
uint8_t payload[kPayloadBytes] = {0}; |
WebRtcRTPHeader rtp_info; |
PopulateRtpInfo(frame_index, frame_index * kSamples, &rtp_info); |
- ASSERT_EQ(0, neteq_->InsertPacket(rtp_info.header, payload, 0)); |
+ ASSERT_EQ(0, neteq_->InsertPacket(rtp_info, payload, 0)); |
++frame_index; |
} |
@@ -596,7 +595,7 @@ |
uint8_t payload[kPayloadBytes] = {0}; |
WebRtcRTPHeader rtp_info; |
PopulateRtpInfo(frame_index, frame_index * kSamples, &rtp_info); |
- ASSERT_EQ(0, neteq_->InsertPacket(rtp_info.header, payload, 0)); |
+ ASSERT_EQ(0, neteq_->InsertPacket(rtp_info, payload, 0)); |
++frame_index; |
} |
@@ -634,7 +633,7 @@ |
uint8_t payload[kPayloadBytes] = {0}; |
WebRtcRTPHeader rtp_info; |
PopulateRtpInfo(seq_no, timestamp, &rtp_info); |
- ASSERT_EQ(0, neteq_->InsertPacket(rtp_info.header, payload, 0)); |
+ ASSERT_EQ(0, neteq_->InsertPacket(rtp_info, payload, 0)); |
++seq_no; |
timestamp += kSamples; |
next_input_time_ms += static_cast<double>(kFrameSizeMs) * drift_factor; |
@@ -662,7 +661,7 @@ |
WebRtcRTPHeader rtp_info; |
PopulateCng(seq_no, timestamp, &rtp_info, payload, &payload_len); |
ASSERT_EQ(0, neteq_->InsertPacket( |
- rtp_info.header, |
+ rtp_info, |
rtc::ArrayView<const uint8_t>(payload, payload_len), 0)); |
++seq_no; |
timestamp += kCngPeriodSamples; |
@@ -705,7 +704,7 @@ |
WebRtcRTPHeader rtp_info; |
PopulateCng(seq_no, timestamp, &rtp_info, payload, &payload_len); |
ASSERT_EQ(0, neteq_->InsertPacket( |
- rtp_info.header, |
+ rtp_info, |
rtc::ArrayView<const uint8_t>(payload, payload_len), 0)); |
++seq_no; |
timestamp += kCngPeriodSamples; |
@@ -722,7 +721,7 @@ |
uint8_t payload[kPayloadBytes] = {0}; |
WebRtcRTPHeader rtp_info; |
PopulateRtpInfo(seq_no, timestamp, &rtp_info); |
- ASSERT_EQ(0, neteq_->InsertPacket(rtp_info.header, payload, 0)); |
+ ASSERT_EQ(0, neteq_->InsertPacket(rtp_info, payload, 0)); |
++seq_no; |
timestamp += kSamples; |
next_input_time_ms += kFrameSizeMs * drift_factor; |
@@ -834,7 +833,7 @@ |
WebRtcRTPHeader rtp_info; |
PopulateRtpInfo(0, 0, &rtp_info); |
rtp_info.header.payloadType = 1; // Not registered as a decoder. |
- EXPECT_EQ(NetEq::kFail, neteq_->InsertPacket(rtp_info.header, payload, 0)); |
+ EXPECT_EQ(NetEq::kFail, neteq_->InsertPacket(rtp_info, payload, 0)); |
EXPECT_EQ(NetEq::kUnknownRtpPayloadType, neteq_->LastError()); |
} |
@@ -850,7 +849,7 @@ |
WebRtcRTPHeader rtp_info; |
PopulateRtpInfo(0, 0, &rtp_info); |
rtp_info.header.payloadType = 103; // iSAC, but the payload is invalid. |
- EXPECT_EQ(0, neteq_->InsertPacket(rtp_info.header, payload, 0)); |
+ EXPECT_EQ(0, neteq_->InsertPacket(rtp_info, payload, 0)); |
// Set all of |out_data_| to 1, and verify that it was set to 0 by the call |
// to GetAudio. |
for (size_t i = 0; i < AudioFrame::kMaxDataSizeSamples; ++i) { |
@@ -957,10 +956,9 @@ |
WebRtcPcm16b_Encode(block.data(), block.size(), payload); |
ASSERT_EQ(enc_len_bytes, expected_samples_per_channel * 2); |
- ASSERT_EQ(0, neteq_->InsertPacket( |
- rtp_info.header, |
- rtc::ArrayView<const uint8_t>(payload, enc_len_bytes), |
- receive_timestamp)); |
+ ASSERT_EQ(0, neteq_->InsertPacket(rtp_info, rtc::ArrayView<const uint8_t>( |
+ payload, enc_len_bytes), |
+ receive_timestamp)); |
output.Reset(); |
ASSERT_EQ(0, neteq_->GetAudio(&output, &muted)); |
ASSERT_EQ(1u, output.num_channels_); |
@@ -1094,8 +1092,8 @@ |
PopulateRtpInfo(seq_no, timestamp, &rtp_info); |
if (drop_seq_numbers.find(seq_no) == drop_seq_numbers.end()) { |
// This sequence number was not in the set to drop. Insert it. |
- ASSERT_EQ(0, neteq_->InsertPacket(rtp_info.header, payload, |
- receive_timestamp)); |
+ ASSERT_EQ(0, |
+ neteq_->InsertPacket(rtp_info, payload, receive_timestamp)); |
++packets_inserted; |
} |
NetEqNetworkStatistics network_stats; |
@@ -1183,7 +1181,7 @@ |
bool muted; |
for (int i = 0; i < 3; ++i) { |
PopulateRtpInfo(seq_no, timestamp, &rtp_info); |
- ASSERT_EQ(0, neteq_->InsertPacket(rtp_info.header, payload, 0)); |
+ ASSERT_EQ(0, neteq_->InsertPacket(rtp_info, payload, 0)); |
++seq_no; |
timestamp += kSamples; |
@@ -1200,9 +1198,9 @@ |
size_t payload_len; |
PopulateCng(seq_no, timestamp, &rtp_info, payload, &payload_len); |
// This is the first time this CNG packet is inserted. |
- ASSERT_EQ(0, neteq_->InsertPacket( |
- rtp_info.header, |
- rtc::ArrayView<const uint8_t>(payload, payload_len), 0)); |
+ ASSERT_EQ( |
+ 0, neteq_->InsertPacket( |
+ rtp_info, rtc::ArrayView<const uint8_t>(payload, payload_len), 0)); |
// Pull audio once and make sure CNG is played. |
ASSERT_EQ(0, neteq_->GetAudio(&out_frame_, &muted)); |
@@ -1214,9 +1212,9 @@ |
// Insert the same CNG packet again. Note that at this point it is old, since |
// we have already decoded the first copy of it. |
- ASSERT_EQ(0, neteq_->InsertPacket( |
- rtp_info.header, |
- rtc::ArrayView<const uint8_t>(payload, payload_len), 0)); |
+ ASSERT_EQ( |
+ 0, neteq_->InsertPacket( |
+ rtp_info, rtc::ArrayView<const uint8_t>(payload, payload_len), 0)); |
// Pull audio until we have played |kCngPeriodMs| of CNG. Start at 10 ms since |
// we have already pulled out CNG once. |
@@ -1233,7 +1231,7 @@ |
++seq_no; |
timestamp += kCngPeriodSamples; |
PopulateRtpInfo(seq_no, timestamp, &rtp_info); |
- ASSERT_EQ(0, neteq_->InsertPacket(rtp_info.header, payload, 0)); |
+ ASSERT_EQ(0, neteq_->InsertPacket(rtp_info, payload, 0)); |
// Pull audio once and verify that the output is speech again. |
ASSERT_EQ(0, neteq_->GetAudio(&out_frame_, &muted)); |
@@ -1266,10 +1264,10 @@ |
WebRtcRTPHeader rtp_info; |
PopulateCng(seq_no, timestamp, &rtp_info, payload, &payload_len); |
- ASSERT_EQ(NetEq::kOK, |
- neteq_->InsertPacket( |
- rtp_info.header, |
- rtc::ArrayView<const uint8_t>(payload, payload_len), 0)); |
+ ASSERT_EQ( |
+ NetEq::kOK, |
+ neteq_->InsertPacket( |
+ rtp_info, rtc::ArrayView<const uint8_t>(payload, payload_len), 0)); |
++seq_no; |
timestamp += kCngPeriodSamples; |
@@ -1285,7 +1283,7 @@ |
do { |
ASSERT_LT(timeout_counter++, 20) << "Test timed out"; |
PopulateRtpInfo(seq_no, timestamp, &rtp_info); |
- ASSERT_EQ(0, neteq_->InsertPacket(rtp_info.header, payload, 0)); |
+ ASSERT_EQ(0, neteq_->InsertPacket(rtp_info, payload, 0)); |
++seq_no; |
timestamp += kSamples; |
@@ -1311,7 +1309,7 @@ |
uint8_t payload[kPayloadBytes] = {0}; |
WebRtcRTPHeader rtp_info; |
PopulateRtpInfo(0, rtp_timestamp, &rtp_info); |
- EXPECT_EQ(0, neteq_->InsertPacket(rtp_info.header, payload, 0)); |
+ EXPECT_EQ(0, neteq_->InsertPacket(rtp_info, payload, 0)); |
} |
void InsertCngPacket(uint32_t rtp_timestamp) { |
@@ -1319,10 +1317,10 @@ |
WebRtcRTPHeader rtp_info; |
size_t payload_len; |
PopulateCng(0, rtp_timestamp, &rtp_info, payload, &payload_len); |
- EXPECT_EQ(NetEq::kOK, |
- neteq_->InsertPacket( |
- rtp_info.header, |
- rtc::ArrayView<const uint8_t>(payload, payload_len), 0)); |
+ EXPECT_EQ( |
+ NetEq::kOK, |
+ neteq_->InsertPacket( |
+ rtp_info, rtc::ArrayView<const uint8_t>(payload, payload_len), 0)); |
} |
bool GetAudioReturnMuted() { |
@@ -1547,8 +1545,8 @@ |
uint8_t payload[kPayloadBytes] = {0}; |
WebRtcRTPHeader rtp_info; |
PopulateRtpInfo(0, 0, &rtp_info); |
- EXPECT_EQ(0, neteq_->InsertPacket(rtp_info.header, payload, 0)); |
- EXPECT_EQ(0, neteq2_->InsertPacket(rtp_info.header, payload, 0)); |
+ EXPECT_EQ(0, neteq_->InsertPacket(rtp_info, payload, 0)); |
+ EXPECT_EQ(0, neteq2_->InsertPacket(rtp_info, payload, 0)); |
AudioFrame out_frame1, out_frame2; |
bool muted; |
@@ -1570,8 +1568,8 @@ |
// Insert new data. Timestamp is corrected for the time elapsed since the last |
// packet. |
PopulateRtpInfo(0, kSamples * 1000, &rtp_info); |
- EXPECT_EQ(0, neteq_->InsertPacket(rtp_info.header, payload, 0)); |
- EXPECT_EQ(0, neteq2_->InsertPacket(rtp_info.header, payload, 0)); |
+ EXPECT_EQ(0, neteq_->InsertPacket(rtp_info, payload, 0)); |
+ EXPECT_EQ(0, neteq2_->InsertPacket(rtp_info, payload, 0)); |
int counter = 0; |
while (out_frame1.speech_type_ != AudioFrame::kNormalSpeech) { |