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

chrome/browser/extensions/extension_process_manager.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/extensions/extension_process_manager.h"
 
 #include "chrome/browser/browsing_instance.h"
 #include "chrome/browser/extensions/extension_host.h"
 #include "chrome/browser/extensions/extensions_service.h"
 #include "chrome/browser/profile.h"
@@ skipping 67 matching lines @@
 ExtensionHost* ExtensionProcessManager::CreateBackgroundHost(
     Extension* extension, const GURL& url) {
   ExtensionHost* host =
       new ExtensionHost(extension, GetSiteInstanceForURL(url), url);
   host->CreateRenderView(NULL);  // create a RenderViewHost with no view
   OnExtensionHostCreated(host, true);
   return host;
 }
 
 void ExtensionProcessManager::RegisterExtensionProcess(
-    std::string extension_id, int process_id) {
+    const std::string& extension_id, int process_id) {
   ProcessIDMap::const_iterator it = process_ids_.find(extension_id);
   if (it != process_ids_.end() && (*it).second == process_id)
     return;
 
   process_ids_[extension_id] = process_id;
 
   ExtensionsService* extension_service =
       browsing_instance_->profile()->GetExtensionsService();
 
   std::vector<std::string> page_action_ids;
@@ skipping 11 matching lines @@
 void ExtensionProcessManager::UnregisterExtensionProcess(int process_id) {
   ProcessIDMap::iterator it = process_ids_.begin();
   while (it != process_ids_.end()) {
     if (it->second == process_id)
       process_ids_.erase(it++);
     else
       ++it;
   }
 }
 
+RenderProcessHost* ExtensionProcessManager::GetExtensionProcess(
+    const std::string& extension_id) {
+  ProcessIDMap::const_iterator it = process_ids_.find(extension_id);
+  if (it == process_ids_.end())
+    return NULL;
+
+  RenderProcessHost* rph = RenderProcessHost::FromID(it->second);
+  DCHECK(rph) << "We should have unregistered this host.";
+  return rph;
+}
+
 SiteInstance* ExtensionProcessManager::GetSiteInstanceForURL(const GURL& url) {
   return browsing_instance_->GetSiteInstanceForURL(url);
 }
 
 void ExtensionProcessManager::Observe(NotificationType type,
                                       const NotificationSource& source,
                                       const NotificationDetails& details) {
   switch (type.value) {
     case NotificationType::EXTENSIONS_READY:
       CreateBackgroundHosts(this,
@@ skipping 46 matching lines @@
 void ExtensionProcessManager::OnExtensionHostCreated(ExtensionHost* host,
                                                      bool is_background) {
   all_hosts_.insert(host);
   if (is_background)
     background_hosts_.insert(host);
   NotificationService::current()->Notify(
       NotificationType::EXTENSION_HOST_CREATED,
       Source<ExtensionProcessManager>(this),
       Details<ExtensionHost>(host));
 }