Chromium Code Reviews| Index: webrtc/modules/audio_coding/neteq/tools/neteq_test.cc |
| diff --git a/webrtc/modules/audio_coding/neteq/tools/neteq_test.cc b/webrtc/modules/audio_coding/neteq/tools/neteq_test.cc |
| index 7cca0fed8abfecc5aa1b4a04566cd657461afbfb..6ff46bcd90b537c4674d953c12ab8bfb3fe173e8 100644 |
| --- a/webrtc/modules/audio_coding/neteq/tools/neteq_test.cc |
| +++ b/webrtc/modules/audio_coding/neteq/tools/neteq_test.cc |
| @@ -41,11 +41,11 @@ NetEqTest::NetEqTest(const NetEq::Config& config, |
| const ExtDecoderMap& ext_codecs, |
| std::unique_ptr<NetEqInput> input, |
| std::unique_ptr<AudioSink> output, |
| - NetEqTestErrorCallback* error_callback) |
| + Callbacks callbacks) |
| : neteq_(NetEq::Create(config, CreateBuiltinAudioDecoderFactory())), |
| input_(std::move(input)), |
| output_(std::move(output)), |
| - error_callback_(error_callback), |
| + callbacks_(callbacks), |
| sample_rate_hz_(config.sample_rate_hz) { |
| RTC_CHECK(!config.enable_muted_state) |
| << "The code does not handle enable_muted_state"; |
| @@ -69,25 +69,37 @@ int64_t NetEqTest::Run() { |
| packet_data->header, |
| rtc::ArrayView<const uint8_t>(packet_data->payload), |
| static_cast<uint32_t>(packet_data->time_ms * sample_rate_hz_ / 1000)); |
| - if (error != NetEq::kOK && error_callback_) { |
| - error_callback_->OnInsertPacketError(neteq_->LastError(), *packet_data); |
| + if (error != NetEq::kOK && callbacks_.error_callback) { |
|
AleBzk
2017/05/02 10:36:55
For sure, it's fine as it is now. Just wondering i
hlundin-webrtc
2017/05/04 12:50:07
I think we have a fair amount of the shorter form
|
| + callbacks_.error_callback->OnInsertPacketError(neteq_->LastError(), |
| + *packet_data); |
| + } |
| + if (callbacks_.post_insert_packet) { |
| + callbacks_.post_insert_packet->AfterInsertPacket(*packet_data, |
| + neteq_.get()); |
|
AleBzk
2017/05/02 10:36:55
I wonder if there was an error for which a packet
hlundin-webrtc
2017/05/04 12:50:07
There could be. But I think we can leave that up t
|
| } |
| } |
| // Check if it is time to get output audio. |
| if (input_->NextOutputEventTime() && |
| time_now_ms >= *input_->NextOutputEventTime()) { |
| + if (callbacks_.get_audio_callback) { |
| + callbacks_.get_audio_callback->BeforeGetAudio(neteq_.get()); |
| + } |
| AudioFrame out_frame; |
| bool muted; |
| int error = neteq_->GetAudio(&out_frame, &muted); |
| RTC_CHECK(!muted) << "The code does not handle enable_muted_state"; |
| if (error != NetEq::kOK) { |
| - if (error_callback_) { |
| - error_callback_->OnGetAudioError(neteq_->LastError()); |
| + if (callbacks_.error_callback) { |
| + callbacks_.error_callback->OnGetAudioError(neteq_->LastError()); |
| } |
| } else { |
| sample_rate_hz_ = out_frame.sample_rate_hz_; |
| } |
| + if (callbacks_.get_audio_callback) { |
| + callbacks_.get_audio_callback->AfterGetAudio(time_now_ms, out_frame, |
| + muted, neteq_.get()); |
| + } |
| if (output_) { |
| RTC_CHECK(output_->WriteArray( |