Removed the dependency of PepperPluginRegistry on Pepper proxy.

content/renderer/pepper_plugin_delegate_impl.cc

 // Copyright (c) 2011 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/renderer/pepper_plugin_delegate_impl.h"
 
 #include <cmath>
 #include <queue>
 
 #include "base/bind.h"
@@ skipping 315 matching lines @@
     // occurred while the request was in-flight, so we need to NULL check.
     if (client_)
       client_->StreamCreated(handle, length, socket_handle);
   } else {
     main_message_loop_->PostTask(FROM_HERE,
         NewRunnableMethod(this, &PlatformAudioImpl::OnLowLatencyCreated,
                           handle, socket_handle, length));
   }
 }
 
-class DispatcherWrapper
+class DispatcherDelegate : public ppapi::proxy::ProxyChannel::Delegate {
+ public:
+  virtual ~DispatcherDelegate() {}
+
+  // ProxyChannel::Delegate implementation.
+  virtual base::MessageLoopProxy* GetIPCMessageLoop() {
+    // This is called only in the renderer so we know we have a child process.
+    DCHECK(ChildProcess::current()) << "Must be in the renderer.";
+    return ChildProcess::current()->io_message_loop_proxy();
+  }
+  virtual base::WaitableEvent* GetShutdownEvent() {
+    DCHECK(ChildProcess::current()) << "Must be in the renderer.";
+    return ChildProcess::current()->GetShutDownEvent();
+  }
+};
+
+class HostDispatcherWrapper
     : public webkit::ppapi::PluginDelegate::OutOfProcessProxy {
  public:
-  DispatcherWrapper() {}
-  virtual ~DispatcherWrapper() {}
+  HostDispatcherWrapper() {}
+  virtual ~HostDispatcherWrapper() {}
 
-  bool Init(RenderView* render_view,
-            base::ProcessHandle plugin_process_handle,
+  bool Init(base::ProcessHandle plugin_process_handle,
             const IPC::ChannelHandle& channel_handle,
             PP_Module pp_module,
-            ppapi::proxy::Dispatcher::GetInterfaceFunc local_get_interface);
+            ppapi::proxy::Dispatcher::GetInterfaceFunc local_get_interface,
+            const ppapi::Preferences& preferences) {
+    dispatcher_delegate_.reset(new DispatcherDelegate);
+    dispatcher_.reset(new ppapi::proxy::HostDispatcher(
+        plugin_process_handle, pp_module, local_get_interface));
+
+    if (!dispatcher_->InitHostWithChannel(
+            dispatcher_delegate_.get(),
+            channel_handle, true, preferences)) {
+      dispatcher_.reset();
+      dispatcher_delegate_.reset();
+      return false;
+    }
+    dispatcher_->channel()->SetRestrictDispatchToSameChannel(true);
+    return true;
+  }
 
   // OutOfProcessProxy implementation.
   virtual const void* GetProxiedInterface(const char* name) {
     return dispatcher_->GetProxiedInterface(name);
   }
   virtual void AddInstance(PP_Instance instance) {
     ppapi::proxy::HostDispatcher::SetForInstance(instance, dispatcher_.get());
   }
   virtual void RemoveInstance(PP_Instance instance) {
     ppapi::proxy::HostDispatcher::RemoveForInstance(instance);
   }
 
  private:
   scoped_ptr<ppapi::proxy::HostDispatcher> dispatcher_;
+  scoped_ptr<ppapi::proxy::ProxyChannel::Delegate> dispatcher_delegate_;
 };
 
 class QuotaCallbackTranslator : public QuotaDispatcher::Callback {
  public:
   typedef webkit::ppapi::PluginDelegate::AvailableSpaceCallback PluginCallback;
   explicit QuotaCallbackTranslator(PluginCallback* cb) : callback_(cb) {}
   virtual void DidQueryStorageUsageAndQuota(int64 usage, int64 quota) OVERRIDE {
     callback_->Run(std::max(static_cast<int64>(0), quota - usage));
   }
   virtual void DidGrantStorageQuota(int64 granted_quota) OVERRIDE {
@@ skipping 59 matching lines @@
     return handler_proxy_->state().frame_rate;
   }
 
  private:
   scoped_ptr<media::VideoCaptureHandlerProxy> handler_proxy_;
   media::VideoCapture* video_capture_;
 };
 
 }  // namespace
 
