OLD | NEW |
1 // Copyright 2015 The Chromium Authors. All rights reserved. | 1 // Copyright 2015 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include "net/nqe/network_quality_estimator.h" | 5 #include "net/nqe/network_quality_estimator.h" |
6 | 6 |
7 #include <stddef.h> | 7 #include <stddef.h> |
8 #include <stdint.h> | 8 #include <stdint.h> |
9 | 9 |
10 #include <limits> | 10 #include <limits> |
(...skipping 2139 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
2150 | 2150 |
2151 estimator.AddRTTObserver(&rtt_observer); | 2151 estimator.AddRTTObserver(&rtt_observer); |
2152 // |observer| may be notified as soon as it is added. Run the loop to so that | 2152 // |observer| may be notified as soon as it is added. Run the loop to so that |
2153 // the notification to |observer| is finished. | 2153 // the notification to |observer| is finished. |
2154 base::RunLoop().RunUntilIdle(); | 2154 base::RunLoop().RunUntilIdle(); |
2155 | 2155 |
2156 TestDelegate test_delegate; | 2156 TestDelegate test_delegate; |
2157 TestURLRequestContext context(true); | 2157 TestURLRequestContext context(true); |
2158 context.set_network_quality_estimator(&estimator); | 2158 context.set_network_quality_estimator(&estimator); |
2159 | 2159 |
2160 std::unique_ptr<HttpNetworkSession::Params> params( | 2160 std::unique_ptr<HttpNetworkSession::Context> session_context( |
2161 new HttpNetworkSession::Params); | 2161 new HttpNetworkSession::Context); |
2162 // |estimator| should be notified of TCP RTT observations. | 2162 // |estimator| should be notified of TCP RTT observations. |
2163 params->socket_performance_watcher_factory = | 2163 session_context->socket_performance_watcher_factory = |
2164 estimator.GetSocketPerformanceWatcherFactory(); | 2164 estimator.GetSocketPerformanceWatcherFactory(); |
2165 context.set_http_network_session_params(std::move(params)); | 2165 context.set_http_network_session_context(std::move(session_context)); |
2166 context.Init(); | 2166 context.Init(); |
2167 | 2167 |
2168 EXPECT_EQ(0U, rtt_observer.observations().size()); | 2168 EXPECT_EQ(0U, rtt_observer.observations().size()); |
2169 base::TimeDelta rtt; | 2169 base::TimeDelta rtt; |
2170 EXPECT_TRUE(estimator.GetRecentHttpRTT(base::TimeTicks(), &rtt)); | 2170 EXPECT_TRUE(estimator.GetRecentHttpRTT(base::TimeTicks(), &rtt)); |
2171 EXPECT_TRUE(estimator.GetRecentTransportRTT(base::TimeTicks(), &rtt)); | 2171 EXPECT_TRUE(estimator.GetRecentTransportRTT(base::TimeTicks(), &rtt)); |
2172 EXPECT_EQ(rtt, estimator.GetTransportRTT().value()); | 2172 EXPECT_EQ(rtt, estimator.GetTransportRTT().value()); |
2173 | 2173 |
2174 // Send two requests. Verify that the completion of each request generates at | 2174 // Send two requests. Verify that the completion of each request generates at |
2175 // least one TCP RTT observation. | 2175 // least one TCP RTT observation. |
(...skipping 915 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
3091 | 3091 |
3092 // Cleanup. | 3092 // Cleanup. |
3093 estimator.RemoveRTTObserver(&rtt_observer); | 3093 estimator.RemoveRTTObserver(&rtt_observer); |
3094 estimator.RemoveThroughputObserver(&throughput_observer); | 3094 estimator.RemoveThroughputObserver(&throughput_observer); |
3095 estimator.RemoveRTTAndThroughputEstimatesObserver(&rtt_throughput_observer); | 3095 estimator.RemoveRTTAndThroughputEstimatesObserver(&rtt_throughput_observer); |
3096 estimator.RemoveEffectiveConnectionTypeObserver( | 3096 estimator.RemoveEffectiveConnectionTypeObserver( |
3097 &effective_connection_type_observer); | 3097 &effective_connection_type_observer); |
3098 } | 3098 } |
3099 | 3099 |
3100 } // namespace net | 3100 } // namespace net |
OLD | NEW |