ozone: ClientPixmapManager passes VGEM fd from browser to renderer.

content/child/child_thread_impl.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/child_thread_impl.h"
 
 #include <signal.h>
 
 #include <string>
 
@@ skipping 50 matching lines @@
 #include "ipc/mojo/ipc_channel_mojo.h"
 
 #if defined(TCMALLOC_TRACE_MEMORY_SUPPORTED)
 #include "third_party/tcmalloc/chromium/src/gperftools/heap-profiler.h"
 #endif
 
 #if defined(OS_MACOSX)
 #include "content/child/child_io_surface_manager_mac.h"
 #endif
 
+#if defined(USE_OZONE)
+#include "ui/ozone/public/client_native_pixmap_factory.h"
+#endif
+
 #if defined(OS_WIN)
 #include "ipc/attachment_broker_unprivileged_win.h"
 #endif
 
 using tracked_objects::ThreadData;
 
 namespace content {
 namespace {
 
 // How long to wait for a connection to the browser process before giving up.
@@ skipping 104 matching lines @@
 
  protected:
   ~IOSurfaceManagerFilter() override {}
 
   void OnSetIOSurfaceManagerToken(const IOSurfaceManagerToken& token) {
     ChildIOSurfaceManager::GetInstance()->set_token(token);
   }
 };
 #endif
 
+#if defined(USE_OZONE)
+class ClientNativePixmapFactoryFilter : public IPC::MessageFilter {
+ public:
+  // Overridden from IPC::MessageFilter:
+  bool OnMessageReceived(const IPC::Message& message) override {
+    bool handled = true;
+    IPC_BEGIN_MESSAGE_MAP(ClientNativePixmapFactoryFilter, message)
+      IPC_MESSAGE_HANDLER(ChildProcessMsg_InitializeClientNativePixmapFactory,
+                          OnInitializeClientNativePixmapFactory)
+      IPC_MESSAGE_UNHANDLED(handled = false)
+    IPC_END_MESSAGE_MAP()
+    return handled;
+  }
+
+ protected:
+  ~ClientNativePixmapFactoryFilter() override {}
+
+  void OnInitializeClientNativePixmapFactory(
+      const base::FileDescriptor& device_fd) {
+    ui::ClientNativePixmapFactory::GetInstance()->Initialize(

[jam, 2015/08/24 15:00:32]

do you specifically want this to happen on the IO thread? is the class you're
calling thread safe?

i.e. why are you using a filter?

+        base::ScopedFD(device_fd.fd));
+  }
+};
+#endif
+
 #if defined(OS_ANDROID)
 // A class that allows for triggering a clean shutdown from another
 // thread through draining the main thread's msg loop.
 class QuitClosure {
  public:
   QuitClosure();
   ~QuitClosure();
 
   void BindToMainThread();
   void PostQuitFromNonMainThread();
@@ skipping 216 matching lines @@
   // Check that --process-type is specified so we don't do this in unit tests
   // and single-process mode.
   if (base::CommandLine::ForCurrentProcess()->HasSwitch(switches::kProcessType))
     channel_->AddFilter(new SuicideOnChannelErrorFilter());
 #endif
 
 #if defined(OS_MACOSX)
   channel_->AddFilter(new IOSurfaceManagerFilter());
 #endif
 
+#if defined(USE_OZONE)
+  channel_->AddFilter(new ClientNativePixmapFactoryFilter());
+#endif
+
   // Add filters passed here via options.
   for (auto startup_filter : options.startup_filters) {
     channel_->AddFilter(startup_filter);
   }
 
   ConnectChannel(options.use_mojo_channel);
   if (attachment_broker_)
     attachment_broker_->DesignateBrokerCommunicationChannel(channel_.get());
 
   int connection_timeout = kConnectionTimeoutS;
@@ skipping 266 matching lines @@
 
 void ChildThreadImpl::OnProcessBackgrounded(bool background) {
   // Set timer slack to maximum on main thread when in background.
   base::TimerSlack timer_slack = base::TIMER_SLACK_NONE;
   if (background)
     timer_slack = base::TIMER_SLACK_MAXIMUM;
   base::MessageLoop::current()->SetTimerSlack(timer_slack);
 }
 
 }  // namespace content