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 |