Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(16)

Unified Diff: chrome/browser/renderer_host/render_widget_helper.cc

Issue 6532073: Move core pieces of browser\renderer_host to src\content. (Closed) Base URL: svn://chrome-svn/chrome/trunk/src/
Patch Set: '' Created 9 years, 10 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
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

Powered by Google App Engine
This is Rietveld 408576698