Index: webrtc/audio/audio_send_stream_unittest.cc |
diff --git a/webrtc/audio/audio_send_stream_unittest.cc b/webrtc/audio/audio_send_stream_unittest.cc |
index 4efd91b3e5618e2c6e5e4951836c9c124aebce56..e760b33dd03d6652f6271eeb7e897bd7ea2fc1b7 100644 |
--- a/webrtc/audio/audio_send_stream_unittest.cc |
+++ b/webrtc/audio/audio_send_stream_unittest.cc |
@@ -217,6 +217,13 @@ struct ConfigHelper { |
.WillRepeatedly(Return(audio_processing_stats_)); |
} |
+ void SyncWorkerQueue() { |
+ static const size_t kDefaultTimeoutMs = 150; |
+ rtc::Event event(false, false); |
+ worker_queue_.PostTask([this, &event] { event.Set(); }); |
+ EXPECT_TRUE(event.Wait(kDefaultTimeoutMs)); |
+ } |
+ |
private: |
SimulatedClock simulated_clock_; |
testing::StrictMock<MockVoiceEngine> voice_engine_; |
@@ -419,8 +426,10 @@ TEST(AudioSendStreamTest, DoesNotPassHigherBitrateThanMaxBitrate) { |
helper.bitrate_allocator(), helper.event_log(), helper.rtcp_rtt_stats()); |
EXPECT_CALL(*helper.channel_proxy(), |
SetBitrate(helper.config().max_bitrate_bps, _)); |
+ EXPECT_CALL(*helper.channel_proxy(), AdaptCodec()); |
send_stream.OnBitrateUpdated(helper.config().max_bitrate_bps + 5000, 0.0, 50, |
6000); |
+ helper.SyncWorkerQueue(); |
} |
TEST(AudioSendStreamTest, ProbingIntervalOnBitrateUpdated) { |
@@ -430,7 +439,9 @@ TEST(AudioSendStreamTest, ProbingIntervalOnBitrateUpdated) { |
helper.packet_router(), helper.congestion_controller(), |
helper.bitrate_allocator(), helper.event_log(), helper.rtcp_rtt_stats()); |
EXPECT_CALL(*helper.channel_proxy(), SetBitrate(_, 5000)); |
+ EXPECT_CALL(*helper.channel_proxy(), AdaptCodec()); |
send_stream.OnBitrateUpdated(50000, 0.0, 50, 5000); |
+ helper.SyncWorkerQueue(); |
} |
} // namespace test |