Make WebURLLoader capable of retaining received buffers.

content/child/npapi/plugin_url_fetcher.cc

 // Copyright (c) 2013 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 "content/child/npapi/plugin_url_fetcher.h"
 
 #include "base/memory/scoped_ptr.h"
 #include "content/child/child_thread_impl.h"
 #include "content/child/multipart_response_delegate.h"
 #include "content/child/npapi/plugin_host.h"
@@ skipping 310 matching lines @@
                                      headers,
                                      expected_length,
                                      last_modified,
                                      request_is_seekable);
 }
 
 void PluginURLFetcher::OnDownloadedData(int len,
                                         int encoded_data_length) {
 }
 
-void PluginURLFetcher::OnReceivedData(const char* data,
-                                      int data_length,
-                                      int encoded_data_length) {
+void PluginURLFetcher::OnReceivedData(scoped_ptr<ReceivedData> data) {
+  const char* payload = data->payload();
+  int data_length = data->length();
+  int encoded_data_length = data->encoded_length();
   if (!plugin_stream_)
     return;
 
   if (multipart_delegate_) {
-    multipart_delegate_->OnReceivedData(data, data_length, encoded_data_length);
+    multipart_delegate_->OnReceivedData(payload, data_length,
+                                        encoded_data_length);
   } else {
     int64 offset = data_offset_;
     data_offset_ += data_length;
 
     if (copy_stream_data_) {
       // QuickTime writes to this memory, and since we got it from
       // ResourceDispatcher it's not mapped for write access in this process.
       // http://crbug.com/308466.
       scoped_ptr<char[]> data_copy(new char[data_length]);
-      memcpy(data_copy.get(), data, data_length);
+      memcpy(data_copy.get(), payload, data_length);
       plugin_stream_->DidReceiveData(data_copy.get(), data_length, offset);
     } else {
-      plugin_stream_->DidReceiveData(data, data_length, offset);
+      plugin_stream_->DidReceiveData(payload, data_length, offset);
     }
     // DANGER: this instance may be deleted at this point.
   }
 }
 
 void PluginURLFetcher::OnCompletedRequest(
     int error_code,
     bool was_ignored_by_handler,
     bool stale_copy_in_cache,
     const std::string& security_info,
     const base::TimeTicks& completion_time,
     int64 total_transfer_size) {
   if (!plugin_stream_)
     return;
 
   if (multipart_delegate_) {
     multipart_delegate_->OnCompletedRequest();
     multipart_delegate_.reset();
   }
 
   if (error_code == net::OK) {
     plugin_stream_->DidFinishLoading(resource_id_);
   } else {
     plugin_stream_->DidFail(resource_id_);
   }
 }
 
 }  // namespace content