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

content/plugin/webplugin_proxy.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/plugin/webplugin_proxy.h"
 
 #include "build/build_config.h"
 
 #include "base/bind.h"
 #include "base/lazy_instance.h"
 #include "base/memory/scoped_handle.h"
 #include "base/memory/shared_memory.h"
 #include "build/build_config.h"
 #include "content/child/npapi/npobject_proxy.h"
 #include "content/child/npapi/npobject_util.h"
 #include "content/child/npapi/webplugin_delegate_impl.h"
+#include "content/child/npapi/webplugin_resource_client.h"
 #include "content/child/plugin_messages.h"
 #include "content/plugin/plugin_channel.h"
 #include "content/plugin/plugin_thread.h"
+#include "content/plugin/plugin_url_fetcher.h"
 #include "content/public/common/content_client.h"
 #include "content/public/common/url_constants.h"
 #include "skia/ext/platform_canvas.h"
 #include "skia/ext/platform_device.h"
 #include "third_party/WebKit/public/web/WebBindings.h"
 #include "ui/gfx/blit.h"
 #include "ui/gfx/canvas.h"
 
 #if defined(OS_MACOSX)
 #include "base/mac/mac_util.h"
@@ skipping 109 matching lines @@
   BrokerDuplicateHandle(pump_messages_event, channel_->peer_pid(),
                                  &pump_messages_event_for_renderer,
                                  SYNCHRONIZE | EVENT_MODIFY_STATE, 0);
   DCHECK(pump_messages_event_for_renderer);
   Send(new PluginHostMsg_SetWindowlessData(
       route_id_, pump_messages_event_for_renderer, dummy_activation_window));
 }
 #endif
 
 void WebPluginProxy::CancelResource(unsigned long id) {
-  Send(new PluginHostMsg_CancelResource(route_id_, id));
-  resource_clients_.erase(id);
+  if (resource_clients_.count(id)) {
+    Send(new PluginHostMsg_CancelResource(route_id_, id));
+
+    resource_clients_.erase(id);
+  } else if (plugin_url_fetchers_.count(id)) {
+    plugin_url_fetchers_[id]->Cancel();
+  } else {
+    NOTREACHED();
+  }
 }
 
 void WebPluginProxy::Invalidate() {
   gfx::Rect rect(0, 0,
                  delegate_->GetRect().width(),
                  delegate_->GetRect().height());
   InvalidateRect(rect);
 }
 
 void WebPluginProxy::InvalidateRect(const gfx::Rect& rect) {
@@ skipping 138 matching lines @@
   if (!damaged_rect_.IsEmpty())
     InvalidateRect(damaged_rect_);
 }
 
 void WebPluginProxy::OnResourceCreated(int resource_id,
                                        WebPluginResourceClient* client) {
   DCHECK(resource_clients_.find(resource_id) == resource_clients_.end());
   resource_clients_[resource_id] = client;
 }
 
+void WebPluginProxy::FetchURL(const PluginMsg_FetchURL_Params& params) {
+  // TODO(jam): once we switch over to resource loading always happening in this
+  // code path, remove WebPluginResourceClient abstraction.
+  WebPluginResourceClient* resource_client = delegate_->CreateResourceClient(
+      params.resource_id, params.url, params.notify_id);
+
+  DCHECK(plugin_url_fetchers_.find(params.resource_id) ==
+         plugin_url_fetchers_.end());
+  plugin_url_fetchers_[params.resource_id] = new PluginURLFetcher(
+      resource_client, this, params.url, params.first_party_for_cookies,
+      params.method, params.post_data, params.referrer, params.notify_redirect,
+      params.is_plugin_src_load, channel_->renderer_id(), params.resource_id);
+}
+
 void WebPluginProxy::HandleURLRequest(const char* url,
                                       const char* method,
                                       const char* target,
                                       const char* buf,
                                       unsigned int len,
                                       int notify_id,
                                       bool popups_allowed,
                                       bool notify_redirects) {
  if (!target && (0 == base::strcasecmp(method, "GET"))) {
     // Please refer to https://bugzilla.mozilla.org/show_bug.cgi?id=366082
@@ skipping 350 matching lines @@
   Paint(damaged_rect);
   Send(new PluginHostMsg_InvalidateRect(route_id_, damaged_rect));
 }
 
 bool WebPluginProxy::IsOffTheRecord() {
   return channel_->incognito();
 }
 
 void WebPluginProxy::ResourceClientDeleted(
     WebPluginResourceClient* resource_client) {
+  // resource_client->ResourceId() is 0 at this point, so can't use it as an
+  // index into the map.
   ResourceClientMap::iterator index = resource_clients_.begin();
   while (index != resource_clients_.end()) {
     WebPluginResourceClient* client = (*index).second;
-
     if (client == resource_client) {
-      resource_clients_.erase(index++);
+      resource_clients_.erase(index);
+      return;
     } else {
       index++;
     }
   }
+
+  PluginURLFetcherMap::iterator index2 = plugin_url_fetchers_.begin();
+  while (index2 != plugin_url_fetchers_.end()) {
+    PluginURLFetcher* fetcher = (*index2).second;
+    if (fetcher->client() == resource_client) {
+      plugin_url_fetchers_.erase(index2);
+      return;
+    } else {
+      index2++;
+    }
+  }
 }
 
 void WebPluginProxy::URLRedirectResponse(bool allow, int resource_id) {
-  Send(new PluginHostMsg_URLRedirectResponse(route_id_, allow, resource_id));
+  if (resource_clients_.count(resource_id)) {
+    Send(new PluginHostMsg_URLRedirectResponse(route_id_, allow, resource_id));
+  } else if (plugin_url_fetchers_.count(resource_id)) {
+    plugin_url_fetchers_[resource_id]->URLRedirectResponse(allow);
+  } else {
+    NOTREACHED();
+  }
 }
 
 #if defined(OS_WIN) && !defined(USE_AURA)
 void WebPluginProxy::UpdateIMEStatus() {
   // Retrieve the IME status from a plug-in and send it to a renderer process
   // when the plug-in has updated it.
   int input_type;
   gfx::Rect caret_rect;
   if (!delegate_->GetIMEStatus(&input_type, &caret_rect))
     return;
 
   Send(new PluginHostMsg_NotifyIMEStatus(route_id_, input_type, caret_rect));
 }
 #endif
 
 }  // namespace content