Notify NQE of TCP RTT values

net/socket/client_socket_pool_base.h

 // Copyright (c) 2012 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.
 //
 // A ClientSocketPoolBase is used to restrict the number of sockets open at
 // a time.  It also maintains a list of idle persistent sockets for reuse.
 // Subclasses of ClientSocketPool should compose ClientSocketPoolBase to handle
 // the core logic of (1) restricting the number of active (connected or
 // connecting) sockets per "group" (generally speaking, the hostname), (2)
 // maintaining a per-group list of idle, persistent sockets for reuse, and (3)
@@ skipping 38 matching lines @@
 #include "net/base/priority_queue.h"
 #include "net/base/request_priority.h"
 #include "net/log/net_log.h"
 #include "net/socket/client_socket_handle.h"
 #include "net/socket/client_socket_pool.h"
 #include "net/socket/stream_socket.h"
 
 namespace net {
 
 class ClientSocketHandle;
+class SocketPerformanceWatcherFactory;
 
 // ConnectJob provides an abstract interface for "connecting" a socket.
 // The connection may involve host resolution, tcp connection, ssl connection,
 // etc.
 class NET_EXPORT_PRIVATE ConnectJob {
  public:
   class NET_EXPORT_PRIVATE Delegate {
    public:
     Delegate() {}
     virtual ~Delegate() {}
@@ skipping 153 matching lines @@
     ConnectJobFactory() {}
     virtual ~ConnectJobFactory() {}
 
     virtual scoped_ptr<ConnectJob> NewConnectJob(
         const std::string& group_name,
         const Request& request,
         ConnectJob::Delegate* delegate) const = 0;
 
     virtual base::TimeDelta ConnectionTimeout() const = 0;
 
+    virtual void SetSocketPerformanceWatcherFactory(
+        SocketPerformanceWatcherFactory*
+            socket_performance_watcher_factory) = 0;
+
    private:
     DISALLOW_COPY_AND_ASSIGN(ConnectJobFactory);
   };
 
   ClientSocketPoolBaseHelper(
       HigherLayeredPool* pool,
       int max_sockets,
       int max_sockets_per_group,
       base::TimeDelta unused_idle_socket_timeout,
       base::TimeDelta used_idle_socket_timeout,
       ConnectJobFactory* connect_job_factory);
 
+  void SetSocketPerformanceWatcherFactory(
+      SocketPerformanceWatcherFactory* socket_performance_watcher_factory) {
+    connect_job_factory_->SetSocketPerformanceWatcherFactory(
+        socket_performance_watcher_factory);
+  }
+
   ~ClientSocketPoolBaseHelper() override;
 
   // Adds a lower layered pool to |this|, and adds |this| as a higher layered
   // pool on top of |lower_pool|.
   void AddLowerLayeredPool(LowerLayeredPool* lower_pool);
 
   // See LowerLayeredPool::IsStalled for documentation on this function.
   bool IsStalled() const;
 
   // See LowerLayeredPool for documentation on these functions. It is expected
@@ skipping 456 matching lines @@
     ConnectJobFactory() {}
     virtual ~ConnectJobFactory() {}
 
     virtual scoped_ptr<ConnectJob> NewConnectJob(
         const std::string& group_name,
         const Request& request,
         ConnectJob::Delegate* delegate) const = 0;
 
     virtual base::TimeDelta ConnectionTimeout() const = 0;
 
+    virtual void SetSocketPerformanceWatcherFactory(
+        SocketPerformanceWatcherFactory* socket_performance_watcher_factory) {}
+
    private:
     DISALLOW_COPY_AND_ASSIGN(ConnectJobFactory);
   };
 
   // |max_sockets| is the maximum number of sockets to be maintained by this
   // ClientSocketPool.  |max_sockets_per_group| specifies the maximum number of
   // sockets a "group" can have.  |unused_idle_socket_timeout| specifies how
   // long to leave an unused idle socket open before closing it.
   // |used_idle_socket_timeout| specifies how long to leave a previously used
   // idle socket open before closing it.
   ClientSocketPoolBase(HigherLayeredPool* self,
                        int max_sockets,
                        int max_sockets_per_group,
                        base::TimeDelta unused_idle_socket_timeout,
                        base::TimeDelta used_idle_socket_timeout,
                        ConnectJobFactory* connect_job_factory)
       : helper_(self,
                 max_sockets,
                 max_sockets_per_group,
                 unused_idle_socket_timeout,
                 used_idle_socket_timeout,
                 new ConnectJobFactoryAdaptor(connect_job_factory)) {}
 
+  void SetSocketPerformanceWatcherFactory(
+      SocketPerformanceWatcherFactory* socket_performance_watcher_factory) {
+    helper_.SetSocketPerformanceWatcherFactory(
+        socket_performance_watcher_factory);
+  }
+
   virtual ~ClientSocketPoolBase() {}
 
   // These member functions simply forward to ClientSocketPoolBaseHelper.
   void AddLowerLayeredPool(LowerLayeredPool* lower_pool) {
     helper_.AddLowerLayeredPool(lower_pool);
   }
 
   void AddHigherLayeredPool(HigherLayeredPool* higher_pool) {
     helper_.AddHigherLayeredPool(higher_pool);
   }
@@ skipping 122 matching lines @@
         ConnectJob::Delegate* delegate) const override {
       const Request& casted_request = static_cast<const Request&>(request);
       return connect_job_factory_->NewConnectJob(
           group_name, casted_request, delegate);
     }
 
     base::TimeDelta ConnectionTimeout() const override {
       return connect_job_factory_->ConnectionTimeout();
     }
 
+    void SetSocketPerformanceWatcherFactory(
+        SocketPerformanceWatcherFactory* socket_performance_watcher_factory) {
+      connect_job_factory_->SetSocketPerformanceWatcherFactory(
+          socket_performance_watcher_factory);
+    }
+
     const scoped_ptr<ConnectJobFactory> connect_job_factory_;
   };
 
   internal::ClientSocketPoolBaseHelper helper_;
 
   DISALLOW_COPY_AND_ASSIGN(ClientSocketPoolBase);
 };
 
 }  // namespace net
 
 #endif  // NET_SOCKET_CLIENT_SOCKET_POOL_BASE_H_