| Index: webrtc/audio/audio_receive_stream_unittest.cc
|
| diff --git a/webrtc/audio/audio_receive_stream_unittest.cc b/webrtc/audio/audio_receive_stream_unittest.cc
|
| index bc071970e14454acb3aaa76c7d7b472dd547c05e..4c443e0f2e99c11391713c0f789326aef2ae2c9f 100644
|
| --- a/webrtc/audio/audio_receive_stream_unittest.cc
|
| +++ b/webrtc/audio/audio_receive_stream_unittest.cc
|
| @@ -17,11 +17,9 @@
|
| #include "webrtc/logging/rtc_event_log/mock/mock_rtc_event_log.h"
|
| #include "webrtc/modules/audio_coding/codecs/mock/mock_audio_decoder_factory.h"
|
| #include "webrtc/modules/bitrate_controller/include/mock/mock_bitrate_controller.h"
|
| -#include "webrtc/modules/congestion_controller/include/mock/mock_congestion_controller.h"
|
| #include "webrtc/modules/pacing/packet_router.h"
|
| #include "webrtc/modules/remote_bitrate_estimator/include/mock/mock_remote_bitrate_estimator.h"
|
| #include "webrtc/modules/rtp_rtcp/source/byte_io.h"
|
| -#include "webrtc/system_wrappers/include/clock.h"
|
| #include "webrtc/test/gtest.h"
|
| #include "webrtc/test/mock_voe_channel_proxy.h"
|
| #include "webrtc/test/mock_voice_engine.h"
|
| @@ -67,12 +65,7 @@ const AudioDecodingCallStats kAudioDecodeStats = MakeAudioDecodeStatsForTest();
|
|
|
| struct ConfigHelper {
|
| ConfigHelper()
|
| - : simulated_clock_(123456),
|
| - decoder_factory_(new rtc::RefCountedObject<MockAudioDecoderFactory>),
|
| - congestion_controller_(&simulated_clock_,
|
| - &bitrate_observer_,
|
| - &remote_bitrate_observer_,
|
| - &event_log_),
|
| + : decoder_factory_(new rtc::RefCountedObject<MockAudioDecoderFactory>),
|
| audio_mixer_(new rtc::RefCountedObject<MockAudioMixer>()) {
|
| using testing::Invoke;
|
|
|
| @@ -104,8 +97,6 @@ struct ConfigHelper {
|
| EXPECT_CALL(*channel_proxy_,
|
| RegisterReceiverCongestionControlObjects(&packet_router_))
|
| .Times(1);
|
| - EXPECT_CALL(congestion_controller_, packet_router())
|
| - .WillOnce(Return(&packet_router_));
|
| EXPECT_CALL(*channel_proxy_, ResetCongestionControlObjects())
|
| .Times(1);
|
| EXPECT_CALL(*channel_proxy_, RegisterExternalTransport(nullptr))
|
| @@ -134,9 +125,7 @@ struct ConfigHelper {
|
| stream_config_.decoder_factory = decoder_factory_;
|
| }
|
|
|
| - MockCongestionController* congestion_controller() {
|
| - return &congestion_controller_;
|
| - }
|
| + PacketRouter* packet_router() { return &packet_router_; }
|
| MockRemoteBitrateEstimator* remote_bitrate_estimator() {
|
| return &remote_bitrate_estimator_;
|
| }
|
| @@ -148,9 +137,6 @@ struct ConfigHelper {
|
| MockVoEChannelProxy* channel_proxy() { return channel_proxy_; }
|
|
|
| void SetupMockForBweFeedback(bool send_side_bwe) {
|
| - EXPECT_CALL(congestion_controller_,
|
| - GetRemoteBitrateEstimator(send_side_bwe))
|
| - .WillOnce(Return(&remote_bitrate_estimator_));
|
| EXPECT_CALL(remote_bitrate_estimator_,
|
| RemoveStream(stream_config_.rtp.remote_ssrc));
|
| }
|
| @@ -176,12 +162,8 @@ struct ConfigHelper {
|
| }
|
|
|
| private:
|
| - SimulatedClock simulated_clock_;
|
| PacketRouter packet_router_;
|
| - testing::NiceMock<MockCongestionObserver> bitrate_observer_;
|
| - testing::NiceMock<MockRemoteBitrateObserver> remote_bitrate_observer_;
|
| rtc::scoped_refptr<AudioDecoderFactory> decoder_factory_;
|
| - MockCongestionController congestion_controller_;
|
| MockRemoteBitrateEstimator remote_bitrate_estimator_;
|
| MockRtcEventLog event_log_;
|
| testing::StrictMock<MockVoiceEngine> voice_engine_;
|
| @@ -261,8 +243,9 @@ TEST(AudioReceiveStreamTest, ConfigToString) {
|
| TEST(AudioReceiveStreamTest, ConstructDestruct) {
|
| ConfigHelper helper;
|
| internal::AudioReceiveStream recv_stream(
|
| - helper.congestion_controller(), helper.config(), helper.audio_state(),
|
| - helper.event_log());
|
| + helper.packet_router(),
|
| + helper.remote_bitrate_estimator(),
|
| + helper.config(), helper.audio_state(), helper.event_log());
|
| }
|
|
|
| MATCHER_P(VerifyHeaderExtension, expected_extension, "") {
|
| @@ -277,8 +260,9 @@ TEST(AudioReceiveStreamTest, ReceiveRtpPacket) {
|
| helper.config().rtp.transport_cc = true;
|
| helper.SetupMockForBweFeedback(true);
|
| internal::AudioReceiveStream recv_stream(
|
| - helper.congestion_controller(), helper.config(), helper.audio_state(),
|
| - helper.event_log());
|
| + helper.packet_router(),
|
| + helper.remote_bitrate_estimator(),
|
| + helper.config(), helper.audio_state(), helper.event_log());
|
| const int kTransportSequenceNumberValue = 1234;
|
| std::vector<uint8_t> rtp_packet = CreateRtpHeaderWithOneByteExtension(
|
| kTransportSequenceNumberId, kTransportSequenceNumberValue, 2);
|
| @@ -306,8 +290,9 @@ TEST(AudioReceiveStreamTest, ReceiveRtcpPacket) {
|
| helper.config().rtp.transport_cc = true;
|
| helper.SetupMockForBweFeedback(true);
|
| internal::AudioReceiveStream recv_stream(
|
| - helper.congestion_controller(), helper.config(), helper.audio_state(),
|
| - helper.event_log());
|
| + helper.packet_router(),
|
| + helper.remote_bitrate_estimator(),
|
| + helper.config(), helper.audio_state(), helper.event_log());
|
|
|
| std::vector<uint8_t> rtcp_packet = CreateRtcpSenderReport();
|
| EXPECT_CALL(*helper.channel_proxy(),
|
| @@ -319,8 +304,9 @@ TEST(AudioReceiveStreamTest, ReceiveRtcpPacket) {
|
| TEST(AudioReceiveStreamTest, GetStats) {
|
| ConfigHelper helper;
|
| internal::AudioReceiveStream recv_stream(
|
| - helper.congestion_controller(), helper.config(), helper.audio_state(),
|
| - helper.event_log());
|
| + helper.packet_router(),
|
| + helper.remote_bitrate_estimator(),
|
| + helper.config(), helper.audio_state(), helper.event_log());
|
| helper.SetupMockForGetStats();
|
| AudioReceiveStream::Stats stats = recv_stream.GetStats();
|
| EXPECT_EQ(kRemoteSsrc, stats.remote_ssrc);
|
| @@ -364,8 +350,9 @@ TEST(AudioReceiveStreamTest, GetStats) {
|
| TEST(AudioReceiveStreamTest, SetGain) {
|
| ConfigHelper helper;
|
| internal::AudioReceiveStream recv_stream(
|
| - helper.congestion_controller(), helper.config(), helper.audio_state(),
|
| - helper.event_log());
|
| + helper.packet_router(),
|
| + helper.remote_bitrate_estimator(),
|
| + helper.config(), helper.audio_state(), helper.event_log());
|
| EXPECT_CALL(*helper.channel_proxy(),
|
| SetChannelOutputVolumeScaling(FloatEq(0.765f)));
|
| recv_stream.SetGain(0.765f);
|
| @@ -374,8 +361,9 @@ TEST(AudioReceiveStreamTest, SetGain) {
|
| TEST(AudioReceiveStreamTest, StreamShouldNotBeAddedToMixerWhenVoEReturnsError) {
|
| ConfigHelper helper;
|
| internal::AudioReceiveStream recv_stream(
|
| - helper.congestion_controller(), helper.config(), helper.audio_state(),
|
| - helper.event_log());
|
| + helper.packet_router(),
|
| + helper.remote_bitrate_estimator(),
|
| + helper.config(), helper.audio_state(), helper.event_log());
|
|
|
| EXPECT_CALL(helper.voice_engine(), StartPlayout(_)).WillOnce(Return(-1));
|
| EXPECT_CALL(*helper.audio_mixer(), AddSource(_)).Times(0);
|
| @@ -386,8 +374,9 @@ TEST(AudioReceiveStreamTest, StreamShouldNotBeAddedToMixerWhenVoEReturnsError) {
|
| TEST(AudioReceiveStreamTest, StreamShouldBeAddedToMixerOnStart) {
|
| ConfigHelper helper;
|
| internal::AudioReceiveStream recv_stream(
|
| - helper.congestion_controller(), helper.config(), helper.audio_state(),
|
| - helper.event_log());
|
| + helper.packet_router(),
|
| + helper.remote_bitrate_estimator(),
|
| + helper.config(), helper.audio_state(), helper.event_log());
|
|
|
| EXPECT_CALL(helper.voice_engine(), StartPlayout(_)).WillOnce(Return(0));
|
| EXPECT_CALL(helper.voice_engine(), StopPlayout(_));
|
|
|