| OLD | NEW |
| 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "content/browser/renderer_host/pepper/browser_ppapi_host_impl.h" | 5 #include "content/browser/renderer_host/pepper/browser_ppapi_host_impl.h" |
| 6 | 6 |
| 7 #include "content/browser/renderer_host/pepper/pepper_message_filter.h" | 7 #include "content/browser/renderer_host/pepper/pepper_message_filter.h" |
| 8 #include "content/browser/tracing/trace_message_filter.h" | 8 #include "content/browser/tracing/trace_message_filter.h" |
| 9 #include "content/common/pepper_renderer_instance_data.h" | 9 #include "content/common/pepper_renderer_instance_data.h" |
| 10 #include "content/public/browser/render_view_host.h" | |
| 11 #include "content/public/common/process_type.h" | 10 #include "content/public/common/process_type.h" |
| 12 #include "ipc/ipc_message_macros.h" | 11 #include "ipc/ipc_message_macros.h" |
| 12 #include "ppapi/proxy/ppapi_messages.h" |
| 13 | 13 |
| 14 namespace content { | 14 namespace content { |
| 15 | 15 |
| 16 // static | 16 // static |
| 17 BrowserPpapiHost* BrowserPpapiHost::CreateExternalPluginProcess( | 17 BrowserPpapiHost* BrowserPpapiHost::CreateExternalPluginProcess( |
| 18 IPC::Sender* sender, | 18 IPC::Sender* sender, |
| 19 ppapi::PpapiPermissions permissions, | 19 ppapi::PpapiPermissions permissions, |
| 20 base::ProcessHandle plugin_child_process, | 20 base::ProcessHandle plugin_child_process, |
| 21 IPC::ChannelProxy* channel, | 21 IPC::ChannelProxy* channel, |
| 22 int render_process_id, | 22 int render_process_id, |
| (...skipping 25 matching lines...) Expand all Loading... |
| 48 bool in_process, | 48 bool in_process, |
| 49 bool external_plugin) | 49 bool external_plugin) |
| 50 : ppapi_host_(new ppapi::host::PpapiHost(sender, permissions)), | 50 : ppapi_host_(new ppapi::host::PpapiHost(sender, permissions)), |
| 51 plugin_process_handle_(base::kNullProcessHandle), | 51 plugin_process_handle_(base::kNullProcessHandle), |
| 52 plugin_name_(plugin_name), | 52 plugin_name_(plugin_name), |
| 53 plugin_path_(plugin_path), | 53 plugin_path_(plugin_path), |
| 54 profile_data_directory_(profile_data_directory), | 54 profile_data_directory_(profile_data_directory), |
| 55 in_process_(in_process), | 55 in_process_(in_process), |
| 56 external_plugin_(external_plugin), | 56 external_plugin_(external_plugin), |
| 57 ssl_context_helper_(new SSLContextHelper()) { | 57 ssl_context_helper_(new SSLContextHelper()) { |
| 58 message_filter_ = new HostMessageFilter(ppapi_host_.get()); | 58 message_filter_ = new HostMessageFilter(ppapi_host_.get(), this); |
| 59 ppapi_host_->AddHostFactoryFilter(scoped_ptr<ppapi::host::HostFactory>( | 59 ppapi_host_->AddHostFactoryFilter(scoped_ptr<ppapi::host::HostFactory>( |
| 60 new ContentBrowserPepperHostFactory(this))); | 60 new ContentBrowserPepperHostFactory(this))); |
| 61 } | 61 } |
| 62 | 62 |
| 63 BrowserPpapiHostImpl::~BrowserPpapiHostImpl() { | 63 BrowserPpapiHostImpl::~BrowserPpapiHostImpl() { |
| 64 // Notify the filter so it won't foward messages to us. | 64 // Notify the filter so it won't foward messages to us. |
| 65 message_filter_->OnHostDestroyed(); | 65 message_filter_->OnHostDestroyed(); |
| 66 | 66 |
| 67 // Delete the host explicitly first. This shutdown will destroy the | 67 // Delete the host explicitly first. This shutdown will destroy the |
| 68 // resources, which may want to do cleanup in their destructors and expect | 68 // resources, which may want to do cleanup in their destructors and expect |
| (...skipping 50 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 119 return found->second.document_url; | 119 return found->second.document_url; |
| 120 } | 120 } |
| 121 | 121 |
| 122 GURL BrowserPpapiHostImpl::GetPluginURLForInstance(PP_Instance instance) { | 122 GURL BrowserPpapiHostImpl::GetPluginURLForInstance(PP_Instance instance) { |
| 123 InstanceMap::const_iterator found = instance_map_.find(instance); | 123 InstanceMap::const_iterator found = instance_map_.find(instance); |
| 124 if (found == instance_map_.end()) | 124 if (found == instance_map_.end()) |
| 125 return GURL(); | 125 return GURL(); |
| 126 return found->second.plugin_url; | 126 return found->second.plugin_url; |
| 127 } | 127 } |
| 128 | 128 |
| 129 void BrowserPpapiHostImpl::SetOnKeepaliveCallback( |
| 130 const BrowserPpapiHost::OnKeepaliveCallback& callback) { |
| 131 on_keepalive_callback_ = callback; |
| 132 } |
| 133 |
| 129 void BrowserPpapiHostImpl::AddInstance( | 134 void BrowserPpapiHostImpl::AddInstance( |
| 130 PP_Instance instance, | 135 PP_Instance instance, |
| 131 const PepperRendererInstanceData& instance_data) { | 136 const PepperRendererInstanceData& instance_data) { |
| 132 DCHECK(instance_map_.find(instance) == instance_map_.end()); | 137 DCHECK(instance_map_.find(instance) == instance_map_.end()); |
| 133 instance_map_[instance] = instance_data; | 138 instance_map_[instance] = instance_data; |
| 134 } | 139 } |
| 135 | 140 |
| 136 void BrowserPpapiHostImpl::DeleteInstance(PP_Instance instance) { | 141 void BrowserPpapiHostImpl::DeleteInstance(PP_Instance instance) { |
| 137 InstanceMap::iterator found = instance_map_.find(instance); | 142 InstanceMap::iterator found = instance_map_.find(instance); |
| 138 if (found == instance_map_.end()) { | 143 if (found == instance_map_.end()) { |
| 139 NOTREACHED(); | 144 NOTREACHED(); |
| 140 return; | 145 return; |
| 141 } | 146 } |
| 142 instance_map_.erase(found); | 147 instance_map_.erase(found); |
| 143 } | 148 } |
| 144 | 149 |
| 150 BrowserPpapiHostImpl::HostMessageFilter::HostMessageFilter( |
| 151 ppapi::host::PpapiHost* ppapi_host, |
| 152 BrowserPpapiHostImpl* browser_ppapi_host_impl) |
| 153 : ppapi_host_(ppapi_host), |
| 154 browser_ppapi_host_impl_(browser_ppapi_host_impl) { |
| 155 } |
| 156 |
| 145 bool BrowserPpapiHostImpl::HostMessageFilter::OnMessageReceived( | 157 bool BrowserPpapiHostImpl::HostMessageFilter::OnMessageReceived( |
| 146 const IPC::Message& msg) { | 158 const IPC::Message& msg) { |
| 147 // Don't forward messages if our owner object has been destroyed. | 159 // Don't forward messages if our owner object has been destroyed. |
| 148 if (!ppapi_host_) | 160 if (!ppapi_host_) |
| 149 return false; | 161 return false; |
| 150 | 162 |
| 151 /* TODO(brettw) when we add messages, here, the code should look like this: | |
| 152 bool handled = true; | 163 bool handled = true; |
| 153 IPC_BEGIN_MESSAGE_MAP(BrowserPpapiHostImpl, msg) | 164 IPC_BEGIN_MESSAGE_MAP(BrowserPpapiHostImpl::HostMessageFilter, msg) |
| 154 // Add necessary message handlers here. | 165 // Add necessary message handlers here. |
| 166 IPC_MESSAGE_HANDLER(PpapiHostMsg_Keepalive, OnKeepalive) |
| 155 IPC_MESSAGE_UNHANDLED(handled = ppapi_host_->OnMessageReceived(msg)) | 167 IPC_MESSAGE_UNHANDLED(handled = ppapi_host_->OnMessageReceived(msg)) |
| 156 IPC_END_MESSAGE_MAP(); | 168 IPC_END_MESSAGE_MAP(); |
| 157 return handled; | 169 return handled; |
| 158 */ | |
| 159 return ppapi_host_->OnMessageReceived(msg); | |
| 160 } | 170 } |
| 161 | 171 |
| 162 void BrowserPpapiHostImpl::HostMessageFilter::OnHostDestroyed() { | 172 void BrowserPpapiHostImpl::HostMessageFilter::OnHostDestroyed() { |
| 163 DCHECK(ppapi_host_); | 173 DCHECK(ppapi_host_); |
| 164 ppapi_host_ = NULL; | 174 ppapi_host_ = NULL; |
| 175 browser_ppapi_host_impl_ = NULL; |
| 176 } |
| 177 |
| 178 BrowserPpapiHostImpl::HostMessageFilter::~HostMessageFilter() { |
| 179 } |
| 180 |
| 181 void BrowserPpapiHostImpl::HostMessageFilter::OnKeepalive() { |
| 182 if (browser_ppapi_host_impl_) |
| 183 browser_ppapi_host_impl_->OnKeepalive(); |
| 184 } |
| 185 |
| 186 void BrowserPpapiHostImpl::OnKeepalive() { |
| 187 // An instance has been active. The on_keepalive_callback_ will be |
| 188 // used to permit the content embedder to handle this, e.g. by tracking |
| 189 // activity and shutting down processes that go idle. |
| 190 // |
| 191 // Currently embedders do not need to distinguish between instances having |
| 192 // different idle state, and thus this implementation handles all instances |
| 193 // for this module together. |
| 194 |
| 195 if (on_keepalive_callback_.is_null()) |
| 196 return; |
| 197 |
| 198 BrowserPpapiHost::OnKeepaliveInstanceData |
| 199 instance_data(instance_map_.size()); |
| 200 |
| 201 InstanceMap::iterator instance = instance_map_.begin(); |
| 202 int i = 0; |
| 203 while (instance != instance_map_.end()) { |
| 204 instance_data[i].render_process_id = instance->second.render_process_id; |
| 205 instance_data[i].render_view_id = instance->second.render_view_id; |
| 206 instance_data[i].document_url = instance->second.document_url; |
| 207 ++instance; |
| 208 ++i; |
| 209 } |
| 210 on_keepalive_callback_.Run(instance_data, profile_data_directory_); |
| 165 } | 211 } |
| 166 | 212 |
| 167 } // namespace content | 213 } // namespace content |
| OLD | NEW |