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

net/socket/stream_socket.h

 // Copyright (c) 2011 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.
 
 #ifndef NET_SOCKET_STREAM_SOCKET_H_
 #define NET_SOCKET_STREAM_SOCKET_H_
 #pragma once
 
 #include "net/base/net_log.h"
 #include "net/socket/socket.h"
 
 namespace net {
 
 class AddressList;
 class IPEndPoint;
 
 class NET_TEST StreamSocket : public Socket {
  public:
+  StreamSocket() : num_bytes_read_(0) {}
+
   virtual ~StreamSocket() {}
 
   // Called to establish a connection.  Returns OK if the connection could be
   // established synchronously.  Otherwise, ERR_IO_PENDING is returned and the
   // given callback will run asynchronously when the connection is established
   // or when an error occurs.  The result is some other error code if the
   // connection could not be established.
   //
   // The socket's Read and Write methods may not be called until Connect
   // succeeds.
@@ skipping 43 matching lines @@
 
   // Returns true if the underlying transport socket ever had any reads or
   // writes.  StreamSockets layered on top of transport sockets should forward
   // this call to the transport socket.
   virtual bool WasEverUsed() const = 0;
 
   // Returns true if the underlying transport socket is using TCP FastOpen.
   // TCP FastOpen is an experiment with sending data in the TCP SYN packet.
   virtual bool UsingTCPFastOpen() const = 0;
 
+  // Returns the number of bytes successfully written to this socket.

[willchan no longer on Chromium, 2011/06/06 10:57:36]

This should be virtual int NumBytesRead() const = 0;

[Gagan, 2011/06/06 20:27:10]

Done.

+  virtual int NumBytesRead() const { return num_bytes_read_; }
+
+  // Returns the RTT of this socket.
+  virtual double GetRTTMs() const { return rtt_ms_; }

[willchan no longer on Chromium, 2011/06/06 10:57:36]

virtual double GetRTTInMs() const = 0;

[Gagan, 2011/06/06 20:27:10]

Done.

+
  protected:
   // The following class is only used to gather statistics about the history of
   // a socket.  It is only instantiated and used in basic sockets, such as
   // TCPClientSocket* instances.  Other classes that are derived from
   // StreamSocket should forward any potential settings to their underlying
   // transport sockets.
   class UseHistory {
    public:
     UseHistory();
     ~UseHistory();
@@ skipping 27 matching lines @@
     bool omnibox_speculation_;
     bool subresource_speculation_;
     DISALLOW_COPY_AND_ASSIGN(UseHistory);
   };
 
   // Logs a SOCKET_BYTES_RECEIVED or SOCKET_BYTES_SENT event to the NetLog.
   // Determines whether to log the received bytes or not, based on the current
   // logging level.
   void LogByteTransfer(const BoundNetLog& net_log, NetLog::EventType event_type,
                        int byte_count, char* bytes) const;
+
+  int num_bytes_read_;

[willchan no longer on Chromium, 2011/06/06 10:57:36]

Don't add any concrete member variables into this abstract interface class.

You want to add these guys into the transport sockets (TCPClientSocketLibevent
and TCPClientSocketWin). Higher level sockets like the HttpProxyClientSocket
should just forward to their underlying sockets.

[Gagan, 2011/06/06 20:27:10]

Done.

+  double rtt_ms_;
 };
 
 }  // namespace net
 
 #endif  // NET_SOCKET_STREAM_SOCKET_H_