Delete background tab IOSurfaces on Mac.

content/browser/renderer_host/render_widget_helper.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/browser/renderer_host/render_widget_helper.h"
 
 #include "base/bind.h"
 #include "base/bind_helpers.h"
 #include "base/eintr_wrapper.h"
+#include "base/lazy_instance.h"
 #include "base/threading/thread.h"
 #include "content/browser/gpu/gpu_surface_tracker.h"
 #include "content/browser/renderer_host/render_process_host_impl.h"
 #include "content/browser/renderer_host/render_view_host_impl.h"
 #include "content/browser/renderer_host/resource_dispatcher_host_impl.h"
 #include "content/common/view_messages.h"
-#include "content/public/browser/browser_thread.h"
 
 using content::BrowserThread;
 using content::RenderViewHostImpl;
 using content::ResourceDispatcherHostImpl;
 
-// A helper used with DidReceiveUpdateMsg that we hold a pointer to in
+namespace {
+
+typedef std::map<int, RenderWidgetHelper*> WidgetHelperMap;
+base::LazyInstance<WidgetHelperMap> g_widget_helpers =
+    LAZY_INSTANCE_INITIALIZER;
+
+void AddWidgetHelper(int render_process_id,
+                     const scoped_refptr<RenderWidgetHelper>& widget_helper) {
+  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
+  // We don't care if RenderWidgetHelpers overwrite an existing process_id. Just
+  // want this to be up to date.
+  g_widget_helpers.Get()[render_process_id] = widget_helper.get();
+}
+
+}  // namespace
+
+// A helper used with DidReceiveBackingStoreMsg that we hold a pointer to in
 // pending_paints_.
