Create a ResourceMessageFilter to filter resource related IPCs. This gets ri...

chrome/browser/worker_host/worker_process_host.cc

 // 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.
 
 #include "chrome/browser/worker_host/worker_process_host.h"
 
 #include <set>
 #include <vector>
 
 #include "base/callback.h"
@@ skipping 57 matching lines @@
 WorkerProcessHost::WorkerProcessHost(
     ResourceDispatcherHost* resource_dispatcher_host,
     ChromeURLRequestContext *request_context)
     : BrowserChildProcessHost(WORKER_PROCESS, resource_dispatcher_host),
       request_context_(request_context) {
   next_route_id_callback_.reset(NewCallbackWithReturnValue(
       WorkerService::GetInstance(), &WorkerService::next_worker_route_id));
 }
 
 WorkerProcessHost::~WorkerProcessHost() {
-  for (size_t i = 0; i < filters_.size(); ++i) {
-    filters_[i]->OnChannelClosing();
-    filters_[i]->OnFilterRemoved();
-  }
-
   // Let interested observers know we are being deleted.
   NotificationService::current()->Notify(
       NotificationType::WORKER_PROCESS_HOST_SHUTDOWN,
       Source<WorkerProcessHost>(this),
       NotificationService::NoDetails());
 
   // If we crashed, tell the RenderViewHosts.
   for (Instances::iterator i = instances_.begin(); i != instances_.end(); ++i) {
     const WorkerDocumentSet::DocumentInfoSet& parents =
         i->worker_document_set()->documents();
@@ skipping 97 matching lines @@
           base::PLATFORM_FILE_TRUNCATE |
           base::PLATFORM_FILE_WRITE_ATTRIBUTES);
   }
 
   CreateMessageFilters();
 
   return true;
 }
 
 void WorkerProcessHost::CreateMessageFilters() {
-  filters_.push_back(new AppCacheDispatcherHost(request_context_, id()));
-  filters_.push_back(new FileSystemDispatcherHost(request_context_));
-  filters_.push_back(new FileUtilitiesMessageFilter(id()));
-  filters_.push_back(
+  AddFilter(new AppCacheDispatcherHost(request_context_, id()));
+  AddFilter(new FileSystemDispatcherHost(request_context_));
+  AddFilter(new FileUtilitiesMessageFilter(id()));
+  AddFilter(
       new BlobMessageFilter(id(), request_context_->blob_storage_context()));
-  filters_.push_back(new MimeRegistryMessageFilter());
-  filters_.push_back(new DatabaseMessageFilter(
+  AddFilter(new MimeRegistryMessageFilter());
+  AddFilter(new DatabaseMessageFilter(
       request_context_->database_tracker(),
       request_context_->host_content_settings_map()));
-  filters_.push_back(new SocketStreamDispatcherHost());
-
-  for (size_t i = 0; i < filters_.size(); ++i)
-    filters_[i]->OnFilterAdded(channel());
+  AddFilter(new SocketStreamDispatcherHost());
 }
 
 void WorkerProcessHost::CreateWorker(const WorkerInstance& instance) {
   ChildProcessSecurityPolicy::GetInstance()->GrantRequestURL(
       id(), instance.url());
 
   instances_.push_back(instance);
 
   WorkerProcessMsg_CreateWorker_Params params;
   params.url = instance.url();
@@ skipping 23 matching lines @@
     if (!i->closed() && i->HasSender(sender, message.routing_id())) {
       RelayMessage(
           message, this, i->worker_route_id(), next_route_id_callback_.get());
       return true;
     }
   }
 
   return false;
 }
 
-URLRequestContext* WorkerProcessHost::GetRequestContext(
-    uint32 request_id,
-    const ViewHostMsg_Resource_Request& request_data) {
-  return request_context_;
-}
-
 // Sent to notify the browser process when a worker context invokes close(), so
 // no new connections are sent to shared workers.
 void WorkerProcessHost::OnWorkerContextClosed(int worker_route_id) {
   for (Instances::iterator i = instances_.begin(); i != instances_.end(); ++i) {
     if (i->worker_route_id() == worker_route_id) {
       // Set the closed flag - this will stop any further messages from
       // being sent to the worker (messages can still be sent from the worker,
       // for exception reporting, etc).
       i->set_closed(true);
       break;
     }
   }
 }
 
 void WorkerProcessHost::OnMessageReceived(const IPC::Message& message) {
-  for (size_t i = 0; i < filters_.size(); ++i) {
-    if (filters_[i]->OnMessageReceived(message))
-      return;
-  }
-
   bool msg_is_ok = true;
   bool handled =
       MessagePortDispatcher::GetInstance()->OnMessageReceived(
           message, this, next_route_id_callback_.get(), &msg_is_ok);
 
   if (!handled) {
     handled = true;
     IPC_BEGIN_MESSAGE_MAP_EX(WorkerProcessHost, message, msg_is_ok)
       IPC_MESSAGE_HANDLER(ViewHostMsg_CreateWorker, OnCreateWorker)
       IPC_MESSAGE_HANDLER(ViewHostMsg_LookupSharedWorker, OnLookupSharedWorker)
@@ skipping 30 matching lines @@
 
       if (message.type() == WorkerHostMsg_WorkerContextDestroyed::ID) {
         instances_.erase(i);
         UpdateTitle();
       }
       break;
     }
   }
 }
 
-void WorkerProcessHost::OnChannelConnected(int32 peer_pid) {
-  for (size_t i = 0; i < filters_.size(); ++i)
-    filters_[i]->OnChannelConnected(peer_pid);
-}
-
-void WorkerProcessHost::OnChannelError() {
-  for (size_t i = 0; i < filters_.size(); ++i)
-    filters_[i]->OnChannelError();
-}
-
 void WorkerProcessHost::OnProcessLaunched() {
 }
 
 CallbackWithReturnValue<int>::Type* WorkerProcessHost::GetNextRouteIdCallback(
     IPC::Message::Sender* sender) {
   // We don't keep callbacks for senders associated with workers, so figure out
   // what kind of sender this is, and cast it to the correct class to get the
   // callback.
   for (BrowserChildProcessHost::Iterator iter(ChildProcessInfo::WORKER_PROCESS);
        !iter.Done(); ++iter) {
@@ skipping 338 matching lines @@
     }
   }
   return false;
 }
 
 WorkerProcessHost::WorkerInstance::SenderInfo
 WorkerProcessHost::WorkerInstance::GetSender() const {
   DCHECK(NumSenders() == 1);
   return *senders_.begin();
 }