Never lock the Pepper proxy lock on the IO thread

ppapi/proxy/plugin_globals.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 "ppapi/proxy/plugin_globals.h"
 
 #include "base/task_runner.h"
 #include "base/threading/thread.h"
 #include "ipc/ipc_message.h"
 #include "ipc/ipc_sender.h"
 #include "ppapi/proxy/plugin_dispatcher.h"
+#include "ppapi/proxy/plugin_message_filter.h"
 #include "ppapi/proxy/plugin_proxy_delegate.h"
 #include "ppapi/proxy/ppapi_messages.h"
 #include "ppapi/proxy/ppb_message_loop_proxy.h"
 #include "ppapi/proxy/resource_reply_thread_registrar.h"
+#include "ppapi/proxy/udp_socket_filter.h"
 #include "ppapi/shared_impl/ppapi_constants.h"
 #include "ppapi/shared_impl/proxy_lock.h"
 #include "ppapi/thunk/enter.h"
 
 namespace ppapi {
 namespace proxy {
 
 // It performs necessary locking/unlocking of the proxy lock, and forwards all
 // messages to the underlying sender.
 class PluginGlobals::BrowserSender : public IPC::Sender {
@@ skipping 18 matching lines @@
 
  private:
   // Non-owning pointer.
   IPC::Sender* underlying_sender_;
 
   DISALLOW_COPY_AND_ASSIGN(BrowserSender);
 };
 
 PluginGlobals* PluginGlobals::plugin_globals_ = NULL;
 
-PluginGlobals::PluginGlobals()
+PluginGlobals::PluginGlobals(
+    const scoped_refptr<base::TaskRunner>& ipc_task_runner)
     : ppapi::PpapiGlobals(),
       plugin_proxy_delegate_(NULL),
       callback_tracker_(new CallbackTracker),
+      ipc_task_runner_(ipc_task_runner),
       resource_reply_thread_registrar_(
           new ResourceReplyThreadRegistrar(GetMainThreadMessageLoop())),
+      udp_socket_filter_(new UDPSocketFilter()),
       plugin_recently_active_(false),
       keepalive_throttle_interval_milliseconds_(
           ppapi::kKeepaliveThrottleIntervalDefaultMilliseconds),
       weak_factory_(this) {
   DCHECK(!plugin_globals_);
   plugin_globals_ = this;
 
   // ResourceTracker asserts that we have the lock when we add new resources,
   // so we lock when creating the MessageLoopResource even though there is no
   // chance of race conditions.
   ProxyAutoLock lock;
   loop_for_main_thread_ =
       new MessageLoopResource(MessageLoopResource::ForMainThread());
 }
 
-PluginGlobals::PluginGlobals(PerThreadForTest per_thread_for_test)
+PluginGlobals::PluginGlobals(
+    PerThreadForTest per_thread_for_test,
+    const scoped_refptr<base::TaskRunner>& ipc_task_runner)
     : ppapi::PpapiGlobals(per_thread_for_test),
       plugin_proxy_delegate_(NULL),
       callback_tracker_(new CallbackTracker),
+      ipc_task_runner_(ipc_task_runner),
       resource_reply_thread_registrar_(
           new ResourceReplyThreadRegistrar(GetMainThreadMessageLoop())),
       plugin_recently_active_(false),
       keepalive_throttle_interval_milliseconds_(
           kKeepaliveThrottleIntervalDefaultMilliseconds),
       weak_factory_(this) {
   DCHECK(!plugin_globals_);
 }
 
 PluginGlobals::~PluginGlobals() {
@@ skipping 140 matching lines @@
 void PluginGlobals::ResetPluginProxyDelegate() {
   DCHECK(plugin_proxy_delegate_);
   plugin_proxy_delegate_ = NULL;
   browser_sender_.reset();
 }
 
 MessageLoopResource* PluginGlobals::loop_for_main_thread() {
   return loop_for_main_thread_.get();
 }
 
+void PluginGlobals::RegisterResourceMessageFilters(
+    ppapi::proxy::PluginMessageFilter* plugin_filter) {
+  plugin_filter->AddResourceMessageFilter(udp_socket_filter_.get());
+}
+
 void PluginGlobals::set_keepalive_throttle_interval_milliseconds(unsigned i) {
   keepalive_throttle_interval_milliseconds_ = i;
 }
 
 bool PluginGlobals::IsPluginGlobals() const {
   return true;
 }
 
 void PluginGlobals::OnReleaseKeepaliveThrottle() {
   ppapi::ProxyLock::AssertAcquiredDebugOnly();
   plugin_recently_active_ = false;
 }
 
 }  // namespace proxy
 }  // namespace ppapi