Make the AppCacheDispatcherHost be a MessageFilter so that ResourceMessageFil...

chrome/browser/worker_host/worker_process_host.h

 // Copyright (c) 2009 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.
 
 #ifndef CHROME_BROWSER_WORKER_HOST_WORKER_PROCESS_HOST_H_
 #define CHROME_BROWSER_WORKER_HOST_WORKER_PROCESS_HOST_H_
 #pragma once
 
 #include <list>
+#include <vector>
 
 #include "base/basictypes.h"
 #include "base/callback.h"
 #include "base/file_path.h"
 #include "base/ref_counted.h"
 #include "chrome/browser/browser_child_process_host.h"
+#include "chrome/browser/browser_io_message_filter.h"
 #include "chrome/browser/net/chrome_url_request_context.h"
 #include "chrome/browser/worker_host/worker_document_set.h"
 #include "googleurl/src/gurl.h"
 #include "ipc/ipc_channel.h"
 
-class AppCacheDispatcherHost;
 class BlobDispatcherHost;
 class ChromeURLRequestContext;
 class ChromeURLRequestContextGetter;
 class DatabaseDispatcherHost;
 class FileSystemDispatcherHost;
 class FileUtilitiesDispatcherHost;
 class MimeRegistryDispatcher;
 namespace webkit_database {
 class DatabaseTracker;
 }  // namespace webkit_database
@@ skipping 120 matching lines @@
   typedef std::list<WorkerInstance> Instances;
   const Instances& instances() const { return instances_; }
   Instances& mutable_instances() { return instances_; }
 
  private:
   // ResourceDispatcherHost::Receiver implementation:
   virtual URLRequestContext* GetRequestContext(
       uint32 request_id,
       const ViewHostMsg_Resource_Request& request_data);
 
+  // IPC::Channel::Listener implementation:
   // Called when a message arrives from the worker process.
   virtual void OnMessageReceived(const IPC::Message& message);
+  virtual void OnChannelConnected(int32 peer_pid);
+  virtual void OnChannelError();
+
+  // Creates and adds the message filters.
+  void CreateMessageFilters();
 
   // Called when the process has been launched successfully.
   virtual void OnProcessLaunched();
 
   // Called when the app invokes close() from within worker context.
   void OnWorkerContextClosed(int worker_route_id);
 
   // Called if a worker tries to connect to a shared worker.
   void OnLookupSharedWorker(const ViewHostMsg_CreateWorker_Params& params,
                             bool* exists,
@@ skipping 26 matching lines @@
   // worker.
   void OnAllowDatabase(const GURL& url,
                        const string16& name,
                        const string16& display_name,
                        unsigned long estimated_size,
                        IPC::Message* reply_msg);
 
   Instances instances_;
 
   scoped_refptr<ChromeURLRequestContext> request_context_;
-  scoped_ptr<AppCacheDispatcherHost> appcache_dispatcher_host_;
   scoped_refptr<DatabaseDispatcherHost> db_dispatcher_host_;
   scoped_ptr<BlobDispatcherHost> blob_dispatcher_host_;
   scoped_refptr<FileSystemDispatcherHost> file_system_dispatcher_host_;
   scoped_refptr<FileUtilitiesDispatcherHost> file_utilities_dispatcher_host_;
   scoped_refptr<MimeRegistryDispatcher> mime_registry_dispatcher_;
 
+  // Holds all the IPC message filters.  Since the worker process host is on the
+  // IO thread, we don't have a IPC::ChannelProxy and so we manage filters
+  // manually.
+  std::vector<scoped_refptr<BrowserIOMessageFilter> > filters_;
+
   // A callback to create a routing id for the associated worker process.
   scoped_ptr<CallbackWithReturnValue<int>::Type> next_route_id_callback_;
 
   DISALLOW_COPY_AND_ASSIGN(WorkerProcessHost);
 };
 
 #endif  // CHROME_BROWSER_WORKER_HOST_WORKER_PROCESS_HOST_H_