Add optimization for CHROMIUM_subscribe_uniform extension.

content/browser/gpu/gpu_process_host.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/gpu/gpu_process_host.h"
 
 #include "base/base64.h"
 #include "base/base_switches.h"
 #include "base/basictypes.h"
 #include "base/bind.h"
@@ skipping 123 matching lines @@
                            CauseForGpuLaunch cause,
                            IPC::Message* message) {
   GpuProcessHost* host = GpuProcessHost::Get(kind, cause);
   if (host) {
     host->Send(message);
   } else {
     delete message;
   }
 }
 
+void SendGpuProcessUpdateValueStateMessage(int client_id,
+                                           unsigned int target,
+                                           const gpu::ValueState& state) {
+  GpuProcessHost* host = GpuProcessHost::Get(
+      GpuProcessHost::GPU_PROCESS_KIND_SANDBOXED,
+      CAUSE_FOR_GPU_LAUNCH_NO_LAUNCH);
+  if (host)
+    host->SendUpdateValueState(client_id, target, state);
+}
+
 // NOTE: changes to this class need to be reviewed by the security team.
 class GpuSandboxedProcessLauncherDelegate
     : public SandboxedProcessLauncherDelegate {
  public:
   GpuSandboxedProcessLauncherDelegate(base::CommandLine* cmd_line,
                                       ChildProcessHost* host)
 #if defined(OS_WIN)
       : cmd_line_(cmd_line) {}
 #elif defined(OS_POSIX)
       : ipc_fd_(host->TakeClientFileDescriptor()) {}
@@ skipping 188 matching lines @@
                               CauseForGpuLaunch cause,
                               IPC::Message* message) {
   if (!BrowserThread::PostTask(
           BrowserThread::IO, FROM_HERE,
           base::Bind(
               &SendGpuProcessMessage, kind, cause, message))) {
     delete message;
   }
 }
 
+//static
+void GpuProcessHost::SendUpdateValueStateOnIOThread(
+    int client_id, unsigned int target, const gpu::ValueState& state) {
+  BrowserThread::PostTask(
+      BrowserThread::IO, FROM_HERE,
+      base::Bind(&SendGpuProcessUpdateValueStateMessage,
+                 client_id, target, state));
+}
+
 GpuMainThreadFactoryFunction g_gpu_main_thread_factory = NULL;
 
 void GpuProcessHost::RegisterGpuMainThreadFactory(
     GpuMainThreadFactoryFunction create) {
   g_gpu_main_thread_factory = create;
 }
 
 // static
 GpuProcessHost* GpuProcessHost::FromID(int host_id) {
   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
@@ skipping 213 matching lines @@
     IPC_MESSAGE_HANDLER(GpuHostMsg_GpuMemoryUmaStats,
                         OnGpuMemoryUmaStatsReceived)
 #if defined(OS_MACOSX)
     IPC_MESSAGE_HANDLER_GENERIC(GpuHostMsg_AcceleratedSurfaceBuffersSwapped,
                                 OnAcceleratedSurfaceBuffersSwapped(message))
 #endif
     IPC_MESSAGE_HANDLER(GpuHostMsg_DestroyChannel,
                         OnDestroyChannel)
     IPC_MESSAGE_HANDLER(GpuHostMsg_CacheShader,
                         OnCacheShader)
-
+    IPC_MESSAGE_HANDLER(GpuHostMsg_AddSubscription, OnAddSubscription)
+    IPC_MESSAGE_HANDLER(GpuHostMsg_RemoveSubscription, OnRemoveSubscription)
     IPC_MESSAGE_UNHANDLED(RouteOnUIThread(message))
   IPC_END_MESSAGE_MAP()
 
   return true;
 }
 
 void GpuProcessHost::OnChannelConnected(int32 peer_pid) {
   TRACE_EVENT0("gpu", "GpuProcessHost::OnChannelConnected");
 
   while (!queued_messages_.empty()) {
@@ skipping 436 matching lines @@
   return shader_prefix_key_;
 }
 
 void GpuProcessHost::LoadedShader(const std::string& key,
                                   const std::string& data) {
   std::string prefix = GetShaderPrefixKey();
   if (!key.compare(0, prefix.length(), prefix))
     Send(new GpuMsg_LoadedShader(data));
 }
 
+void GpuProcessHost::SendUpdateValueState(int client_id,
+                                          unsigned int target,
+                                          const gpu::ValueState& state) {
+  // Only send data if a valuebuffer is subscribed to the target
+  if (subscription_set_.find(target) != subscription_set_.end()) {
+    Send(new GpuMsg_UpdateValueState(client_id, target, state));
+  }
+}
+
 void GpuProcessHost::CreateChannelCache(int32 client_id) {
   TRACE_EVENT0("gpu", "GpuProcessHost::CreateChannelCache");
 
   scoped_refptr<ShaderDiskCache> cache =
       ShaderCacheFactory::GetInstance()->Get(client_id);
   if (!cache.get())
     return;
 
   cache->set_host_id(host_id_);
 
@@ skipping 10 matching lines @@
                                    const std::string& shader) {
   TRACE_EVENT0("gpu", "GpuProcessHost::OnCacheShader");
   ClientIdToShaderCacheMap::iterator iter =
       client_id_to_shader_cache_.find(client_id);
   // If the cache doesn't exist then this is an off the record profile.
   if (iter == client_id_to_shader_cache_.end())
     return;
   iter->second->Cache(GetShaderPrefixKey() + ":" + key, shader);
 }
 
+void GpuProcessHost::OnAddSubscription(unsigned int target) {
+  subscription_set_.insert(target);
+}
+
+void GpuProcessHost::OnRemoveSubscription(unsigned int target) {
+  subscription_set_.erase(target);
+}
+
 }  // namespace content