| OLD | NEW |
| 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "chrome/browser/extensions/api/messaging/extension_message_port.h" | 5 #include "chrome/browser/extensions/api/messaging/extension_message_port.h" |
| 6 | 6 |
| 7 #include "base/scoped_observer.h" | 7 #include "base/scoped_observer.h" |
| 8 #include "chrome/browser/profiles/profile.h" | 8 #include "chrome/browser/profiles/profile.h" |
| 9 #include "content/public/browser/interstitial_page.h" |
| 9 #include "content/public/browser/navigation_details.h" | 10 #include "content/public/browser/navigation_details.h" |
| 10 #include "content/public/browser/render_frame_host.h" | 11 #include "content/public/browser/render_frame_host.h" |
| 11 #include "content/public/browser/render_process_host.h" | 12 #include "content/public/browser/render_process_host.h" |
| 12 #include "content/public/browser/web_contents.h" | 13 #include "content/public/browser/web_contents.h" |
| 13 #include "content/public/browser/web_contents_observer.h" | 14 #include "content/public/browser/web_contents_observer.h" |
| 14 #include "extensions/browser/extension_host.h" | 15 #include "extensions/browser/extension_host.h" |
| 15 #include "extensions/browser/process_manager.h" | 16 #include "extensions/browser/process_manager.h" |
| 16 #include "extensions/browser/process_manager_observer.h" | 17 #include "extensions/browser/process_manager_observer.h" |
| 17 #include "extensions/common/extension_messages.h" | 18 #include "extensions/common/extension_messages.h" |
| 18 #include "extensions/common/manifest_handlers/background_info.h" | 19 #include "extensions/common/manifest_handlers/background_info.h" |
| 19 | 20 |
| 20 namespace extensions { | 21 namespace extensions { |
| 21 | 22 |
| 22 const char kReceivingEndDoesntExistError[] = | 23 const char kReceivingEndDoesntExistError[] = |
| 23 "Could not establish connection. Receiving end does not exist."; | 24 "Could not establish connection. Receiving end does not exist."; |
| 24 | 25 |
| 25 // Helper class to detect when frames are destroyed. | 26 // Helper class to detect when frames are destroyed. |
| 26 class ExtensionMessagePort::FrameTracker : public content::WebContentsObserver, | 27 class ExtensionMessagePort::FrameTracker : public content::WebContentsObserver, |
| 27 public ProcessManagerObserver { | 28 public ProcessManagerObserver { |
| 28 public: | 29 public: |
| 29 explicit FrameTracker(ExtensionMessagePort* port) | 30 explicit FrameTracker(ExtensionMessagePort* port) |
| 30 : pm_observer_(this), port_(port) {} | 31 : pm_observer_(this), port_(port), interstitial_frame_(nullptr) {} |
| 31 ~FrameTracker() override {} | 32 ~FrameTracker() override {} |
| 32 | 33 |
| 33 void TrackExtensionProcessFrames() { | 34 void TrackExtensionProcessFrames() { |
| 34 pm_observer_.Add(ProcessManager::Get(port_->browser_context_)); | 35 pm_observer_.Add(ProcessManager::Get(port_->browser_context_)); |
| 35 } | 36 } |
| 36 | 37 |
| 37 void TrackTabFrames(content::WebContents* tab) { | 38 void TrackTabFrames(content::WebContents* tab) { |
| 38 Observe(tab); | 39 Observe(tab); |
| 39 } | 40 } |
| 40 | 41 |
| 42 void TrackInterstitialFrame(content::WebContents* tab, |
| 43 content::RenderFrameHost* interstitial_frame) { |
| 44 // |tab| should never be nullptr, because an interstitial's lifetime is |
| 45 // tied to a tab. This is a CHECK, not a DCHECK because we really need an |
| 46 // observer subject to detect frame removal (via DidDetachInterstitialPage). |
| 47 CHECK(tab); |
| 48 DCHECK(interstitial_frame); |
| 49 interstitial_frame_ = interstitial_frame; |
| 50 Observe(tab); |
| 51 } |
| 52 |
| 41 private: | 53 private: |
| 42 // content::WebContentsObserver overrides: | 54 // content::WebContentsObserver overrides: |
| 43 void RenderFrameDeleted(content::RenderFrameHost* render_frame_host) | 55 void RenderFrameDeleted(content::RenderFrameHost* render_frame_host) |
| 44 override { | 56 override { |
| 45 port_->UnregisterFrame(render_frame_host); | 57 port_->UnregisterFrame(render_frame_host); |
| 46 } | 58 } |
| 47 | 59 |
| 48 // TODO(robwu): This should be superfluous with RenderFrameDeleted above, but | |
| 49 // we are not entirely sure. | |
| 50 void FrameDeleted(content::RenderFrameHost* render_frame_host) override { | |
| 51 port_->UnregisterFrame(render_frame_host); | |
| 52 } | |
| 53 | |
| 54 void DidNavigateAnyFrame(content::RenderFrameHost* render_frame_host, | 60 void DidNavigateAnyFrame(content::RenderFrameHost* render_frame_host, |
| 55 const content::LoadCommittedDetails& details, | 61 const content::LoadCommittedDetails& details, |
| 56 const content::FrameNavigateParams&) override { | 62 const content::FrameNavigateParams&) override { |
| 57 if (!details.is_in_page) | 63 if (!details.is_in_page) |
| 58 port_->UnregisterFrame(render_frame_host); | 64 port_->UnregisterFrame(render_frame_host); |
| 59 } | 65 } |
| 60 | 66 |
| 67 void DidDetachInterstitialPage() override { |
| 68 if (interstitial_frame_) |
| 69 port_->UnregisterFrame(interstitial_frame_); |
| 70 } |
| 71 |
| 61 // extensions::ProcessManagerObserver overrides: | 72 // extensions::ProcessManagerObserver overrides: |
| 62 void OnExtensionFrameUnregistered( | 73 void OnExtensionFrameUnregistered( |
| 63 const std::string& extension_id, | 74 const std::string& extension_id, |
| 64 content::RenderFrameHost* render_frame_host) override { | 75 content::RenderFrameHost* render_frame_host) override { |
| 65 if (extension_id == port_->extension_id_) | 76 if (extension_id == port_->extension_id_) |
| 66 port_->UnregisterFrame(render_frame_host); | 77 port_->UnregisterFrame(render_frame_host); |
| 67 } | 78 } |
| 68 | 79 |
| 69 ScopedObserver<ProcessManager, ProcessManagerObserver> pm_observer_; | 80 ScopedObserver<ProcessManager, ProcessManagerObserver> pm_observer_; |
| 70 ExtensionMessagePort* port_; // Owns this FrameTracker. | 81 ExtensionMessagePort* port_; // Owns this FrameTracker. |
| 71 | 82 |
| 83 // Set to the main frame of an interstitial if we are tracking an interstitial |
| 84 // page, because RenderFrameDeleted is never triggered for frames in an |
| 85 // interstitial (and we only support tracking the interstitial's main frame). |
| 86 content::RenderFrameHost* interstitial_frame_; |
| 87 |
| 72 DISALLOW_COPY_AND_ASSIGN(FrameTracker); | 88 DISALLOW_COPY_AND_ASSIGN(FrameTracker); |
| 73 }; | 89 }; |
| 74 | 90 |
| 75 ExtensionMessagePort::ExtensionMessagePort( | 91 ExtensionMessagePort::ExtensionMessagePort( |
| 76 base::WeakPtr<MessageService> message_service, | 92 base::WeakPtr<MessageService> message_service, |
| 77 int port_id, | 93 int port_id, |
| 78 const std::string& extension_id, | 94 const std::string& extension_id, |
| 79 content::RenderProcessHost* extension_process) | 95 content::RenderProcessHost* extension_process) |
| 80 : weak_message_service_(message_service), | 96 : weak_message_service_(message_service), |
| 81 port_id_(port_id), | 97 port_id_(port_id), |
| (...skipping 19 matching lines...) Expand all Loading... |
| 101 bool include_child_frames) | 117 bool include_child_frames) |
| 102 : weak_message_service_(message_service), | 118 : weak_message_service_(message_service), |
| 103 port_id_(port_id), | 119 port_id_(port_id), |
| 104 extension_id_(extension_id), | 120 extension_id_(extension_id), |
| 105 browser_context_(rfh->GetProcess()->GetBrowserContext()), | 121 browser_context_(rfh->GetProcess()->GetBrowserContext()), |
| 106 extension_process_(nullptr), | 122 extension_process_(nullptr), |
| 107 did_create_port_(false), | 123 did_create_port_(false), |
| 108 background_host_ptr_(nullptr), | 124 background_host_ptr_(nullptr), |
| 109 frame_tracker_(new FrameTracker(this)) { | 125 frame_tracker_(new FrameTracker(this)) { |
| 110 content::WebContents* tab = content::WebContents::FromRenderFrameHost(rfh); | 126 content::WebContents* tab = content::WebContents::FromRenderFrameHost(rfh); |
| 111 CHECK(tab); | 127 if (!tab) { |
| 128 content::InterstitialPage* interstitial = |
| 129 content::InterstitialPage::FromRenderFrameHost(rfh); |
| 130 // A RenderFrameHost must be hosted in a WebContents or InterstitialPage. |
| 131 CHECK(interstitial); |
| 132 |
| 133 // Only the main frame of an interstitial is supported, because frames in |
| 134 // the interstitial do not trigger RenderFrameCreated / RenderFrameDeleted |
| 135 // on WebContentObservers. Consequently, (1) we cannot detect removal of |
| 136 // RenderFrameHosts, and (2) even if the RenderFrameDeleted is propagated, |
| 137 // then WebContentsObserverSanityChecker triggers a CHECK when it detects |
| 138 // frame notifications without a corresponding RenderFrameCreated. |
| 139 if (!rfh->GetParent()) { |
| 140 // It is safe to pass the interstitial's WebContents here because we only |
| 141 // use it to observe DidDetachInterstitialPage. |
| 142 frame_tracker_->TrackInterstitialFrame(interstitial->GetWebContents(), |
| 143 rfh); |
| 144 RegisterFrame(rfh); |
| 145 } |
| 146 return; |
| 147 } |
| 148 |
| 112 frame_tracker_->TrackTabFrames(tab); | 149 frame_tracker_->TrackTabFrames(tab); |
| 113 if (include_child_frames) { | 150 if (include_child_frames) { |
| 114 tab->ForEachFrame(base::Bind(&ExtensionMessagePort::RegisterFrame, | 151 tab->ForEachFrame(base::Bind(&ExtensionMessagePort::RegisterFrame, |
| 115 base::Unretained(this))); | 152 base::Unretained(this))); |
| 116 } else { | 153 } else { |
| 117 RegisterFrame(rfh); | 154 RegisterFrame(rfh); |
| 118 } | 155 } |
| 119 } | 156 } |
| 120 | 157 |
| 121 ExtensionMessagePort::~ExtensionMessagePort() {} | 158 ExtensionMessagePort::~ExtensionMessagePort() {} |
| (...skipping 129 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 251 return; | 288 return; |
| 252 } | 289 } |
| 253 for (content::RenderFrameHost* rfh : frames_) { | 290 for (content::RenderFrameHost* rfh : frames_) { |
| 254 IPC::Message* msg_copy = new IPC::Message(*msg.get()); | 291 IPC::Message* msg_copy = new IPC::Message(*msg.get()); |
| 255 msg_copy->set_routing_id(rfh->GetRoutingID()); | 292 msg_copy->set_routing_id(rfh->GetRoutingID()); |
| 256 rfh->Send(msg_copy); | 293 rfh->Send(msg_copy); |
| 257 } | 294 } |
| 258 } | 295 } |
| 259 | 296 |
| 260 } // namespace extensions | 297 } // namespace extensions |
| OLD | NEW |