[ON HOLD] Implement pull-based design for content decoding

net/url_request/url_request_http_job.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/url_request/url_request_http_job.h"
 
 #include "base/base_switches.h"
 #include "base/bind.h"
 #include "base/bind_helpers.h"
 #include "base/command_line.h"
@@ skipping 1150 matching lines @@
   return GetResponseHeaders()->response_code();
 }
 
 void URLRequestHttpJob::PopulateNetErrorDetails(
     NetErrorDetails* details) const {
   if (!transaction_)
     return;
   return transaction_->PopulateNetErrorDetails(details);
 }
 
+#if 0
 Filter* URLRequestHttpJob::SetupFilter() const {
   DCHECK(transaction_.get());
   if (!response_info_)
     return NULL;
 
   std::vector<Filter::FilterType> encoding_types;
   std::string encoding_type;
   HttpResponseHeaders* headers = GetResponseHeaders();
   size_t iter = 0;
   while (headers->EnumerateHeader(&iter, "Content-Encoding", &encoding_type)) {
     encoding_types.push_back(Filter::ConvertEncodingToType(encoding_type));
   }
 
   // Even if encoding types are empty, there is a chance that we need to add
   // some decoding, as some proxies strip encoding completely. In such cases,
   // we may need to add (for example) SDCH filtering (when the context suggests
   // it is appropriate).
   Filter::FixupEncodingTypes(*filter_context_, &encoding_types);
 
   return !encoding_types.empty()
       ? Filter::Factory(encoding_types, *filter_context_) : NULL;
 }
+#endif
+scoped_ptr<StreamSource> URLRequestHttpJob::SetupSource() {
+  DCHECK(transaction_.get());
+  if (!response_info_)
+    return NULL;
+
+  std::string encoding_type;
+  std::vector<std::string> encoding_types;
+  HttpResponseHeaders* headers = GetResponseHeaders();
+  size_t iter = 0;
+  while (headers->EnumerateHeader(&iter, "Content-Encoding", &encoding_type)) {
+    encoding_types.push_back(base::ToLowerASCII(encoding_type));
+  }
+
+  return StreamSource::BuildSourceChain(URLRequestJob::SetupSource(),
+                                        encoding_types, nullptr);
+}
 
 bool URLRequestHttpJob::CopyFragmentOnRedirect(const GURL& location) const {
   // Allow modification of reference fragments by default, unless
   // |allowed_unsafe_redirect_url_| is set and equal to the redirect URL.
   // When this is the case, we assume that the network delegate has set the
   // desired redirect URL (with or without fragment), so it must not be changed
   // any more.
   return !allowed_unsafe_redirect_url_.is_valid() ||
        allowed_unsafe_redirect_url_ != location;
 }
@@ skipping 403 matching lines @@
   return override_response_headers_.get() ?
              override_response_headers_.get() :
              transaction_->GetResponseInfo()->headers.get();
 }
 
 void URLRequestHttpJob::NotifyURLRequestDestroyed() {
   awaiting_callback_ = false;
 }
 
 }  // namespace net