Create a message filter for message port messages. This allows a nice cleanu...

chrome_frame/chrome_frame_automation.cc

 // Copyright (c) 2010 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_frame/chrome_frame_automation.h"
 
 #include "app/app_switches.h"
 #include "base/callback.h"
 #include "base/command_line.h"
 #include "base/compiler_specific.h"
@@ skipping 1085 matching lines @@
   // Either directly call appropriate url_fetcher function
   // or postpone call to the UI thread.
   uint16 msg_type = msg.type();
   switch (msg_type) {
     default:
       return false;
 
     case AutomationMsg_RequestStart::ID:
       if (ui_thread || (url_fetcher_flags_ &
                            PluginUrlRequestManager::START_REQUEST_THREADSAFE)) {
-        AutomationMsg_RequestStart::Dispatch(&msg, url_fetcher_,
+        AutomationMsg_RequestStart::Dispatch(&msg, url_fetcher_, this,
             &PluginUrlRequestManager::StartUrlRequest);
         return true;
       }
       break;
 
     case AutomationMsg_RequestRead::ID:
       if (ui_thread || (url_fetcher_flags_ &
                             PluginUrlRequestManager::READ_REQUEST_THREADSAFE)) {
-        AutomationMsg_RequestRead::Dispatch(&msg, url_fetcher_,
+        AutomationMsg_RequestRead::Dispatch(&msg, url_fetcher_, this,
             &PluginUrlRequestManager::ReadUrlRequest);
         return true;
       }
       break;
 
     case AutomationMsg_RequestEnd::ID:
       if (ui_thread || (url_fetcher_flags_ &
                             PluginUrlRequestManager::STOP_REQUEST_THREADSAFE)) {
-        AutomationMsg_RequestEnd::Dispatch(&msg, url_fetcher_,
+        AutomationMsg_RequestEnd::Dispatch(&msg, url_fetcher_, this,
             &PluginUrlRequestManager::EndUrlRequest);
         return true;
       }
       break;
 
     case AutomationMsg_DownloadRequestInHost::ID:
       if (ui_thread || (url_fetcher_flags_ &
                         PluginUrlRequestManager::DOWNLOAD_REQUEST_THREADSAFE)) {
-        AutomationMsg_DownloadRequestInHost::Dispatch(&msg, url_fetcher_,
+        AutomationMsg_DownloadRequestInHost::Dispatch(&msg, url_fetcher_, this,
             &PluginUrlRequestManager::DownloadUrlRequestInHost);
         return true;
       }
       break;
 
     case AutomationMsg_GetCookiesFromHost::ID:
       if (ui_thread || (url_fetcher_flags_ &
                           PluginUrlRequestManager::COOKIE_REQUEST_THREADSAFE)) {
-        AutomationMsg_GetCookiesFromHost::Dispatch(&msg, url_fetcher_,
+        AutomationMsg_GetCookiesFromHost::Dispatch(&msg, url_fetcher_, this,
             &PluginUrlRequestManager::GetCookiesFromHost);
         return true;
       }
       break;
 
     case AutomationMsg_SetCookieAsync::ID:
       if (ui_thread || (url_fetcher_flags_ &
                           PluginUrlRequestManager::COOKIE_REQUEST_THREADSAFE)) {
-        AutomationMsg_SetCookieAsync::Dispatch(&msg, url_fetcher_,
+        AutomationMsg_SetCookieAsync::Dispatch(&msg, url_fetcher_, this,
             &PluginUrlRequestManager::SetCookiesInHost);
         return true;
       }
       break;
   }
 
   PostTask(FROM_HERE, NewRunnableMethod(this,
       &ChromeFrameAutomationClient::ProcessUrlRequestMessage, tab, msg, true));
   return true;
 }
@@ skipping 291 matching lines @@
     const URLRequestStatus& status) {
   automation_server_->Send(new AutomationMsg_RequestEnd(0, tab_->handle(),
       request_id, status));
 }
 
 void ChromeFrameAutomationClient::OnCookiesRetrieved(bool success,
     const GURL& url, const std::string& cookie_string, int cookie_id) {
   automation_server_->Send(new AutomationMsg_GetCookiesHostResponse(0,
       tab_->handle(), success, url, cookie_string, cookie_id));
 }