| OLD | NEW | 
|    1 /* |    1 /* | 
|    2  *  Copyright (c) 2013 The WebRTC project authors. All Rights Reserved. |    2  *  Copyright (c) 2013 The WebRTC project authors. All Rights Reserved. | 
|    3  * |    3  * | 
|    4  *  Use of this source code is governed by a BSD-style license |    4  *  Use of this source code is governed by a BSD-style license | 
|    5  *  that can be found in the LICENSE file in the root of the source |    5  *  that can be found in the LICENSE file in the root of the source | 
|    6  *  tree. An additional intellectual property rights grant can be found |    6  *  tree. An additional intellectual property rights grant can be found | 
|    7  *  in the file PATENTS.  All contributing project authors may |    7  *  in the file PATENTS.  All contributing project authors may | 
|    8  *  be found in the AUTHORS file in the root of the source tree. |    8  *  be found in the AUTHORS file in the root of the source tree. | 
|    9  */ |    9  */ | 
|   10 #include <functional> |   10 #include <functional> | 
| (...skipping 251 matching lines...) Expand 10 before | Expand all | Expand 10 after  Loading... | 
|  262  |  262  | 
|  263 static const char* kAbsSendTimeLog = |  263 static const char* kAbsSendTimeLog = | 
|  264     "RemoteBitrateEstimatorAbsSendTime: Instantiating."; |  264     "RemoteBitrateEstimatorAbsSendTime: Instantiating."; | 
|  265 static const char* kSingleStreamLog = |  265 static const char* kSingleStreamLog = | 
|  266     "RemoteBitrateEstimatorSingleStream: Instantiating."; |  266     "RemoteBitrateEstimatorSingleStream: Instantiating."; | 
|  267  |  267  | 
|  268 TEST_F(BitrateEstimatorTest, InstantiatesTOFPerDefaultForVideo) { |  268 TEST_F(BitrateEstimatorTest, InstantiatesTOFPerDefaultForVideo) { | 
|  269   video_send_config_.rtp.extensions.push_back( |  269   video_send_config_.rtp.extensions.push_back( | 
|  270       RtpExtension(RtpExtension::kTimestampOffsetUri, kTOFExtensionId)); |  270       RtpExtension(RtpExtension::kTimestampOffsetUri, kTOFExtensionId)); | 
|  271   receiver_log_.PushExpectedLogLine(kSingleStreamLog); |  271   receiver_log_.PushExpectedLogLine(kSingleStreamLog); | 
|  272   receiver_log_.PushExpectedLogLine(kAbsSendTimeLog); |  | 
|  273   receiver_log_.PushExpectedLogLine(kSingleStreamLog); |  272   receiver_log_.PushExpectedLogLine(kSingleStreamLog); | 
|  274   streams_.push_back(new Stream(this, false)); |  273   streams_.push_back(new Stream(this, false)); | 
|  275   EXPECT_TRUE(receiver_log_.Wait()); |  274   EXPECT_TRUE(receiver_log_.Wait()); | 
|  276 } |  275 } | 
|  277  |  276  | 
|  278 TEST_F(BitrateEstimatorTest, ImmediatelySwitchToASTForVideo) { |  277 TEST_F(BitrateEstimatorTest, ImmediatelySwitchToASTForVideo) { | 
|  279   video_send_config_.rtp.extensions.push_back( |  278   video_send_config_.rtp.extensions.push_back( | 
|  280       RtpExtension(RtpExtension::kAbsSendTimeUri, kASTExtensionId)); |  279       RtpExtension(RtpExtension::kAbsSendTimeUri, kASTExtensionId)); | 
|  281   receiver_log_.PushExpectedLogLine(kSingleStreamLog); |  280   receiver_log_.PushExpectedLogLine(kSingleStreamLog); | 
 |  281   receiver_log_.PushExpectedLogLine(kSingleStreamLog); | 
 |  282   receiver_log_.PushExpectedLogLine("Switching to absolute send time RBE."); | 
|  282   receiver_log_.PushExpectedLogLine(kAbsSendTimeLog); |  283   receiver_log_.PushExpectedLogLine(kAbsSendTimeLog); | 
|  283   receiver_log_.PushExpectedLogLine(kSingleStreamLog); |  | 
|  284   receiver_log_.PushExpectedLogLine(kAbsSendTimeLog); |  | 
|  285   receiver_log_.PushExpectedLogLine("Switching to absolute send time RBE."); |  | 
|  286   streams_.push_back(new Stream(this, false)); |  284   streams_.push_back(new Stream(this, false)); | 
|  287   EXPECT_TRUE(receiver_log_.Wait()); |  285   EXPECT_TRUE(receiver_log_.Wait()); | 
|  288 } |  286 } | 
|  289  |  287  | 
|  290 TEST_F(BitrateEstimatorTest, SwitchesToASTForVideo) { |  288 TEST_F(BitrateEstimatorTest, SwitchesToASTForVideo) { | 
|  291   video_send_config_.rtp.extensions.push_back( |  289   video_send_config_.rtp.extensions.push_back( | 
|  292       RtpExtension(RtpExtension::kTimestampOffsetUri, kTOFExtensionId)); |  290       RtpExtension(RtpExtension::kTimestampOffsetUri, kTOFExtensionId)); | 
|  293   receiver_log_.PushExpectedLogLine(kSingleStreamLog); |  291   receiver_log_.PushExpectedLogLine(kSingleStreamLog); | 
|  294   receiver_log_.PushExpectedLogLine(kAbsSendTimeLog); |  | 
|  295   receiver_log_.PushExpectedLogLine(kSingleStreamLog); |  292   receiver_log_.PushExpectedLogLine(kSingleStreamLog); | 
|  296   streams_.push_back(new Stream(this, false)); |  293   streams_.push_back(new Stream(this, false)); | 
|  297   EXPECT_TRUE(receiver_log_.Wait()); |  294   EXPECT_TRUE(receiver_log_.Wait()); | 
|  298  |  295  | 
|  299   video_send_config_.rtp.extensions[0] = |  296   video_send_config_.rtp.extensions[0] = | 
|  300       RtpExtension(RtpExtension::kAbsSendTimeUri, kASTExtensionId); |  297       RtpExtension(RtpExtension::kAbsSendTimeUri, kASTExtensionId); | 
 |  298   receiver_log_.PushExpectedLogLine("Switching to absolute send time RBE."); | 
|  301   receiver_log_.PushExpectedLogLine(kAbsSendTimeLog); |  299   receiver_log_.PushExpectedLogLine(kAbsSendTimeLog); | 
|  302   receiver_log_.PushExpectedLogLine("Switching to absolute send time RBE."); |  | 
|  303   streams_.push_back(new Stream(this, false)); |  300   streams_.push_back(new Stream(this, false)); | 
|  304   EXPECT_TRUE(receiver_log_.Wait()); |  301   EXPECT_TRUE(receiver_log_.Wait()); | 
|  305 } |  302 } | 
|  306  |  303  | 
|  307 // This test is flaky. See webrtc:5790. |  304 // This test is flaky. See webrtc:5790. | 
|  308 TEST_F(BitrateEstimatorTest, DISABLED_SwitchesToASTThenBackToTOFForVideo) { |  305 TEST_F(BitrateEstimatorTest, DISABLED_SwitchesToASTThenBackToTOFForVideo) { | 
|  309   video_send_config_.rtp.extensions.push_back( |  306   video_send_config_.rtp.extensions.push_back( | 
|  310       RtpExtension(RtpExtension::kTimestampOffsetUri, kTOFExtensionId)); |  307       RtpExtension(RtpExtension::kTimestampOffsetUri, kTOFExtensionId)); | 
|  311   receiver_log_.PushExpectedLogLine(kSingleStreamLog); |  308   receiver_log_.PushExpectedLogLine(kSingleStreamLog); | 
|  312   receiver_log_.PushExpectedLogLine(kAbsSendTimeLog); |  309   receiver_log_.PushExpectedLogLine(kAbsSendTimeLog); | 
| (...skipping 12 matching lines...) Expand all  Loading... | 
|  325       RtpExtension(RtpExtension::kTimestampOffsetUri, kTOFExtensionId); |  322       RtpExtension(RtpExtension::kTimestampOffsetUri, kTOFExtensionId); | 
|  326   receiver_log_.PushExpectedLogLine(kAbsSendTimeLog); |  323   receiver_log_.PushExpectedLogLine(kAbsSendTimeLog); | 
|  327   receiver_log_.PushExpectedLogLine( |  324   receiver_log_.PushExpectedLogLine( | 
|  328       "WrappingBitrateEstimator: Switching to transmission time offset RBE."); |  325       "WrappingBitrateEstimator: Switching to transmission time offset RBE."); | 
|  329   streams_.push_back(new Stream(this, false)); |  326   streams_.push_back(new Stream(this, false)); | 
|  330   streams_[0]->StopSending(); |  327   streams_[0]->StopSending(); | 
|  331   streams_[1]->StopSending(); |  328   streams_[1]->StopSending(); | 
|  332   EXPECT_TRUE(receiver_log_.Wait()); |  329   EXPECT_TRUE(receiver_log_.Wait()); | 
|  333 } |  330 } | 
|  334 }  // namespace webrtc |  331 }  // namespace webrtc | 
| OLD | NEW |