Basic HTTP pipelining support

net/http/http_stream_factory_impl_request.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_HTTP_HTTP_STREAM_FACTORY_IMPL_REQUEST_H_
 #define NET_HTTP_HTTP_STREAM_FACTORY_IMPL_REQUEST_H_
 
 #include <set>
 #include "base/memory/scoped_ptr.h"
 #include "googleurl/src/gurl.h"
@@ skipping 12 matching lines @@
 
   // The GURL from the HttpRequestInfo the started the Request.
   const GURL& url() const { return url_; }
 
   // Called when the Job determines the appropriate |spdy_session_key| for the
   // Request. Note that this does not mean that SPDY is necessarily supported
   // for this HostPortProxyPair, since we may need to wait for NPN to complete
   // before knowing if SPDY is available.
   void SetSpdySessionKey(const HostPortProxyPair& spdy_session_key);
 
+  // Called when the Job determines the appropriate |http_pipelining_key| for
+  // the Request. Registers this Request with the factory, so that if an
+  // existing pipeline becomes available, this Request can be late bound to it.
+  void SetHttpPipeliningKey(const HostPortPair& http_pipelining_key);
+
   // Attaches |job| to this request. Does not mean that Request will use |job|,
   // but Request will own |job|.
   void AttachJob(HttpStreamFactoryImpl::Job* job);
 
   // Marks completion of the request. Must be called before OnStreamReady().
   // |source| is the NetLog::Source generated by the Job that fulfilled this
   // request.
   void Complete(bool was_npn_negotiated,
                 bool using_spdy,
                 const NetLog::Source& source);
 
   // If this Request has a spdy_session_key, remove this session from the
   // SpdySessionRequestMap.
   void RemoveRequestFromSpdySessionRequestMap();
 
+  // If this Request has a http_pipelining_key, remove this session from the

[mmenke, 2011/08/23 19:05:25]

nit:  |http_pipelining_key_|

[James Simonsen, 2011/08/26 22:19:07]

Done.

+  // HttpPipeliningRequestMap.
+  void RemoveRequestFromHttpPipeliningRequestMap();
+
   // Called by an attached Job if it sets up a SpdySession.
   void OnSpdySessionReady(Job* job,
                           scoped_refptr<SpdySession> spdy_session,
                           bool direct);
 
   // HttpStreamRequest::Delegate methods which we implement. Note we don't
   // actually subclass HttpStreamRequest::Delegate.
 
   void OnStreamReady(Job* job,
                      const SSLConfig& used_ssl_config,
@@ skipping 37 matching lines @@
 
   const GURL url_;
   HttpStreamFactoryImpl* const factory_;
   HttpStreamRequest::Delegate* const delegate_;
   const BoundNetLog net_log_;
 
   // At the point where Job is irrevocably tied to the Request, we set this.
   scoped_ptr<Job> bound_job_;
   std::set<HttpStreamFactoryImpl::Job*> jobs_;
   scoped_ptr<const HostPortProxyPair> spdy_session_key_;
+  scoped_ptr<const HostPortPair> http_pipelining_key_;
 
   bool completed_;
   bool was_npn_negotiated_;
   bool using_spdy_;
 
   DISALLOW_COPY_AND_ASSIGN(Request);
 };
 
 }  // namespace net
 
 #endif  // NET_HTTP_HTTP_STREAM_FACTORY_IMPL_H_