Pepper stream-to-file plumbing....

webkit/glue/weburlloader_impl.cc

 // Copyright (c) 2006-2009 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.
 
 // An implementation of WebURLLoader in terms of ResourceLoaderBridge.
 
 #include "webkit/glue/weburlloader_impl.h"
 
 #include "base/file_path.h"
 #include "base/message_loop.h"
@@ skipping 164 matching lines @@
   response->setAppCacheManifestURL(info.appcache_manifest_url);
   response->setWasCached(!info.load_timing.base_time.is_null() &&
       info.response_time < info.load_timing.base_time);
   response->setWasFetchedViaSPDY(info.was_fetched_via_spdy);
   response->setWasNpnNegotiated(info.was_npn_negotiated);
   response->setWasAlternateProtocolAvailable(
       info.was_alternate_protocol_available);
   response->setWasFetchedViaProxy(info.was_fetched_via_proxy);
   response->setConnectionID(info.connection_id);
   response->setConnectionReused(info.connection_reused);
+  response->setDownloadFilePath(FilePathToWebString(info.download_file_path));
 
   WebURLLoadTiming timing;
   timing.initialize();
   const ResourceLoaderBridge::LoadTimingInfo& timing_info = info.load_timing;
   timing.setRequestTime(timing_info.base_time.ToDoubleT());
   timing.setProxyStart(timing_info.proxy_start);
   timing.setProxyEnd(timing_info.proxy_end);
   timing.setDNSStart(timing_info.dns_start);
   timing.setDNSEnd(timing_info.dns_end);
   timing.setConnectStart(timing_info.connect_start);
@@ skipping 11 matching lines @@
 
   response->setHTTPStatusCode(headers->response_code());
   response->setHTTPStatusText(WebString::fromUTF8(headers->GetStatusText()));
 
   // TODO(darin): We should leverage HttpResponseHeaders for this, and this
   // should be using the same code as ResourceDispatcherHost.
   // TODO(jungshik): Figure out the actual value of the referrer charset and
   // pass it to GetSuggestedFilename.
   std::string value;
   if (headers->EnumerateHeader(NULL, "content-disposition", &value)) {
-    response->setSuggestedFileName(webkit_glue::FilePathToWebString(
+    response->setSuggestedFileName(FilePathToWebString(
         net::GetSuggestedFilename(url, value, "", FilePath())));
   }
 
   Time time_val;
   if (headers->GetLastModifiedValue(&time_val))
     response->setLastModifiedDate(time_val.ToDoubleT());
 
   // Build up the header map.
   void* iter = NULL;
   std::string name;
@@ skipping 26 matching lines @@
 
   // ResourceLoaderBridge::Peer methods:
   virtual void OnUploadProgress(uint64 position, uint64 size);
   virtual bool OnReceivedRedirect(
       const GURL& new_url,
       const ResourceLoaderBridge::ResponseInfo& info,
       bool* has_new_first_party_for_cookies,
       GURL* new_first_party_for_cookies);
   virtual void OnReceivedResponse(
       const ResourceLoaderBridge::ResponseInfo& info, bool content_filtered);
+  virtual void OnDownloadedData(int len);
   virtual void OnReceivedData(const char* data, int len);
   virtual void OnReceivedCachedMetadata(const char* data, int len);
   virtual void OnCompletedRequest(
       const URLRequestStatus& status, const std::string& security_info);
   virtual GURL GetURLForDebugging() const;
 
  private:
   friend class base::RefCounted<Context>;
   ~Context() {}
 
@@ skipping 104 matching lines @@
   request.visitHTTPHeaderFields(&flattener);
 
   // TODO(abarth): These are wrong!  I need to figure out how to get the right
   //               strings here.  See: http://crbug.com/8706
   std::string frame_origin = request.firstPartyForCookies().spec();
   std::string main_frame_origin = request.firstPartyForCookies().spec();
 
   // TODO(brettw) this should take parameter encoding into account when
   // creating the GURLs.
 
-  webkit_glue::ResourceLoaderBridge::RequestInfo request_info;
+  ResourceLoaderBridge::RequestInfo request_info;
   request_info.method = method;
   request_info.url = url;
   request_info.first_party_for_cookies = request.firstPartyForCookies();
   request_info.referrer = referrer_url;
   request_info.frame_origin = frame_origin;
   request_info.main_frame_origin = main_frame_origin;
   request_info.headers = flattener.GetBuffer();
   request_info.load_flags = load_flags;
   request_info.requestor_pid = requestor_pid;
   request_info.request_type = FromTargetType(request.targetType());
   request_info.appcache_host_id = request.appCacheHostID();
   request_info.routing_id = request.requestorID();
+  request_info.download_to_file = request.downloadToFile();
   bridge_.reset(ResourceLoaderBridge::Create(request_info));
 
   if (!request.httpBody().isNull()) {
     // GET and HEAD requests shouldn't have http bodies.
     DCHECK(method != "GET" && method != "HEAD");
     const WebHTTPBody& httpBody = request.httpBody();
     size_t i = 0;
     WebHTTPBody::Element element;
     while (httpBody.elementAt(i++, element)) {
       switch (element.type) {
@@ skipping 128 matching lines @@
     }
   } else if (info.mime_type == "text/vnd.chromium.ftp-dir" &&
              !show_raw_listing) {
     ftp_listing_delegate_.reset(
         new FtpDirectoryListingResponseDelegate(client_, loader_, response));
   }
 
   response_url_ = response.url();
 }
 
+void WebURLLoaderImpl::Context::OnDownloadedData(int len) {
+  if (client_)
+    client_->didDownloadData(loader_, len);
+}
+
 void WebURLLoaderImpl::Context::OnReceivedData(const char* data, int len) {
   if (!client_)
     return;
 
   // Temporary logging, see site_isolation_metrics.h/cc.
   SiteIsolationMetrics::SniffCrossOriginHTML(response_url_, data, len);
 
   if (ftp_listing_delegate_.get()) {
     // The FTP listing delegate will make the appropriate calls to
     // client_->didReceiveData and client_->didReceiveResponse.
@@ skipping 121 matching lines @@
 
 void WebURLLoaderImpl::cancel() {
   context_->Cancel();
 }
 
 void WebURLLoaderImpl::setDefersLoading(bool value) {
   context_->SetDefersLoading(value);
 }
 
 }  // namespace webkit_glue