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 | 10 |
(...skipping 896 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
907 (kNumFlows - 1)); | 907 (kNumFlows - 1)); |
908 metric_recorders[i].get()->set_plot_available_capacity( | 908 metric_recorders[i].get()->set_plot_available_capacity( |
909 i == 0 && plot_total_available_capacity_); | 909 i == 0 && plot_total_available_capacity_); |
910 } | 910 } |
911 | 911 |
912 // Test also with one way propagation delay = 100ms. | 912 // Test also with one way propagation delay = 100ms. |
913 // filter.delay.SetOneWayDelayMs(100); | 913 // filter.delay.SetOneWayDelayMs(100); |
914 filter.choke.set_capacity_kbps(3500); | 914 filter.choke.set_capacity_kbps(3500); |
915 | 915 |
916 RunFor(40 * 1000); // 0-40s. | 916 RunFor(40 * 1000); // 0-40s. |
917 | |
918 senders[0].get()->Pause(); | 917 senders[0].get()->Pause(); |
919 metric_recorders[0].get()->PauseFlow(); | |
920 RunFor(20 * 1000); // 40-60s. | 918 RunFor(20 * 1000); // 40-60s. |
921 | 919 senders[0].get()->Resume(20 * 1000); |
922 senders[0].get()->Resume(); | |
923 metric_recorders[0].get()->ResumeFlow(20 * 1000); | |
924 RunFor(60 * 1000); // 60-120s. | 920 RunFor(60 * 1000); // 60-120s. |
925 | 921 |
926 int64_t paused[] = {20 * 1000, 0, 0}; | 922 int64_t paused[] = {20 * 1000, 0, 0}; |
927 | 923 |
928 // First flow is being paused, hence having a different optimum. | 924 // First flow is being paused, hence having a different optimum. |
929 const std::string optima_lines[] = {"1", "2", "2"}; | 925 const std::string optima_lines[] = {"1", "2", "2"}; |
930 | 926 |
931 std::string title("5.8_Pause_and_resume_media_flow"); | 927 std::string title("5.8_Pause_and_resume_media_flow"); |
932 for (size_t i = 0; i < kNumFlows; ++i) { | 928 for (size_t i = 0; i < kNumFlows; ++i) { |
933 metric_recorders[i].get()->PlotThroughputHistogram( | 929 metric_recorders[i].get()->PlotThroughputHistogram( |
(...skipping 44 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
978 tcp_starting_times_ms.push_back( | 974 tcp_starting_times_ms.push_back( |
979 static_cast<int64_t>(random.Exponential(1.0f / kMeanMs))); | 975 static_cast<int64_t>(random.Exponential(1.0f / kMeanMs))); |
980 } | 976 } |
981 | 977 |
982 return tcp_starting_times_ms; | 978 return tcp_starting_times_ms; |
983 } | 979 } |
984 | 980 |
985 } // namespace bwe | 981 } // namespace bwe |
986 } // namespace testing | 982 } // namespace testing |
987 } // namespace webrtc | 983 } // namespace webrtc |
OLD | NEW |