Index: webrtc/video/call_stats_unittest.cc |
diff --git a/webrtc/video/call_stats_unittest.cc b/webrtc/video/call_stats_unittest.cc |
deleted file mode 100644 |
index 6b2e38ff3eea2e2d731a56ce69081b8d7b0d5be2..0000000000000000000000000000000000000000 |
--- a/webrtc/video/call_stats_unittest.cc |
+++ /dev/null |
@@ -1,203 +0,0 @@ |
-/* |
- * Copyright (c) 2012 The WebRTC project authors. All Rights Reserved. |
- * |
- * Use of this source code is governed by a BSD-style license |
- * that can be found in the LICENSE file in the root of the source |
- * tree. An additional intellectual property rights grant can be found |
- * in the file PATENTS. All contributing project authors may |
- * be found in the AUTHORS file in the root of the source tree. |
- */ |
- |
-#include "testing/gmock/include/gmock/gmock.h" |
-#include "testing/gtest/include/gtest/gtest.h" |
- |
-#include "webrtc/base/scoped_ptr.h" |
-#include "webrtc/modules/rtp_rtcp/include/rtp_rtcp_defines.h" |
-#include "webrtc/system_wrappers/include/tick_util.h" |
-#include "webrtc/video/call_stats.h" |
- |
-using ::testing::_; |
-using ::testing::AnyNumber; |
-using ::testing::Return; |
- |
-namespace webrtc { |
- |
-class MockStatsObserver : public CallStatsObserver { |
- public: |
- MockStatsObserver() {} |
- virtual ~MockStatsObserver() {} |
- |
- MOCK_METHOD2(OnRttUpdate, void(int64_t, int64_t)); |
-}; |
- |
-class CallStatsTest : public ::testing::Test { |
- protected: |
- virtual void SetUp() { |
- TickTime::UseFakeClock(12345); |
- call_stats_.reset(new CallStats()); |
- } |
- rtc::scoped_ptr<CallStats> call_stats_; |
-}; |
- |
-TEST_F(CallStatsTest, AddAndTriggerCallback) { |
- MockStatsObserver stats_observer; |
- RtcpRttStats* rtcp_rtt_stats = call_stats_->rtcp_rtt_stats(); |
- call_stats_->RegisterStatsObserver(&stats_observer); |
- TickTime::AdvanceFakeClock(1000); |
- EXPECT_EQ(0, rtcp_rtt_stats->LastProcessedRtt()); |
- |
- const int64_t kRtt = 25; |
- rtcp_rtt_stats->OnRttUpdate(kRtt); |
- EXPECT_CALL(stats_observer, OnRttUpdate(kRtt, kRtt)).Times(1); |
- call_stats_->Process(); |
- EXPECT_EQ(kRtt, rtcp_rtt_stats->LastProcessedRtt()); |
- |
- const int64_t kRttTimeOutMs = 1500 + 10; |
- TickTime::AdvanceFakeClock(kRttTimeOutMs); |
- EXPECT_CALL(stats_observer, OnRttUpdate(_, _)).Times(0); |
- call_stats_->Process(); |
- EXPECT_EQ(0, rtcp_rtt_stats->LastProcessedRtt()); |
- |
- call_stats_->DeregisterStatsObserver(&stats_observer); |
-} |
- |
-TEST_F(CallStatsTest, ProcessTime) { |
- MockStatsObserver stats_observer; |
- call_stats_->RegisterStatsObserver(&stats_observer); |
- RtcpRttStats* rtcp_rtt_stats = call_stats_->rtcp_rtt_stats(); |
- rtcp_rtt_stats->OnRttUpdate(100); |
- |
- // Time isn't updated yet. |
- EXPECT_CALL(stats_observer, OnRttUpdate(_, _)).Times(0); |
- call_stats_->Process(); |
- |
- // Advance clock and verify we get an update. |
- TickTime::AdvanceFakeClock(1000); |
- EXPECT_CALL(stats_observer, OnRttUpdate(_, _)).Times(1); |
- call_stats_->Process(); |
- |
- // Advance clock just too little to get an update. |
- TickTime::AdvanceFakeClock(999); |
- rtcp_rtt_stats->OnRttUpdate(100); |
- EXPECT_CALL(stats_observer, OnRttUpdate(_, _)).Times(0); |
- call_stats_->Process(); |
- |
- // Advance enough to trigger a new update. |
- TickTime::AdvanceFakeClock(1); |
- EXPECT_CALL(stats_observer, OnRttUpdate(_, _)).Times(1); |
- call_stats_->Process(); |
- |
- call_stats_->DeregisterStatsObserver(&stats_observer); |
-} |
- |
-// Verify all observers get correct estimates and observers can be added and |
-// removed. |
-TEST_F(CallStatsTest, MultipleObservers) { |
- MockStatsObserver stats_observer_1; |
- call_stats_->RegisterStatsObserver(&stats_observer_1); |
- // Add the second observer twice, there should still be only one report to the |
- // observer. |
- MockStatsObserver stats_observer_2; |
- call_stats_->RegisterStatsObserver(&stats_observer_2); |
- call_stats_->RegisterStatsObserver(&stats_observer_2); |
- |
- RtcpRttStats* rtcp_rtt_stats = call_stats_->rtcp_rtt_stats(); |
- const int64_t kRtt = 100; |
- rtcp_rtt_stats->OnRttUpdate(kRtt); |
- |
- // Verify both observers are updated. |
- TickTime::AdvanceFakeClock(1000); |
- EXPECT_CALL(stats_observer_1, OnRttUpdate(kRtt, kRtt)).Times(1); |
- EXPECT_CALL(stats_observer_2, OnRttUpdate(kRtt, kRtt)).Times(1); |
- call_stats_->Process(); |
- |
- // Deregister the second observer and verify update is only sent to the first |
- // observer. |
- call_stats_->DeregisterStatsObserver(&stats_observer_2); |
- rtcp_rtt_stats->OnRttUpdate(kRtt); |
- TickTime::AdvanceFakeClock(1000); |
- EXPECT_CALL(stats_observer_1, OnRttUpdate(kRtt, kRtt)).Times(1); |
- EXPECT_CALL(stats_observer_2, OnRttUpdate(kRtt, kRtt)).Times(0); |
- call_stats_->Process(); |
- |
- // Deregister the first observer. |
- call_stats_->DeregisterStatsObserver(&stats_observer_1); |
- rtcp_rtt_stats->OnRttUpdate(kRtt); |
- TickTime::AdvanceFakeClock(1000); |
- EXPECT_CALL(stats_observer_1, OnRttUpdate(kRtt, kRtt)).Times(0); |
- EXPECT_CALL(stats_observer_2, OnRttUpdate(kRtt, kRtt)).Times(0); |
- call_stats_->Process(); |
-} |
- |
-// Verify increasing and decreasing rtt triggers callbacks with correct values. |
-TEST_F(CallStatsTest, ChangeRtt) { |
- MockStatsObserver stats_observer; |
- call_stats_->RegisterStatsObserver(&stats_observer); |
- RtcpRttStats* rtcp_rtt_stats = call_stats_->rtcp_rtt_stats(); |
- |
- // Advance clock to be ready for an update. |
- TickTime::AdvanceFakeClock(1000); |
- |
- // Set a first value and verify the callback is triggered. |
- const int64_t kFirstRtt = 100; |
- rtcp_rtt_stats->OnRttUpdate(kFirstRtt); |
- EXPECT_CALL(stats_observer, OnRttUpdate(kFirstRtt, kFirstRtt)).Times(1); |
- call_stats_->Process(); |
- |
- // Increase rtt and verify the new value is reported. |
- TickTime::AdvanceFakeClock(1000); |
- const int64_t kHighRtt = kFirstRtt + 20; |
- const int64_t kAvgRtt1 = 103; |
- rtcp_rtt_stats->OnRttUpdate(kHighRtt); |
- EXPECT_CALL(stats_observer, OnRttUpdate(kAvgRtt1, kHighRtt)).Times(1); |
- call_stats_->Process(); |
- |
- // Increase time enough for a new update, but not too much to make the |
- // rtt invalid. Report a lower rtt and verify the old/high value still is sent |
- // in the callback. |
- TickTime::AdvanceFakeClock(1000); |
- const int64_t kLowRtt = kFirstRtt - 20; |
- const int64_t kAvgRtt2 = 102; |
- rtcp_rtt_stats->OnRttUpdate(kLowRtt); |
- EXPECT_CALL(stats_observer, OnRttUpdate(kAvgRtt2, kHighRtt)).Times(1); |
- call_stats_->Process(); |
- |
- // Advance time to make the high report invalid, the lower rtt should now be |
- // in the callback. |
- TickTime::AdvanceFakeClock(1000); |
- const int64_t kAvgRtt3 = 95; |
- EXPECT_CALL(stats_observer, OnRttUpdate(kAvgRtt3, kLowRtt)).Times(1); |
- call_stats_->Process(); |
- |
- call_stats_->DeregisterStatsObserver(&stats_observer); |
-} |
- |
-TEST_F(CallStatsTest, LastProcessedRtt) { |
- MockStatsObserver stats_observer; |
- call_stats_->RegisterStatsObserver(&stats_observer); |
- RtcpRttStats* rtcp_rtt_stats = call_stats_->rtcp_rtt_stats(); |
- TickTime::AdvanceFakeClock(1000); |
- |
- // Set a first values and verify that LastProcessedRtt initially returns the |
- // average rtt. |
- const int64_t kRttLow = 10; |
- const int64_t kRttHigh = 30; |
- const int64_t kAvgRtt = 20; |
- rtcp_rtt_stats->OnRttUpdate(kRttLow); |
- rtcp_rtt_stats->OnRttUpdate(kRttHigh); |
- EXPECT_CALL(stats_observer, OnRttUpdate(kAvgRtt, kRttHigh)).Times(1); |
- call_stats_->Process(); |
- EXPECT_EQ(kAvgRtt, rtcp_rtt_stats->LastProcessedRtt()); |
- |
- // Update values and verify LastProcessedRtt. |
- TickTime::AdvanceFakeClock(1000); |
- rtcp_rtt_stats->OnRttUpdate(kRttLow); |
- rtcp_rtt_stats->OnRttUpdate(kRttHigh); |
- EXPECT_CALL(stats_observer, OnRttUpdate(kAvgRtt, kRttHigh)).Times(1); |
- call_stats_->Process(); |
- EXPECT_EQ(kAvgRtt, rtcp_rtt_stats->LastProcessedRtt()); |
- |
- call_stats_->DeregisterStatsObserver(&stats_observer); |
-} |
- |
-} // namespace webrtc |