Plugin Power Saver: Throttled Plugins should block TCPSocket reads.

content/browser/renderer_host/pepper/browser_ppapi_host_impl.cc

 // Copyright (c) 2012 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 "content/browser/renderer_host/pepper/browser_ppapi_host_impl.h"
 
 #include "base/metrics/sparse_histogram.h"
 #include "content/browser/renderer_host/pepper/pepper_message_filter.h"
 #include "content/browser/tracing/trace_message_filter.h"
 #include "content/common/pepper_renderer_instance_data.h"
@@ skipping 81 matching lines @@
     PP_Instance instance,
     int* render_process_id,
     int* render_frame_id) const {
   InstanceMap::const_iterator found = instance_map_.find(instance);
   if (found == instance_map_.end()) {
     *render_process_id = 0;
     *render_frame_id = 0;
     return false;
   }
 
-  *render_process_id = found->second.render_process_id;
-  *render_frame_id = found->second.render_frame_id;
+  *render_process_id = found->second.renderer_data.render_process_id;
+  *render_frame_id = found->second.renderer_data.render_frame_id;
   return true;
 }
 
 const std::string& BrowserPpapiHostImpl::GetPluginName() {
   return plugin_name_;
 }
 
 const base::FilePath& BrowserPpapiHostImpl::GetPluginPath() {
   return plugin_path_;
 }
 
 const base::FilePath& BrowserPpapiHostImpl::GetProfileDataDirectory() {
   return profile_data_directory_;
 }
 
 GURL BrowserPpapiHostImpl::GetDocumentURLForInstance(PP_Instance instance) {
   InstanceMap::const_iterator found = instance_map_.find(instance);
   if (found == instance_map_.end())
     return GURL();
-  return found->second.document_url;
+  return found->second.renderer_data.document_url;
 }
 
 GURL BrowserPpapiHostImpl::GetPluginURLForInstance(PP_Instance instance) {
   InstanceMap::const_iterator found = instance_map_.find(instance);
   if (found == instance_map_.end())
     return GURL();
-  return found->second.plugin_url;
+  return found->second.renderer_data.plugin_url;
 }
 
 void BrowserPpapiHostImpl::SetOnKeepaliveCallback(
     const BrowserPpapiHost::OnKeepaliveCallback& callback) {
   on_keepalive_callback_ = callback;
 }
 
 void BrowserPpapiHostImpl::AddInstance(
     PP_Instance instance,
     const PepperRendererInstanceData& instance_data) {
   DCHECK(instance_map_.find(instance) == instance_map_.end());
-  instance_map_[instance] = instance_data;
+  instance_map_[instance].renderer_data = instance_data;
+
+  instance_observers_map_.set(
+      instance, make_scoped_ptr(new ObserverList<InstanceObserver>()));
 }
 
 void BrowserPpapiHostImpl::DeleteInstance(PP_Instance instance) {
   InstanceMap::iterator found = instance_map_.find(instance);
   if (found == instance_map_.end()) {
     NOTREACHED();
     return;
   }
   instance_map_.erase(found);
+
+  DCHECK(instance_observers_map_.get(instance));
+  instance_observers_map_.erase(instance);
+}
+
+void BrowserPpapiHostImpl::AddInstanceObserver(PP_Instance instance,
+                                               InstanceObserver* observer) {
+  instance_observers_map_.get(instance)->AddObserver(observer);
+}
+
+void BrowserPpapiHostImpl::RemoveInstanceObserver(PP_Instance instance,
+                                                  InstanceObserver* observer) {
+  auto* instance_observer = instance_observers_map_.get(instance);
+  if (instance_observer != nullptr)
+    instance_observer->RemoveObserver(observer);
+}
+
+void BrowserPpapiHostImpl::OnThrottleStateChanged(PP_Instance instance,
+                                                  bool is_throttled) {
+  auto found = instance_map_.find(instance);
+  if (found != instance_map_.end())
+    found->second.is_throttled = is_throttled;
+
+  auto* instance_observer = instance_observers_map_.get(instance);
+  if (instance_observer != nullptr) {
+    FOR_EACH_OBSERVER(InstanceObserver, *instance_observer,
+                      OnThrottleStateChanged(is_throttled));
+  }
+}
+
+bool BrowserPpapiHostImpl::IsThrottled(PP_Instance instance) const {
+  auto found = instance_map_.find(instance);
+  if (found != instance_map_.end()) {
+    return found->second.is_throttled;
+  }
+  return false;
 }
 
 BrowserPpapiHostImpl::HostMessageFilter::HostMessageFilter(
     ppapi::host::PpapiHost* ppapi_host,
     BrowserPpapiHostImpl* browser_ppapi_host_impl)
     : ppapi_host_(ppapi_host),
       browser_ppapi_host_impl_(browser_ppapi_host_impl) {}
 
 bool BrowserPpapiHostImpl::HostMessageFilter::OnMessageReceived(
     const IPC::Message& msg) {
@@ skipping 23 matching lines @@
 void BrowserPpapiHostImpl::HostMessageFilter::OnKeepalive() {
   if (browser_ppapi_host_impl_)
     browser_ppapi_host_impl_->OnKeepalive();
 }
 
 void BrowserPpapiHostImpl::HostMessageFilter::OnHostMsgLogInterfaceUsage(
     int hash) const {
   UMA_HISTOGRAM_SPARSE_SLOWLY("Pepper.InterfaceUsed", hash);
 }
 
+BrowserPpapiHostImpl::InstanceData::InstanceData() : is_throttled(false) {
+}
+
+BrowserPpapiHostImpl::InstanceData::~InstanceData() {
+}
+
 void BrowserPpapiHostImpl::OnKeepalive() {
   // An instance has been active. The on_keepalive_callback_ will be
   // used to permit the content embedder to handle this, e.g. by tracking
   // activity and shutting down processes that go idle.
   //
   // Currently embedders do not need to distinguish between instances having
   // different idle state, and thus this implementation handles all instances
   // for this module together.
 
   if (on_keepalive_callback_.is_null())
     return;
 
   BrowserPpapiHost::OnKeepaliveInstanceData instance_data(instance_map_.size());
 
   InstanceMap::iterator instance = instance_map_.begin();
   int i = 0;
   while (instance != instance_map_.end()) {
-    instance_data[i].render_process_id = instance->second.render_process_id;
-    instance_data[i].render_frame_id = instance->second.render_frame_id;
-    instance_data[i].document_url = instance->second.document_url;
+    instance_data[i].render_process_id =
+        instance->second.renderer_data.render_process_id;
+    instance_data[i].render_frame_id =
+        instance->second.renderer_data.render_frame_id;
+    instance_data[i].document_url = instance->second.renderer_data.document_url;
     ++instance;
     ++i;
   }
   on_keepalive_callback_.Run(instance_data, profile_data_directory_);
 }
 
 }  // namespace content