Clean up HttpStreamFactoryImpl::JobController when Impl::Jobs complete

net/http/http_basic_stream.cc

 // 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.
 
 #include "net/http/http_basic_stream.h"
 
 #include <utility>
 
 #include "net/http/http_request_info.h"
 #include "net/http/http_response_body_drainer.h"
@@ skipping 31 matching lines @@
   return parser()->ReadResponseHeaders(callback);
 }
 
 int HttpBasicStream::ReadResponseBody(IOBuffer* buf,
                                       int buf_len,
                                       const CompletionCallback& callback) {
   return parser()->ReadResponseBody(buf, buf_len, callback);
 }
 
 void HttpBasicStream::Close(bool not_reusable) {
-  parser()->Close(not_reusable);
+  // parser() is null if |this| is created by an orphaned
+  // HttpStreamFactoryImpl::Job in which case InitializeStream() will not have
+  // been called.
+  if (parser())
+    parser()->Close(not_reusable);
 }
 
 HttpStream* HttpBasicStream::RenewStreamForAuth() {
   DCHECK(IsResponseBodyComplete());
   DCHECK(!parser()->IsMoreDataBuffered());
   // The HttpStreamParser object still has a pointer to the connection. Just to
   // be extra-sure it doesn't touch the connection again, delete it here rather
   // than leaving it until the destructor is called.
   state_.DeleteParser();
   return new HttpBasicStream(state_.ReleaseConnection(), state_.using_proxy(),
@@ skipping 65 matching lines @@
   // like the right version should be reported, if headers were received.
   details->connection_info = HttpResponseInfo::CONNECTION_INFO_HTTP1_1;
   return;
 }
 
 void HttpBasicStream::SetPriority(RequestPriority priority) {
   // TODO(akalin): Plumb this through to |connection_|.
 }
 
 }  // namespace net