| Index: third_party/WebKit/Source/platform/network/NetworkStateNotifier.cpp
|
| diff --git a/third_party/WebKit/Source/platform/network/NetworkStateNotifier.cpp b/third_party/WebKit/Source/platform/network/NetworkStateNotifier.cpp
|
| index 800557c4944a1482b505a4102315481a86d2e06d..dc9b06a3e2fef7a129f8cc98f12d2d85fb6812ec 100644
|
| --- a/third_party/WebKit/Source/platform/network/NetworkStateNotifier.cpp
|
| +++ b/third_party/WebKit/Source/platform/network/NetworkStateNotifier.cpp
|
| @@ -58,7 +58,10 @@ NetworkStateNotifier::ScopedNotifier::~ScopedNotifier() {
|
| const NetworkState& after =
|
| notifier_.has_override_ ? notifier_.override_ : notifier_.state_;
|
| if ((after.type != before_.type ||
|
| - after.max_bandwidth_mbps != before_.max_bandwidth_mbps) &&
|
| + after.max_bandwidth_mbps != before_.max_bandwidth_mbps ||
|
| + after.http_rtt != before_.http_rtt ||
|
| + after.transport_rtt != before_.transport_rtt ||
|
| + after.downlink_throughput_mbps != before_.downlink_throughput_mbps) &&
|
| before_.connection_initialized) {
|
| notifier_.NotifyObservers(notifier_.connection_observers_,
|
| ObserverType::CONNECTION_TYPE, after);
|
| @@ -91,6 +94,30 @@ void NetworkStateNotifier::SetWebConnection(WebConnectionType type,
|
| }
|
| }
|
|
|
| +void NetworkStateNotifier::SetWebNetworkQuality(int http_rtt_msec,
|
| + int transport_rtt_msec,
|
| + int downlink_throughput_kbps) {
|
| + DCHECK(IsMainThread());
|
| + ScopedNotifier notifier(*this);
|
| + {
|
| + MutexLocker locker(mutex_);
|
| +
|
| + state_.http_rtt = http_rtt_msec < 0
|
| + ? Optional<TimeDelta>()
|
| + : TimeDelta::FromMilliseconds(http_rtt_msec);
|
| +
|
| + state_.transport_rtt =
|
| + transport_rtt_msec < 0
|
| + ? Optional<TimeDelta>()
|
| + : TimeDelta::FromMilliseconds(transport_rtt_msec);
|
| +
|
| + state_.downlink_throughput_mbps =
|
| + downlink_throughput_kbps < 0
|
| + ? Optional<double>()
|
| + : static_cast<double>(downlink_throughput_kbps) / 1000;
|
| + }
|
| +}
|
| +
|
| void NetworkStateNotifier::AddConnectionObserver(
|
| NetworkStateObserver* observer,
|
| PassRefPtr<WebTaskRunner> task_runner) {
|
| @@ -180,8 +207,9 @@ void NetworkStateNotifier::NotifyObserversOnTaskRunner(
|
| observer_list->observers[i]->OnLineStateChange(state.on_line);
|
| continue;
|
| case ObserverType::CONNECTION_TYPE:
|
| - observer_list->observers[i]->ConnectionChange(state.type,
|
| - state.max_bandwidth_mbps);
|
| + observer_list->observers[i]->ConnectionChange(
|
| + state.type, state.max_bandwidth_mbps, state.http_rtt,
|
| + state.transport_rtt, state.downlink_throughput_mbps);
|
| continue;
|
| }
|
| NOTREACHED();
|
|
|