Deciding best connection to schedule requests on based on cwnd and idle time

net/http/http_proxy_client_socket.cc

 // Copyright (c) 2010 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/http/http_proxy_client_socket.h"
 
 #include "base/string_util.h"
 #include "base/stringprintf.h"
 #include "googleurl/src/gurl.h"
 #include "net/base/auth.h"
@@ skipping 38 matching lines @@
       tunnel_(tunnel),
       using_spdy_(using_spdy),
       is_https_proxy_(is_https_proxy),
       net_log_(transport_socket->socket()->NetLog()) {
   // Synthesize the bits of a request that we actually use.
   request_.url = request_url;
   request_.method = "GET";
   if (!user_agent.empty())
     request_.extra_headers.SetHeader(HttpRequestHeaders::kUserAgent,
                                      user_agent);
+  rtt_ms_ = transport_->socket()->GetRTTMs();
 }
 
 HttpProxyClientSocket::~HttpProxyClientSocket() {
   Disconnect();
 }
 
 int HttpProxyClientSocket::RestartWithAuth(CompletionCallback* callback) {
   DCHECK_EQ(STATE_NONE, next_state_);
   DCHECK(!user_callback_);
 
@@ skipping 106 matching lines @@
     // an active network attacker.  We don't worry about this for HTTP
     // because an active network attacker can already control HTTP sessions.
     // We reach this case when the user cancels a 407 proxy auth prompt.
     // See http://crbug.com/8473.
     DCHECK_EQ(407, response_.headers->response_code());
     LogBlockedTunnelResponse(response_.headers->response_code());
 
     return ERR_TUNNEL_CONNECTION_FAILED;
   }
 
-  return transport_->socket()->Read(buf, buf_len, callback);
+  int num = transport_->socket()->Read(buf, buf_len, callback);
+  num_bytes_read_ += num;
+  return num;
 }
 
 int HttpProxyClientSocket::Write(IOBuffer* buf, int buf_len,
                                  CompletionCallback* callback) {
   DCHECK_EQ(STATE_DONE, next_state_);
   DCHECK(!user_callback_);
 
   return transport_->socket()->Write(buf, buf_len, callback);
 }
 
@@ skipping 282 matching lines @@
 
 int HttpProxyClientSocket::DoTCPRestartComplete(int result) {
   if (result != OK)
     return result;
 
   next_state_ = STATE_GENERATE_AUTH_TOKEN;
   return result;
 }
 
 }  // namespace net