-bool DispatcherWrapper::Init(
-    RenderView* render_view,
-    base::ProcessHandle plugin_process_handle,
-    const IPC::ChannelHandle& channel_handle,
-    PP_Module pp_module,
-    ppapi::proxy::Dispatcher::GetInterfaceFunc local_get_interface) {
-  dispatcher_.reset(new ppapi::proxy::HostDispatcher(
-      plugin_process_handle, pp_module, local_get_interface));
-
-  if (!dispatcher_->InitHostWithChannel(
-          PepperPluginRegistry::GetInstance(),
-          channel_handle, true,
-          ppapi::Preferences(render_view->webkit_preferences()))) {
-    dispatcher_.reset();
-    return false;
-  }
-  dispatcher_->channel()->SetRestrictDispatchToSameChannel(true);
-  return true;
-}
-
 BrokerDispatcherWrapper::BrokerDispatcherWrapper() {
 }
 
 BrokerDispatcherWrapper::~BrokerDispatcherWrapper() {
 }
 
 bool BrokerDispatcherWrapper::Init(
     base::ProcessHandle plugin_process_handle,
     const IPC::ChannelHandle& channel_handle) {
+  dispatcher_delegate_.reset(new DispatcherDelegate);
   dispatcher_.reset(
       new ppapi::proxy::BrokerHostDispatcher(plugin_process_handle));
 
-  if (!dispatcher_->InitBrokerWithChannel(PepperPluginRegistry::GetInstance(),
+  if (!dispatcher_->InitBrokerWithChannel(dispatcher_delegate_.get(),
                                           channel_handle,
                                           true)) {
     dispatcher_.reset();
+    dispatcher_delegate_.reset();
     return false;
   }
   dispatcher_->channel()->SetRestrictDispatchToSameChannel(true);
   return true;
 }
 
 // Does not take ownership of the local pipe.
 int32_t BrokerDispatcherWrapper::SendHandleToBroker(
     PP_Instance instance,
     base::SyncSocket::Handle handle) {
@@ skipping 205 matching lines @@
     // Couldn't be initialized.
     return scoped_refptr<webkit::ppapi::PluginModule>();
   }
 
   // Create a new HostDispatcher for the proxying, and hook it to a new
   // PluginModule. Note that AddLiveModule must be called before any early
   // returns since the module's destructor will remove itself.
   module = new webkit::ppapi::PluginModule(info->name, path,
                                            PepperPluginRegistry::GetInstance());
   PepperPluginRegistry::GetInstance()->AddLiveModule(path, module);
-  scoped_ptr<DispatcherWrapper> dispatcher(new DispatcherWrapper);
+  scoped_ptr<HostDispatcherWrapper> dispatcher(new HostDispatcherWrapper);
   if (!dispatcher->Init(
-          render_view_,
-          plugin_process_handle, channel_handle,
+          plugin_process_handle,
+          channel_handle,
           module->pp_module(),
-          webkit::ppapi::PluginModule::GetLocalGetInterfaceFunc()))
+          webkit::ppapi::PluginModule::GetLocalGetInterfaceFunc(),
+          GetPreferences()))
     return scoped_refptr<webkit::ppapi::PluginModule>();
   module->InitAsProxied(dispatcher.release());
   return module;
 }
 
 scoped_refptr<PpapiBrokerImpl> PepperPluginDelegateImpl::CreatePpapiBroker(
     webkit::ppapi::PluginModule* plugin_module) {
   DCHECK(plugin_module);
   DCHECK(!plugin_module->GetBroker());
 
@@ skipping 761 matching lines @@
 
 int PepperPluginDelegateImpl::GetRoutingId() const {
   return render_view_->routing_id();
 }
 
 void PepperPluginDelegateImpl::PublishInitialPolicy(
     scoped_refptr<webkit::ppapi::PluginInstance> instance,
     const std::string& policy) {
   instance->HandlePolicyUpdate(policy);
 }