Changed the extension.connect() API not to broadcast to all tabs. Added a

chrome/browser/renderer_host/resource_message_filter.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/browser/renderer_host/resource_message_filter.h"
 
 #include "base/clipboard.h"
 #include "base/command_line.h"
 #include "base/gfx/native_widget_types.h"
 #include "base/histogram.h"
@@ skipping 129 matching lines @@
       channel_(NULL),
       resource_dispatcher_host_(resource_dispatcher_host),
       plugin_service_(plugin_service),
       print_job_manager_(print_job_manager),
       render_process_id_(-1),
       spellchecker_(spellchecker),
       ALLOW_THIS_IN_INITIALIZER_LIST(resolve_proxy_msg_helper_(this, NULL)),
       request_context_(profile->GetRequestContext()),
       media_request_context_(profile->GetRequestContextForMedia()),
       extensions_request_context_(profile->GetRequestContextForExtensions()),
+      extensions_message_service_(profile->GetExtensionMessageService()),
       profile_(profile),
       render_widget_helper_(render_widget_helper),
       audio_renderer_host_(audio_renderer_host),
       app_cache_dispatcher_host_(new AppCacheDispatcherHost),
       ALLOW_THIS_IN_INITIALIZER_LIST(dom_storage_dispatcher_host_(
           new DOMStorageDispatcherHost(this, profile->GetWebKitContext(),
               resource_dispatcher_host->webkit_thread()))),
       off_the_record_(profile->IsOffTheRecord()) {
   DCHECK(request_context_.get());
   DCHECK(request_context_->cookie_store());
@@ skipping 167 matching lines @@
                                       OnScriptedPrint)
 #endif
 #if defined(OS_MACOSX)
       IPC_MESSAGE_HANDLER(ViewHostMsg_AllocTransportDIB,
                           OnAllocTransportDIB)
       IPC_MESSAGE_HANDLER(ViewHostMsg_FreeTransportDIB,
                           OnFreeTransportDIB)
 #endif
       IPC_MESSAGE_HANDLER(ViewHostMsg_OpenChannelToExtension,
                           OnOpenChannelToExtension)
+      IPC_MESSAGE_HANDLER(ViewHostMsg_OpenChannelToTab,
+                          OnOpenChannelToTab)
       IPC_MESSAGE_HANDLER(ViewHostMsg_CloseIdleConnections,
                           OnCloseIdleConnections)
       IPC_MESSAGE_HANDLER(ViewHostMsg_SetCacheMode,
                           OnSetCacheMode)
       IPC_MESSAGE_HANDLER_DELAY_REPLY(ViewHostMsg_GetFileSize,
                                       OnGetFileSize)
 
       IPC_MESSAGE_UNHANDLED(
           handled = false)
     IPC_END_MESSAGE_MAP_EX()
@@ skipping 547 matching lines @@
 
 void ResourceMessageFilter::OnFreeTransportDIB(
     TransportDIB::Id dib_id) {
   render_widget_helper_->FreeTransportDIB(dib_id);
 }
 #endif
 
 void ResourceMessageFilter::OnOpenChannelToExtension(
     int routing_id, const std::string& extension_id,
     const std::string& channel_name, int* port_id) {
-  *port_id = ExtensionMessageService::GetInstance(request_context_.get())->
-      OpenChannelToExtension(routing_id, extension_id, channel_name, this);
+  if (extensions_message_service_.get()) {
+    *port_id = extensions_message_service_->
+        OpenChannelToExtension(routing_id, extension_id, channel_name, this);
+  } else {
+    *port_id = -1;
+  }
+}
+
+void ResourceMessageFilter::OnOpenChannelToTab(
+    int routing_id, int tab_id, const std::string& extension_id,
+    const std::string& channel_name, int* port_id) {
+  if (extensions_message_service_.get()) {
+    *port_id = extensions_message_service_->
+        OpenChannelToTab(routing_id, tab_id, extension_id, channel_name, this);
+  } else {
+    *port_id = -1;
+  }
 }
 
 bool ResourceMessageFilter::CheckBenchmarkingEnabled() {
   static bool checked = false;
   static bool result = false;
   if (!checked) {
     const CommandLine& command_line = *CommandLine::ForCurrentProcess();
     result = command_line.HasSwitch(switches::kEnableBenchmarking);
     checked = true;
   }
@@ skipping 40 matching lines @@
 }
 
 void ResourceMessageFilter::ReplyGetFileSize(int64 result, void* param) {
   IPC::Message* reply_msg = static_cast<IPC::Message*>(param);
   ViewHostMsg_GetFileSize::WriteReplyParams(reply_msg, result);
   Send(reply_msg);
 
   // Getting file size callback done, decrease the ref count.
   Release();
 }