Expose getters methods for NQE on UI thread

chrome/browser/net/nqe/ui_network_quality_estimator_service.cc

 // Copyright 2016 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "chrome/browser/net/nqe/ui_network_quality_estimator_service.h"
 
 #include <string>
 
 #include "base/bind.h"
 #include "base/memory/ptr_util.h"
 #include "base/metrics/histogram_macros.h"
 #include "base/threading/thread_checker.h"
 #include "base/values.h"
 #include "chrome/browser/browser_process.h"
 #include "chrome/browser/io_thread.h"
 #include "chrome/browser/profiles/profile.h"
 #include "chrome/common/pref_names.h"
 #include "components/prefs/pref_registry.h"
 #include "components/prefs/pref_registry_simple.h"
 #include "components/prefs/pref_service.h"
 #include "components/variations/variations_associated_data.h"
 #include "content/public/browser/browser_thread.h"
 #include "net/nqe/network_qualities_prefs_manager.h"
+#include "net/nqe/network_quality.h"
 
 namespace {
 
 // PrefDelegateImpl writes the provided dictionary value to the network quality
 // estimator prefs on the disk.
 class PrefDelegateImpl
     : public net::NetworkQualitiesPrefsManager::PrefDelegate {
  public:
   // |pref_service| is used to read and write prefs from/to the disk.
   explicit PrefDelegateImpl(PrefService* pref_service)
@@ skipping 104 matching lines @@
  private:
   base::WeakPtr<UINetworkQualityEstimatorService> service_;
   net::NetworkQualityEstimator* network_quality_estimator_;
 
   DISALLOW_COPY_AND_ASSIGN(IONetworkQualityObserver);
 };
 
 UINetworkQualityEstimatorService::UINetworkQualityEstimatorService(
     Profile* profile)
     : type_(net::EFFECTIVE_CONNECTION_TYPE_UNKNOWN),
-      http_rtt_(base::TimeDelta::FromMilliseconds(-1)),
-      transport_rtt_(base::TimeDelta::FromMilliseconds(-1)),
-      downstream_throughput_kbps_(-1),
+      http_rtt_(net::nqe::internal::InvalidRTT()),
+      transport_rtt_(net::nqe::internal::InvalidRTT()),
+      downstream_throughput_kbps_(net::nqe::internal::kInvalidThroughput),
       weak_factory_(this) {
   DCHECK(profile);
   // If this is running in a context without an IOThread, don't try to create
   // the IO object.
   if (!g_browser_process->io_thread())
     return;
   io_observer_ = base::WrapUnique(
       new IONetworkQualityObserver(weak_factory_.GetWeakPtr()));
   std::unique_ptr<PrefDelegateImpl> pref_delegate(
       new PrefDelegateImpl(profile->GetPrefs()));
@@ skipping 71 matching lines @@
                      NotifyEffectiveConnectionTypeObserverIfPresent,
                  weak_factory_.GetWeakPtr(), observer));
 }
 
 void UINetworkQualityEstimatorService::RemoveEffectiveConnectionTypeObserver(
     net::NetworkQualityEstimator::EffectiveConnectionTypeObserver* observer) {
   DCHECK_CURRENTLY_ON(content::BrowserThread::UI);
   effective_connection_type_observer_list_.RemoveObserver(observer);
 }
 
+base::Optional<base::TimeDelta> UINetworkQualityEstimatorService::GetHttpRTT()
+    const {
+  DCHECK_CURRENTLY_ON(content::BrowserThread::UI);
+
+  if (http_rtt_ == net::nqe::internal::InvalidRTT())
+    return base::Optional<base::TimeDelta>();
+  return http_rtt_;
+}
+
+base::Optional<base::TimeDelta>
+UINetworkQualityEstimatorService::GetTransportRTT() const {
+  DCHECK_CURRENTLY_ON(content::BrowserThread::UI);
+
+  if (transport_rtt_ == net::nqe::internal::InvalidRTT())
+    return base::Optional<base::TimeDelta>();
+  return transport_rtt_;
+}
+
+base::Optional<int32_t>
+UINetworkQualityEstimatorService::GetDownstreamThroughputKbps() const {
+  DCHECK_CURRENTLY_ON(content::BrowserThread::UI);
+
+  if (downstream_throughput_kbps_ == net::nqe::internal::kInvalidThroughput)
+    return base::Optional<int32_t>();
+  return downstream_throughput_kbps_;
+}
+
 void UINetworkQualityEstimatorService::AddRTTAndThroughputEstimatesObserver(
     net::NetworkQualityEstimator::RTTAndThroughputEstimatesObserver* observer) {
   DCHECK_CURRENTLY_ON(content::BrowserThread::UI);
   rtt_throughput_observer_list_.AddObserver(observer);
 
   // Notify the |observer| on the next message pump since |observer| may not
   // be completely set up for receiving the callbacks.
   content::BrowserThread::PostTask(
       content::BrowserThread::UI, FROM_HERE,
       base::Bind(&UINetworkQualityEstimatorService::
@@ skipping 61 matching lines @@
 
 std::map<net::nqe::internal::NetworkID,
          net::nqe::internal::CachedNetworkQuality>
 UINetworkQualityEstimatorService::ForceReadPrefsForTesting() const {
   if (!prefs_manager_) {
     return std::map<net::nqe::internal::NetworkID,
                     net::nqe::internal::CachedNetworkQuality>();
   }
   return prefs_manager_->ForceReadPrefsForTesting();
 }