AppCachePlumbing

chrome/renderer/render_thread.cc

 // Copyright (c) 2006-2008 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/renderer/render_thread.h"
 
 #include <algorithm>
 #include <vector>
 
 #include "base/command_line.h"
 #include "base/shared_memory.h"
 #include "base/stats_table.h"
+#include "chrome/common/app_cache/app_cache_context_impl.h"
+#include "chrome/common/app_cache/app_cache_dispatcher.h"
 #include "chrome/common/chrome_switches.h"
 #include "chrome/common/render_messages.h"
 #include "chrome/common/notification_service.h"
 #include "chrome/common/url_constants.h"
 #include "chrome/plugin/npobject_util.h"
 // TODO(port)
 #if defined(OS_WIN)
 #include "chrome/plugin/plugin_channel.h"
 #else
 #include "base/scoped_handle.h"
@@ skipping 61 matching lines @@
 }
 
 void RenderThread::Resolve(const char* name, size_t length) {
   return dns_master_->Resolve(name, length);
 }
 
 void RenderThread::SendHistograms() {
   return histogram_snapshots_->SendHistograms();
 }
 
+static WebAppCacheContext* CreateAppCacheContextForRenderer() {
+  return new AppCacheContextImpl(RenderThread::current());
+}
+
 void RenderThread::Init() {
-  // TODO(darin): Why do we need COM here?  This is probably bogus.
+  // TODO(darin): Why do we need COM here?  This is probably bogus. Perhaps
+  // this is for InProcessPlugin support?
 #if defined(OS_WIN)
   // The renderer thread should wind-up COM.
   CoInitialize(0);
 #endif
 
   ChildThread::Init();
   notification_service_.reset(new NotificationService);
   cache_stats_factory_.reset(
       new ScopedRunnableMethodFactory<RenderThread>(this));
 
   visited_link_slave_.reset(new VisitedLinkSlave());
   user_script_slave_.reset(new UserScriptSlave());
   dns_master_.reset(new RenderDnsMaster());
   histogram_snapshots_.reset(new RendererHistogramSnapshots());
+  app_cache_dispatcher_.reset(new AppCacheDispatcher());
+  WebAppCacheContext::SetFactory(CreateAppCacheContextForRenderer);
 }
 
 void RenderThread::CleanUp() {
   // Shutdown in reverse of the initialization order.
 
+  WebAppCacheContext::SetFactory(NULL);
+  app_cache_dispatcher_.reset();
   histogram_snapshots_.reset();
   dns_master_.reset();
   user_script_slave_.reset();
   visited_link_slave_.reset();
 
   if (webkit_client_.get()) {
     WebKit::shutdown();
     webkit_client_.reset();
   }
 
@@ skipping 22 matching lines @@
   DCHECK(base::SharedMemory::IsHandleValid(scripts)) << "Bad scripts handle";
   user_script_slave_->UpdateScripts(scripts);
 }
 
 void RenderThread::OnSetExtensionFunctionNames(
     const std::vector<std::string>& names) {
   extensions_v8::ExtensionProcessBindings::SetFunctionNames(names);
 }
 
 void RenderThread::OnControlMessageReceived(const IPC::Message& msg) {
+  // App cache messages are handled by a delegate.
+  if (app_cache_dispatcher_->OnMessageReceived(msg))
+    return;
+
   IPC_BEGIN_MESSAGE_MAP(RenderThread, msg)
     IPC_MESSAGE_HANDLER(ViewMsg_VisitedLink_NewTable, OnUpdateVisitedLinks)
     IPC_MESSAGE_HANDLER(ViewMsg_SetNextPageID, OnSetNextPageID)
     // TODO(port): removed from render_messages_internal.h;
     // is there a new non-windows message I should add here?
     IPC_MESSAGE_HANDLER(ViewMsg_New, OnCreateNewView)
     IPC_MESSAGE_HANDLER(ViewMsg_SetCacheCapacities, OnSetCacheCapacities)
     IPC_MESSAGE_HANDLER(ViewMsg_GetRendererHistograms,
                           OnGetRendererHistograms)
     IPC_MESSAGE_HANDLER(ViewMsg_GetCacheResourceStats,
@@ skipping 122 matching lines @@
 }
 
 void RenderThread::OnExtensionHandleConnect(int port_id) {
   extensions_v8::RendererExtensionBindings::HandleConnect(port_id);
 }
 
 void RenderThread::OnExtensionHandleMessage(const std::string& message,
                                             int port_id) {
   extensions_v8::RendererExtensionBindings::HandleMessage(message, port_id);
 }