Index: chrome/browser/renderer_host/render_widget_helper.cc |
=================================================================== |
--- chrome/browser/renderer_host/render_widget_helper.cc (revision 75488) |
+++ chrome/browser/renderer_host/render_widget_helper.cc (working copy) |
@@ -1,335 +0,0 @@ |
-// Copyright (c) 2010 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 "chrome/browser/renderer_host/render_widget_helper.h" |
- |
-#include "base/eintr_wrapper.h" |
-#include "base/threading/thread.h" |
-#include "chrome/browser/browser_thread.h" |
-#include "chrome/browser/renderer_host/render_process_host.h" |
-#include "chrome/browser/renderer_host/render_view_host.h" |
-#include "chrome/browser/renderer_host/resource_dispatcher_host.h" |
-#include "chrome/common/render_messages_params.h" |
- |
-// A Task used with InvokeLater that we hold a pointer to in pending_paints_. |
-// Instances are deleted by MessageLoop after it calls their Run method. |
-class RenderWidgetHelper::UpdateMsgProxy : public Task { |
- public: |
- UpdateMsgProxy(RenderWidgetHelper* h, const IPC::Message& m) |
- : helper(h), |
- message(m), |
- cancelled(false) { |
- } |
- |
- ~UpdateMsgProxy() { |
- // 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); |
- } |
- |
- virtual void Run() { |
- if (!cancelled) { |
- helper->OnDispatchUpdateMsg(this); |
- helper = NULL; |
- } |
- } |
- |
- scoped_refptr<RenderWidgetHelper> helper; |
- IPC::Message message; |
- bool cancelled; // If true, then the message will not be dispatched. |
- |
- DISALLOW_COPY_AND_ASSIGN(UpdateMsgProxy); |
-}; |
- |
-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() { |
- // 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, |
- ResourceDispatcherHost* resource_dispatcher_host) { |
- render_process_id_ = render_process_id; |
- resource_dispatcher_host_ = resource_dispatcher_host; |
-} |
- |
-int RenderWidgetHelper::GetNextRoutingID() { |
- return next_routing_id_.GetNext() + 1; |
-} |
- |
-void RenderWidgetHelper::CancelResourceRequests(int render_widget_id) { |
- if (render_process_id_ == -1) |
- return; |
- |
- BrowserThread::PostTask( |
- BrowserThread::IO, FROM_HERE, |
- NewRunnableMethod(this, |
- &RenderWidgetHelper::OnCancelResourceRequests, |
- render_widget_id)); |
-} |
- |
-void RenderWidgetHelper::CrossSiteClosePageACK( |
- const ViewMsg_ClosePage_Params& params) { |
- BrowserThread::PostTask( |
- BrowserThread::IO, FROM_HERE, |
- NewRunnableMethod(this, |
- &RenderWidgetHelper::OnCrossSiteClosePageACK, |
- params)); |
-} |
- |
-bool RenderWidgetHelper::WaitForUpdateMsg(int render_widget_id, |
- const base::TimeDelta& max_delay, |
- IPC::Message* msg) { |
- base::TimeTicks time_start = base::TimeTicks::Now(); |
- |
- for (;;) { |
- UpdateMsgProxy* proxy = NULL; |
- { |
- base::AutoLock lock(pending_paints_lock_); |
- |
- UpdateMsgProxyMap::iterator it = pending_paints_.find(render_widget_id); |
- if (it != pending_paints_.end()) { |
- proxy = it->second; |
- |
- // Flag the proxy as cancelled so that when it is run as a task it will |
- // do nothing. |
- proxy->cancelled = true; |
- |
- 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; |
- |
- event_.TimedWait(max_sleep_time); |
- } |
- |
- return false; |
-} |
- |
-void RenderWidgetHelper::DidReceiveUpdateMsg(const IPC::Message& msg) { |
- int render_widget_id = msg.routing_id(); |
- |
- UpdateMsgProxy* proxy = NULL; |
- { |
- base::AutoLock lock(pending_paints_lock_); |
- |
- // Visual Studio 2010 has problems converting NULL to the null pointer for |
- // std::pair. See http://connect.microsoft.com/VisualStudio/feedback/details/520043/error-converting-from-null-to-a-pointer-type-in-std-pair |
- // It will work if we pass nullptr. |
-#if defined(_MSC_VER) && _MSC_VER >= 1600 |
- RenderWidgetHelper::UpdateMsgProxy* null_proxy = nullptr; |
-#else |
- RenderWidgetHelper::UpdateMsgProxy* null_proxy = NULL; |
-#endif |
- UpdateMsgProxyMap::value_type new_value(render_widget_id, null_proxy); |
- |
- // We expect only a single PaintRect message at a time. Optimize for the |
- // case that we don't already have an entry by using the 'insert' method. |
- std::pair<UpdateMsgProxyMap::iterator, bool> result = |
- pending_paints_.insert(new_value); |
- if (!result.second) { |
- NOTREACHED() << "Unexpected PaintRect message!"; |
- return; |
- } |
- |
- result.first->second = (proxy = new UpdateMsgProxy(this, msg)); |
- } |
- |
- // 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(); |
- |
- // The proxy will be deleted when it is run as a task. |
- BrowserThread::PostTask(BrowserThread::UI, FROM_HERE, proxy); |
-} |
- |
-void RenderWidgetHelper::OnDiscardUpdateMsg(UpdateMsgProxy* 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()); |
- DCHECK(it != pending_paints_.end()); |
- DCHECK(it->second == proxy); |
- |
- pending_paints_.erase(it); |
- } |
-} |
- |
-void RenderWidgetHelper::OnDispatchUpdateMsg(UpdateMsgProxy* proxy) { |
- OnDiscardUpdateMsg(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::OnCancelResourceRequests( |
- int render_widget_id) { |
- resource_dispatcher_host_->CancelRequestsForRoute( |
- render_process_id_, render_widget_id); |
-} |
- |
-void RenderWidgetHelper::OnCrossSiteClosePageACK( |
- const ViewMsg_ClosePage_Params& params) { |
- resource_dispatcher_host_->OnClosePageACK(params); |
-} |
- |
-void RenderWidgetHelper::CreateNewWindow( |
- const ViewHostMsg_CreateWindow_Params& params, |
- base::ProcessHandle render_process, |
- int* route_id) { |
- *route_id = GetNextRoutingID(); |
- // Block resource requests until the view is created, since the HWND might be |
- // needed if a response ends up creating a plugin. |
- resource_dispatcher_host_->BlockRequestsForRoute( |
- render_process_id_, *route_id); |
- |
- BrowserThread::PostTask( |
- BrowserThread::UI, FROM_HERE, |
- NewRunnableMethod( |
- this, &RenderWidgetHelper::OnCreateWindowOnUI, params, *route_id)); |
-} |
- |
-void RenderWidgetHelper::OnCreateWindowOnUI( |
- const ViewHostMsg_CreateWindow_Params& params, |
- int route_id) { |
- RenderViewHost* host = |
- RenderViewHost::FromID(render_process_id_, params.opener_id); |
- if (host) |
- host->CreateNewWindow(route_id, params); |
- |
- BrowserThread::PostTask( |
- BrowserThread::IO, FROM_HERE, |
- NewRunnableMethod(this, &RenderWidgetHelper::OnCreateWindowOnIO, |
- route_id)); |
-} |
- |
-void RenderWidgetHelper::OnCreateWindowOnIO(int route_id) { |
- resource_dispatcher_host_->ResumeBlockedRequestsForRoute( |
- render_process_id_, route_id); |
-} |
- |
-void RenderWidgetHelper::CreateNewWidget(int opener_id, |
- WebKit::WebPopupType popup_type, |
- int* route_id) { |
- *route_id = GetNextRoutingID(); |
- BrowserThread::PostTask( |
- BrowserThread::UI, FROM_HERE, |
- NewRunnableMethod( |
- this, &RenderWidgetHelper::OnCreateWidgetOnUI, opener_id, *route_id, |
- popup_type)); |
-} |
- |
-void RenderWidgetHelper::CreateNewFullscreenWidget(int opener_id, |
- int* route_id) { |
- *route_id = GetNextRoutingID(); |
- BrowserThread::PostTask( |
- BrowserThread::UI, FROM_HERE, |
- NewRunnableMethod( |
- this, &RenderWidgetHelper::OnCreateFullscreenWidgetOnUI, |
- opener_id, *route_id)); |
-} |
- |
-void RenderWidgetHelper::OnCreateWidgetOnUI( |
- int opener_id, int route_id, WebKit::WebPopupType popup_type) { |
- RenderViewHost* host = RenderViewHost::FromID(render_process_id_, opener_id); |
- if (host) |
- host->CreateNewWidget(route_id, popup_type); |
-} |
- |
-void RenderWidgetHelper::OnCreateFullscreenWidgetOnUI(int opener_id, |
- int route_id) { |
- RenderViewHost* host = RenderViewHost::FromID(render_process_id_, opener_id); |
- if (host) |
- host->CreateNewFullscreenWidget(route_id); |
-} |
- |
-#if defined(OS_MACOSX) |
-TransportDIB* RenderWidgetHelper::MapTransportDIB(TransportDIB::Id dib_id) { |
- base::AutoLock locked(allocated_dibs_lock_); |
- |
- const std::map<TransportDIB::Id, int>::iterator |
- i = allocated_dibs_.find(dib_id); |
- if (i == allocated_dibs_.end()) |
- return NULL; |
- |
- base::FileDescriptor fd(dup(i->second), true); |
- return TransportDIB::Map(fd); |
-} |
- |
-void RenderWidgetHelper::AllocTransportDIB( |
- size_t size, bool cache_in_browser, TransportDIB::Handle* result) { |
- scoped_ptr<base::SharedMemory> shared_memory(new base::SharedMemory()); |
- if (!shared_memory->CreateAnonymous(size)) { |
- result->fd = -1; |
- result->auto_close = false; |
- return; |
- } |
- |
- shared_memory->GiveToProcess(0 /* pid, not needed */, result); |
- |
- if (cache_in_browser) { |
- // Keep a copy of the file descriptor around |
- base::AutoLock locked(allocated_dibs_lock_); |
- allocated_dibs_[shared_memory->id()] = dup(result->fd); |
- } |
-} |
- |
-void RenderWidgetHelper::FreeTransportDIB(TransportDIB::Id dib_id) { |
- base::AutoLock locked(allocated_dibs_lock_); |
- |
- const std::map<TransportDIB::Id, int>::iterator |
- i = allocated_dibs_.find(dib_id); |
- |
- if (i != allocated_dibs_.end()) { |
- if (HANDLE_EINTR(close(i->second)) < 0) |
- PLOG(ERROR) << "close"; |
- allocated_dibs_.erase(i); |
- } else { |
- DLOG(WARNING) << "Renderer asked us to free unknown transport DIB"; |
- } |
-} |
- |
-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 |