-class RenderWidgetHelper::UpdateMsgProxy {
+class RenderWidgetHelper::BackingStoreMsgProxy {
  public:
-  UpdateMsgProxy(RenderWidgetHelper* h, const IPC::Message& m);
-  ~UpdateMsgProxy();
+  BackingStoreMsgProxy(RenderWidgetHelper* h, const IPC::Message& m);
+  ~BackingStoreMsgProxy();
   void Run();
   void Cancel() { cancelled_ = true; }
 
   const IPC::Message& message() const { return message_; }
 
  private:
   scoped_refptr<RenderWidgetHelper> helper_;
   IPC::Message message_;
   bool cancelled_;  // If true, then the message will not be dispatched.
 
-  DISALLOW_COPY_AND_ASSIGN(UpdateMsgProxy);
+  DISALLOW_COPY_AND_ASSIGN(BackingStoreMsgProxy);
 };
 
-RenderWidgetHelper::UpdateMsgProxy::UpdateMsgProxy(
+RenderWidgetHelper::BackingStoreMsgProxy::BackingStoreMsgProxy(
     RenderWidgetHelper* h, const IPC::Message& m)
     : helper_(h),
       message_(m),
       cancelled_(false) {
 }
 
-RenderWidgetHelper::UpdateMsgProxy::~UpdateMsgProxy() {
+RenderWidgetHelper::BackingStoreMsgProxy::~BackingStoreMsgProxy() {
   // If the paint message was never dispatched, then we need to let the
   // helper know that we are going away.
   if (!cancelled_ && helper_)
-    helper_->OnDiscardUpdateMsg(this);
+    helper_->OnDiscardBackingStoreMsg(this);
 }
 
-void RenderWidgetHelper::UpdateMsgProxy::Run() {
+void RenderWidgetHelper::BackingStoreMsgProxy::Run() {
   if (!cancelled_) {
-    helper_->OnDispatchUpdateMsg(this);
+    helper_->OnDispatchBackingStoreMsg(this);
     helper_ = NULL;
   }
 }
 
 RenderWidgetHelper::RenderWidgetHelper()
     : render_process_id_(-1),
 #if defined(OS_WIN)
       event_(CreateEvent(NULL, FALSE /* auto-reset */, FALSE, NULL)),
 #elif defined(OS_POSIX)
       event_(false /* auto-reset */, false),
 #endif
       resource_dispatcher_host_(NULL) {
 }
 
 RenderWidgetHelper::~RenderWidgetHelper() {
+  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
+  g_widget_helpers.Get().erase(render_process_id_);
+
   // The elements of pending_paints_ each hold an owning reference back to this
   // object, so we should not be destroyed unless pending_paints_ is empty!
   DCHECK(pending_paints_.empty());
 
 #if defined(OS_MACOSX)
   ClearAllocatedDIBs();
 #endif
 }
 
 void RenderWidgetHelper::Init(
     int render_process_id,
     ResourceDispatcherHostImpl* resource_dispatcher_host) {
   render_process_id_ = render_process_id;
   resource_dispatcher_host_ = resource_dispatcher_host;
+
+  BrowserThread::PostTask(
+      BrowserThread::IO, FROM_HERE,
+      base::Bind(&AddWidgetHelper,
+                 render_process_id_, make_scoped_refptr(this)));
 }
 
 int RenderWidgetHelper::GetNextRoutingID() {
   return next_routing_id_.GetNext() + 1;
 }
 
+// static
+RenderWidgetHelper* RenderWidgetHelper::FromProcessHostID(
+    int render_process_host_id) {
+  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
+  WidgetHelperMap::const_iterator ci = g_widget_helpers.Get().find(
+      render_process_host_id);
+  return (ci == g_widget_helpers.Get().end())? NULL : ci->second;
+}
+
 void RenderWidgetHelper::CancelResourceRequests(int render_widget_id) {
   if (render_process_id_ == -1)
     return;
 
   BrowserThread::PostTask(
       BrowserThread::IO, FROM_HERE,
       base::Bind(&RenderWidgetHelper::OnCancelResourceRequests,
                  this,
                  render_widget_id));
 }
 
 void RenderWidgetHelper::SimulateSwapOutACK(
     const ViewMsg_SwapOut_Params& params) {
   BrowserThread::PostTask(
       BrowserThread::IO, FROM_HERE,
       base::Bind(&RenderWidgetHelper::OnSimulateSwapOutACK,
                  this,
                  params));
 }
 
-bool RenderWidgetHelper::WaitForUpdateMsg(int render_widget_id,
-                                          const base::TimeDelta& max_delay,
-                                          IPC::Message* msg) {
+bool RenderWidgetHelper::WaitForBackingStoreMsg(
+    int render_widget_id,
+    const base::TimeDelta& max_delay,
+    IPC::Message* msg) {
   base::TimeTicks time_start = base::TimeTicks::Now();
 
   for (;;) {
-    UpdateMsgProxy* proxy = NULL;
+    BackingStoreMsgProxy* proxy = NULL;
     {
       base::AutoLock lock(pending_paints_lock_);
 
-      UpdateMsgProxyMap::iterator it = pending_paints_.find(render_widget_id);
+      BackingStoreMsgProxyMap::iterator it =
+          pending_paints_.find(render_widget_id);
       if (it != pending_paints_.end()) {
-        UpdateMsgProxyQueue &queue = it->second;
+        BackingStoreMsgProxyQueue &queue = it->second;
         DCHECK(!queue.empty());
         proxy = queue.front();
 
         // Flag the proxy as cancelled so that when it is run as a task it will
         // do nothing.
         proxy->Cancel();
 
         queue.pop_front();
         if (queue.empty())
           pending_paints_.erase(it);
@@ skipping 11 matching lines @@
         max_delay - (base::TimeTicks::Now() - time_start);
     if (max_sleep_time <= base::TimeDelta::FromMilliseconds(0))
       break;
 
     event_.TimedWait(max_sleep_time);
   }
 
   return false;
 }
 
-void RenderWidgetHelper::DidReceiveUpdateMsg(const IPC::Message& msg) {
+void RenderWidgetHelper::DidReceiveBackingStoreMsg(const IPC::Message& msg) {
   int render_widget_id = msg.routing_id();
 
-  UpdateMsgProxy* proxy = new UpdateMsgProxy(this, msg);
+  BackingStoreMsgProxy* proxy = new BackingStoreMsgProxy(this, msg);
   {
     base::AutoLock lock(pending_paints_lock_);
 
     pending_paints_[render_widget_id].push_back(proxy);
   }
 
   // Notify anyone waiting on the UI thread that there is a new entry in the
   // proxy map.  If they don't find the entry they are looking for, then they
   // will just continue waiting.
   event_.Signal();
 
   BrowserThread::PostTask(BrowserThread::UI, FROM_HERE,
-                          base::Bind(&UpdateMsgProxy::Run, base::Owned(proxy)));
+      base::Bind(&BackingStoreMsgProxy::Run, base::Owned(proxy)));
 }
 
-void RenderWidgetHelper::OnDiscardUpdateMsg(UpdateMsgProxy* proxy) {
+void RenderWidgetHelper::OnDiscardBackingStoreMsg(BackingStoreMsgProxy* proxy) {
   const IPC::Message& msg = proxy->message();
 
   // Remove the proxy from the map now that we are going to handle it normally.
   {
     base::AutoLock lock(pending_paints_lock_);
 
-    UpdateMsgProxyMap::iterator it = pending_paints_.find(msg.routing_id());
+    BackingStoreMsgProxyMap::iterator it =
+        pending_paints_.find(msg.routing_id());
     DCHECK(it != pending_paints_.end());
-    UpdateMsgProxyQueue &queue = it->second;
+    BackingStoreMsgProxyQueue &queue = it->second;
     DCHECK(queue.front() == proxy);
 
     queue.pop_front();
     if (queue.empty())
       pending_paints_.erase(it);
   }
 }
 
-void RenderWidgetHelper::OnDispatchUpdateMsg(UpdateMsgProxy* proxy) {
-  OnDiscardUpdateMsg(proxy);
+void RenderWidgetHelper::OnDispatchBackingStoreMsg(
+    BackingStoreMsgProxy* proxy) {
+  OnDiscardBackingStoreMsg(proxy);
 
   // It is reasonable for the host to no longer exist.
   content::RenderProcessHost* host =
       content::RenderProcessHost::FromID(render_process_id_);
   if (host)
     host->OnMessageReceived(proxy->message());
 }
 
 void RenderWidgetHelper::OnCancelResourceRequests(
     int render_widget_id) {
@@ skipping 150 matching lines @@
 void RenderWidgetHelper::ClearAllocatedDIBs() {
   for (std::map<TransportDIB::Id, int>::iterator
        i = allocated_dibs_.begin(); i != allocated_dibs_.end(); ++i) {
     if (HANDLE_EINTR(close(i->second)) < 0)
       PLOG(ERROR) << "close: " << i->first;
   }
 
   allocated_dibs_.clear();
 }
 #endif