Make BrowserMessageFilter support dispatching messages on different threads.

chrome/browser/appcache/appcache_dispatcher_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/appcache/appcache_dispatcher_host.h"
 
 #include "base/callback.h"
 #include "chrome/browser/appcache/chrome_appcache_service.h"
 #include "chrome/browser/renderer_host/browser_render_process_host.h"
 #include "chrome/browser/net/chrome_url_request_context.h"
@@ skipping 13 matching lines @@
     int process_id)
     : ALLOW_THIS_IN_INITIALIZER_LIST(frontend_proxy_(this)),
       request_context_getter_(request_context_getter),
       process_id_(process_id) {
   DCHECK(request_context_getter_.get());
 }
 
 AppCacheDispatcherHost::~AppCacheDispatcherHost() {}
 
 void AppCacheDispatcherHost::OnChannelConnected(int32 peer_pid) {
-  BrowserIOMessageFilter::OnChannelConnected(peer_pid);
+  BrowserMessageFilter::OnChannelConnected(peer_pid);
 
   DCHECK(request_context_.get() || request_context_getter_.get());
 
   // Get the AppCacheService (it can only be accessed from IO thread).
   URLRequestContext* context = request_context_.get();
   if (!context)
     context = request_context_getter_->GetURLRequestContext();
   appcache_service_ =
       static_cast<ChromeURLRequestContext*>(context)->appcache_service();
   request_context_ = NULL;
   request_context_getter_ = NULL;
 
   if (appcache_service_.get()) {
     backend_impl_.Initialize(
         appcache_service_.get(), &frontend_proxy_, process_id_);
     get_status_callback_.reset(
         NewCallback(this, &AppCacheDispatcherHost::GetStatusCallback));
     start_update_callback_.reset(
         NewCallback(this, &AppCacheDispatcherHost::StartUpdateCallback));
     swap_cache_callback_.reset(
         NewCallback(this, &AppCacheDispatcherHost::SwapCacheCallback));
   }
 }
 
-bool AppCacheDispatcherHost::OnMessageReceived(const IPC::Message& message) {
+bool AppCacheDispatcherHost::OnMessageReceived(const IPC::Message& message,
+                                               bool* message_was_ok) {
   bool handled = true;
-  bool message_was_ok = true;
 
-  IPC_BEGIN_MESSAGE_MAP_EX(AppCacheDispatcherHost, message, message_was_ok)
+  IPC_BEGIN_MESSAGE_MAP_EX(AppCacheDispatcherHost, message, *message_was_ok)
     IPC_MESSAGE_HANDLER(AppCacheMsg_RegisterHost, OnRegisterHost);
     IPC_MESSAGE_HANDLER(AppCacheMsg_UnregisterHost, OnUnregisterHost);
     IPC_MESSAGE_HANDLER(AppCacheMsg_GetResourceList, OnGetResourceList);
     IPC_MESSAGE_HANDLER(AppCacheMsg_SelectCache, OnSelectCache);
     IPC_MESSAGE_HANDLER(AppCacheMsg_SelectCacheForWorker,
                         OnSelectCacheForWorker);
     IPC_MESSAGE_HANDLER(AppCacheMsg_SelectCacheForSharedWorker,
                         OnSelectCacheForSharedWorker);
     IPC_MESSAGE_HANDLER(AppCacheMsg_MarkAsForeignEntry, OnMarkAsForeignEntry);
     IPC_MESSAGE_HANDLER_DELAY_REPLY(AppCacheMsg_GetStatus, OnGetStatus);
     IPC_MESSAGE_HANDLER_DELAY_REPLY(AppCacheMsg_StartUpdate, OnStartUpdate);
     IPC_MESSAGE_HANDLER_DELAY_REPLY(AppCacheMsg_SwapCache, OnSwapCache);
     IPC_MESSAGE_UNHANDLED(handled = false)
   IPC_END_MESSAGE_MAP_EX()
 
-  if (!message_was_ok)
-    BadMessageReceived(message.type());
-
   return handled;
 }
 
 void AppCacheDispatcherHost::OnRegisterHost(int host_id) {
   if (appcache_service_.get()) {
     if (!backend_impl_.RegisterHost(host_id)) {
       BadMessageReceived(AppCacheMsg_RegisterHost::ID);
     }
   }
 }
@@ skipping 134 matching lines @@
   AppCacheMsg_StartUpdate::WriteReplyParams(reply_msg, result);
   Send(pending_reply_msg_.release());
 }
 
 void AppCacheDispatcherHost::SwapCacheCallback(bool result, void* param) {
   IPC::Message* reply_msg = reinterpret_cast<IPC::Message*>(param);
   DCHECK(reply_msg == pending_reply_msg_.get());
   AppCacheMsg_SwapCache::WriteReplyParams(reply_msg, result);
   Send(pending_reply_msg_.release());
 }