Chromium Code Reviews| OLD | NEW |
|---|---|
| 1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 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 "extensions/browser/process_manager.h" | 5 #include "extensions/browser/process_manager.h" |
| 6 | 6 |
| 7 #include <vector> | 7 #include <vector> |
| 8 | 8 |
| 9 #include "base/bind.h" | 9 #include "base/bind.h" |
| 10 #include "base/logging.h" | 10 #include "base/logging.h" |
| (...skipping 279 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 290 FOR_EACH_OBSERVER(ProcessManagerObserver, | 290 FOR_EACH_OBSERVER(ProcessManagerObserver, |
| 291 observer_list_, | 291 observer_list_, |
| 292 OnExtensionFrameRegistered(extension->id(), | 292 OnExtensionFrameRegistered(extension->id(), |
| 293 render_frame_host)); | 293 render_frame_host)); |
| 294 } | 294 } |
| 295 | 295 |
| 296 void ProcessManager::UnregisterRenderFrameHost( | 296 void ProcessManager::UnregisterRenderFrameHost( |
| 297 content::RenderFrameHost* render_frame_host) { | 297 content::RenderFrameHost* render_frame_host) { |
| 298 ExtensionRenderFrames::iterator frame = | 298 ExtensionRenderFrames::iterator frame = |
| 299 all_extension_frames_.find(render_frame_host); | 299 all_extension_frames_.find(render_frame_host); |
| 300 | |
| 301 if (frame != all_extension_frames_.end()) { | 300 if (frame != all_extension_frames_.end()) { |
| 302 std::string extension_id = GetExtensionID(render_frame_host); | 301 std::string extension_id = GetExtensionID(render_frame_host); |
| 303 // Keepalive count, balanced in RegisterRenderFrame. | 302 // Keepalive count, balanced in RegisterRenderFrame. |
| 304 ReleaseLazyKeepaliveCountForFrame(render_frame_host); | 303 ReleaseLazyKeepaliveCountForFrame(render_frame_host); |
| 305 all_extension_frames_.erase(frame); | 304 all_extension_frames_.erase(frame); |
| 306 | 305 |
| 307 FOR_EACH_OBSERVER(ProcessManagerObserver, | 306 FOR_EACH_OBSERVER(ProcessManagerObserver, |
| 308 observer_list_, | 307 observer_list_, |
| 309 OnExtensionFrameUnregistered(extension_id, | 308 OnExtensionFrameUnregistered(extension_id, |
| 310 render_frame_host)); | 309 render_frame_host)); |
| (...skipping 251 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 562 extension_id, | 561 extension_id, |
| 563 sequence_id), | 562 sequence_id), |
| 564 base::TimeDelta::FromMilliseconds(g_event_page_suspending_time_msec)); | 563 base::TimeDelta::FromMilliseconds(g_event_page_suspending_time_msec)); |
| 565 } | 564 } |
| 566 | 565 |
| 567 void ProcessManager::OnNetworkRequestStarted( | 566 void ProcessManager::OnNetworkRequestStarted( |
| 568 content::RenderFrameHost* render_frame_host, | 567 content::RenderFrameHost* render_frame_host, |
| 569 uint64_t request_id) { | 568 uint64_t request_id) { |
| 570 ExtensionHost* host = GetBackgroundHostForExtension( | 569 ExtensionHost* host = GetBackgroundHostForExtension( |
| 571 GetExtensionID(render_frame_host)); | 570 GetExtensionID(render_frame_host)); |
| 572 auto result = pending_network_requests_.insert(request_id); | 571 if (!host || !IsFrameInExtensionHost(host, render_frame_host)) |
| 572 return; | |
| 573 | |
| 574 auto result = | |
| 575 pending_network_requests_.insert(std::make_pair(request_id, host)); | |
| 573 DCHECK(result.second) << "Duplicate network request IDs."; | 576 DCHECK(result.second) << "Duplicate network request IDs."; |
| 574 if (host && IsFrameInExtensionHost(host, render_frame_host)) { | 577 |
| 575 IncrementLazyKeepaliveCount(host->extension()); | 578 IncrementLazyKeepaliveCount(host->extension()); |
| 576 host->OnNetworkRequestStarted(request_id); | 579 host->OnNetworkRequestStarted(request_id); |
| 577 } | |
| 578 } | 580 } |
| 579 | 581 |
| 580 void ProcessManager::OnNetworkRequestDone( | 582 void ProcessManager::OnNetworkRequestDone( |
| 581 content::RenderFrameHost* render_frame_host, | 583 content::RenderFrameHost* render_frame_host, |
| 582 uint64_t request_id) { | 584 uint64_t request_id) { |
| 583 ExtensionHost* host = GetBackgroundHostForExtension( | 585 auto result = pending_network_requests_.find(request_id); |
| 584 GetExtensionID(render_frame_host)); | 586 if (result == pending_network_requests_.end()) |
| 585 if (host && IsFrameInExtensionHost(host, render_frame_host)) { | 587 return; |
| 586 host->OnNetworkRequestDone(request_id); | 588 |
| 587 if (pending_network_requests_.erase(request_id)) | 589 ExtensionHost* host = result->second; |
|
Devlin
2016/06/01 21:39:02
It might be worth noting that |host| can be invali
nasko
2016/06/01 23:17:51
Done.
| |
| 588 DecrementLazyKeepaliveCount(host->extension()); | 590 pending_network_requests_.erase(result); |
| 589 } | 591 |
| 592 if (background_hosts_.find(host) == background_hosts_.end()) | |
| 593 return; | |
| 594 | |
| 595 DCHECK(IsFrameInExtensionHost(host, render_frame_host)); | |
| 596 | |
| 597 host->OnNetworkRequestDone(request_id); | |
| 598 DecrementLazyKeepaliveCount(host->extension()); | |
| 590 } | 599 } |
| 591 | 600 |
| 592 void ProcessManager::CancelSuspend(const Extension* extension) { | 601 void ProcessManager::CancelSuspend(const Extension* extension) { |
| 593 bool& is_closing = background_page_data_[extension->id()].is_closing; | 602 bool& is_closing = background_page_data_[extension->id()].is_closing; |
| 594 ExtensionHost* host = GetBackgroundHostForExtension(extension->id()); | 603 ExtensionHost* host = GetBackgroundHostForExtension(extension->id()); |
| 595 if (host && is_closing) { | 604 if (host && is_closing) { |
| 596 is_closing = false; | 605 is_closing = false; |
| 597 host->render_process_host()->Send( | 606 host->render_process_host()->Send( |
| 598 new ExtensionMsg_CancelSuspend(extension->id())); | 607 new ExtensionMsg_CancelSuspend(extension->id())); |
| 599 // This increment / decrement is to simulate an instantaneous event. This | 608 // This increment / decrement is to simulate an instantaneous event. This |
| (...skipping 377 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 977 if (extension && !IncognitoInfo::IsSplitMode(extension)) { | 986 if (extension && !IncognitoInfo::IsSplitMode(extension)) { |
| 978 BrowserContext* original_context = | 987 BrowserContext* original_context = |
| 979 ExtensionsBrowserClient::Get()->GetOriginalContext(browser_context()); | 988 ExtensionsBrowserClient::Get()->GetOriginalContext(browser_context()); |
| 980 return ProcessManager::Get(original_context)->GetSiteInstanceForURL(url); | 989 return ProcessManager::Get(original_context)->GetSiteInstanceForURL(url); |
| 981 } | 990 } |
| 982 | 991 |
| 983 return ProcessManager::GetSiteInstanceForURL(url); | 992 return ProcessManager::GetSiteInstanceForURL(url); |
| 984 } | 993 } |
| 985 | 994 |
| 986 } // namespace extensions | 995 } // namespace extensions |
| OLD | NEW |