Load NPAPI plugin resources through the browser process directly instead of going through the render

content/child/npapi/plugin_stream_url.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 "content/child/npapi/plugin_stream_url.h"
 
 #include <algorithm>
 
+#include "base/strings/string_util.h"
 #include "content/child/npapi/plugin_host.h"
 #include "content/child/npapi/plugin_instance.h"
 #include "content/child/npapi/plugin_lib.h"
+#include "content/child/npapi/plugin_url_fetcher.h"
 #include "content/child/npapi/webplugin.h"
 #include "net/http/http_response_headers.h"
 
 namespace content {
 
 PluginStreamUrl::PluginStreamUrl(
     unsigned long resource_id,
     const GURL &url,
     PluginInstance *instance,
     bool notify_needed,
     void *notify_data)
     : PluginStream(instance, url.spec().c_str(), notify_needed, notify_data),
       url_(url),
       id_(resource_id) {
 }
 
+void PluginStreamUrl::SetPluginURLFetcher(PluginURLFetcher* fetcher) {
+  plugin_url_fetcher_.reset(fetcher);
+}
+
+void PluginStreamUrl::URLRedirectResponse(bool allow) {
+  if (plugin_url_fetcher_.get()) {
+    plugin_url_fetcher_->URLRedirectResponse(allow);
+  } else {
+    instance()->webplugin()->URLRedirectResponse(allow, id_);
+  }
+
+  if (allow)
+    UpdateUrl(pending_redirect_url_.c_str());
+}
+
 bool PluginStreamUrl::Close(NPReason reason) {
   // Protect the stream against it being destroyed or the whole plugin instance
   // being destroyed within the destroy stream handler.
   scoped_refptr<PluginStream> protect(this);
   CancelRequest();
   bool result = PluginStream::Close(reason);
   instance()->RemoveStream(this);
   return result;
 }
 
 WebPluginResourceClient* PluginStreamUrl::AsResourceClient() {
   return static_cast<WebPluginResourceClient*>(this);
 }
 
 void PluginStreamUrl::CancelRequest() {
   if (id_ > 0) {
-    if (instance()->webplugin()) {
-      instance()->webplugin()->CancelResource(id_);
+    if (plugin_url_fetcher_.get()) {
+      plugin_url_fetcher_->Cancel();
+    } else {
+      if (instance()->webplugin()) {
+        instance()->webplugin()->CancelResource(id_);
+      }
     }
     id_ = 0;
   }
   if (instance()->webplugin()) {
     for (size_t i = 0; i < range_requests_.size(); ++i)
       instance()->webplugin()->CancelResource(range_requests_[i]);
   }
   range_requests_.clear();
 }
 
@@ skipping 78 matching lines @@
 
 bool PluginStreamUrl::IsMultiByteResponseExpected() {
   return seekable();
 }
 
 int PluginStreamUrl::ResourceId() {
   return id_;
 }
 
 PluginStreamUrl::~PluginStreamUrl() {
-  if (instance() && instance()->webplugin()) {
+  if (!plugin_url_fetcher_.get() && instance() && instance()->webplugin()) {
     instance()->webplugin()->ResourceClientDeleted(AsResourceClient());
   }
 }
 
 void PluginStreamUrl::AddRangeRequestResourceId(unsigned long resource_id) {
   DCHECK_NE(resource_id, 0u);
   range_requests_.push_back(resource_id);
 }
 
 void PluginStreamUrl::SetDeferLoading(bool value) {
   if (id_ > 0)
     instance()->webplugin()->SetDeferResourceLoading(id_, value);
   for (size_t i = 0; i < range_requests_.size(); ++i)
     instance()->webplugin()->SetDeferResourceLoading(range_requests_[i],
                                                      value);
 }
 
+void PluginStreamUrl::UpdateUrl(const char* url) {
+  DCHECK(!open());
+  free(const_cast<char*>(stream()->url));
+  stream()->url = base::strdup(url);
+  pending_redirect_url_.clear();
+}
+
 }  // namespace content