| 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
|
|
|