Notify NQE of TCP RTT values

net/base/socket_performance_watcher.cc

 // Copyright 2015 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 "net/base/socket_performance_watcher.h"
 
 #include "base/logging.h"
 
 namespace net {
 
 SocketPerformanceWatcher::SocketPerformanceWatcher(
     const SocketPerformanceWatcherFactory::Protocol protocol,
     SocketPerformanceWatcherFactory* socket_performance_watcher_factory)
     : protocol_(protocol),
+      rtt_notification_received_count_(0),
       socket_performance_watcher_factory_(socket_performance_watcher_factory) {
   DCHECK(socket_performance_watcher_factory_);
 
   switch (protocol) {
     case SocketPerformanceWatcherFactory::PROTOCOL_TCP:
     case SocketPerformanceWatcherFactory::PROTOCOL_QUIC:
       return;
     default:
       NOTREACHED();
   }
 }
 
 SocketPerformanceWatcher::~SocketPerformanceWatcher() {}
 
 void SocketPerformanceWatcher::OnUpdatedRTTAvailable(
-    const base::TimeDelta& rtt) const {
+    const base::TimeDelta& rtt) {
+  rtt_notification_received_count_++;
   socket_performance_watcher_factory_->OnUpdatedRTTAvailable(protocol_, rtt);
 }
 
+bool SocketPerformanceWatcher::ShouldNotifyUpdatedRTT() const {
+  // Currently using a small value until crbug.com/590300 is fixed.

[bengr, 2016/03/09 17:58:04]

Could you elaborate in this comment?

[tbansal1, 2016/03/09 19:13:11]

Done.

+  return rtt_notification_received_count_ < 1;
+}
+
+void SocketPerformanceWatcher::Reset() {
+  rtt_notification_received_count_ = 0;
+  socket_performance_watcher_factory_->OnWatcherReset();
+}
+
 }  // namespace net