Index: content/browser/renderer_host/render_widget_helper.cc |
diff --git a/content/browser/renderer_host/render_widget_helper.cc b/content/browser/renderer_host/render_widget_helper.cc |
index 545b75bf623ea639687e3e20bfd97fa4103f724e..1f88835cd275d8fe60cc96cbc4735ac4ed5025ee 100644 |
--- a/content/browser/renderer_host/render_widget_helper.cc |
+++ b/content/browser/renderer_host/render_widget_helper.cc |
@@ -10,6 +10,7 @@ |
#include "base/posix/eintr_wrapper.h" |
#include "base/threading/thread.h" |
#include "base/threading/thread_restrictions.h" |
+#include "content/browser/gpu/gpu_process_host_ui_shim.h" |
#include "content/browser/gpu/gpu_surface_tracker.h" |
#include "content/browser/loader/resource_dispatcher_host_impl.h" |
#include "content/browser/renderer_host/render_process_host_impl.h" |
@@ -34,53 +35,8 @@ void AddWidgetHelper(int render_process_id, |
} // namespace |
-// A helper used with DidReceiveBackingStoreMsg that we hold a pointer to in |
-// pending_paints_. |
-class RenderWidgetHelper::BackingStoreMsgProxy { |
- public: |
- 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(BackingStoreMsgProxy); |
-}; |
- |
-RenderWidgetHelper::BackingStoreMsgProxy::BackingStoreMsgProxy( |
- RenderWidgetHelper* h, const IPC::Message& m) |
- : helper_(h), |
- message_(m), |
- cancelled_(false) { |
-} |
- |
-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_.get()) |
- helper_->OnDiscardBackingStoreMsg(this); |
-} |
- |
-void RenderWidgetHelper::BackingStoreMsgProxy::Run() { |
- if (!cancelled_) { |
- 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) { |
} |
@@ -93,10 +49,6 @@ RenderWidgetHelper::~RenderWidgetHelper() { |
if (it != widget_map.end() && it->second == this) |
widget_map.erase(it); |
- // 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_POSIX) && !defined(OS_ANDROID) |
ClearAllocatedDIBs(); |
#endif |
@@ -146,51 +98,6 @@ void RenderWidgetHelper::ResumeResponseDeferredAtStart( |
request_id)); |
} |
-bool RenderWidgetHelper::WaitForBackingStoreMsg( |
- int render_widget_id, const base::TimeDelta& max_delay, IPC::Message* msg) { |
- base::TimeTicks time_start = base::TimeTicks::Now(); |
- |
- for (;;) { |
- BackingStoreMsgProxy* proxy = NULL; |
- { |
- base::AutoLock lock(pending_paints_lock_); |
- |
- BackingStoreMsgProxyMap::iterator it = |
- pending_paints_.find(render_widget_id); |
- if (it != pending_paints_.end()) { |
- 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); |
- } |
- } |
- |
- if (proxy) { |
- *msg = proxy->message(); |
- DCHECK(msg->routing_id() == render_widget_id); |
- return true; |
- } |
- |
- // Calculate the maximum amount of time that we are willing to sleep. |
- base::TimeDelta max_sleep_time = |
- max_delay - (base::TimeTicks::Now() - time_start); |
- if (max_sleep_time <= base::TimeDelta::FromMilliseconds(0)) |
- break; |
- |
- base::ThreadRestrictions::ScopedAllowWait allow_wait; |
- event_.TimedWait(max_sleep_time); |
- } |
- |
- return false; |
-} |
- |
void RenderWidgetHelper::ResumeRequestsForView(int route_id) { |
// We only need to resume blocked requests if we used a valid route_id. |
// See CreateNewWindow. |
@@ -202,54 +109,6 @@ void RenderWidgetHelper::ResumeRequestsForView(int route_id) { |
} |
} |
-void RenderWidgetHelper::DidReceiveBackingStoreMsg(const IPC::Message& msg) { |
- int render_widget_id = msg.routing_id(); |
- |
- 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(&BackingStoreMsgProxy::Run, base::Owned(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_); |
- |
- BackingStoreMsgProxyMap::iterator it = |
- pending_paints_.find(msg.routing_id()); |
- DCHECK(it != pending_paints_.end()); |
- BackingStoreMsgProxyQueue &queue = it->second; |
- DCHECK(queue.front() == proxy); |
- |
- queue.pop_front(); |
- if (queue.empty()) |
- pending_paints_.erase(it); |
- } |
-} |
- |
-void RenderWidgetHelper::OnDispatchBackingStoreMsg( |
- BackingStoreMsgProxy* proxy) { |
- OnDiscardBackingStoreMsg(proxy); |
- |
- // It is reasonable for the host to no longer exist. |
- RenderProcessHost* host = RenderProcessHost::FromID(render_process_id_); |
- if (host) |
- host->OnMessageReceived(proxy->message()); |
-} |
- |
void RenderWidgetHelper::OnResumeDeferredNavigation( |
const GlobalRequestID& request_id) { |
resource_dispatcher_host_->ResumeDeferredNavigation(request_id); |