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 "content/browser/devtools/devtools_manager.h" | 5 #include "content/browser/devtools/devtools_manager.h" |
6 | 6 |
7 #include "base/bind.h" | 7 #include "base/bind.h" |
8 #include "base/message_loop/message_loop.h" | 8 #include "base/message_loop/message_loop.h" |
9 #include "content/browser/devtools/devtools_agent_host_impl.h" | |
10 #include "content/browser/devtools/devtools_netlog_observer.h" | 9 #include "content/browser/devtools/devtools_netlog_observer.h" |
11 #include "content/public/browser/browser_thread.h" | 10 #include "content/public/browser/browser_thread.h" |
12 #include "content/public/browser/content_browser_client.h" | 11 #include "content/public/browser/content_browser_client.h" |
| 12 #include "content/public/browser/devtools_manager_delegate.h" |
13 | 13 |
14 namespace content { | 14 namespace content { |
15 | 15 |
16 // static | 16 // static |
17 DevToolsManager* DevToolsManager::GetInstance() { | 17 DevToolsManager* DevToolsManager::GetInstance() { |
18 return Singleton<DevToolsManager>::get(); | 18 return Singleton<DevToolsManager>::get(); |
19 } | 19 } |
20 | 20 |
21 DevToolsManager::DevToolsManager() | 21 DevToolsManager::DevToolsManager() |
22 : delegate_(GetContentClient()->browser()->GetDevToolsManagerDelegate()), | 22 : delegate_(GetContentClient()->browser()->GetDevToolsManagerDelegate()), |
23 update_target_list_required_(false), | 23 client_count_(0) { |
24 update_target_list_scheduled_(false), | |
25 update_target_list_callback_(base::Bind( | |
26 &DevToolsManager::UpdateTargetListThrottled, | |
27 base::Unretained(this))) { | |
28 } | 24 } |
29 | 25 |
30 DevToolsManager::~DevToolsManager() { | 26 DevToolsManager::~DevToolsManager() { |
31 DCHECK(!attached_hosts_.size()); | 27 DCHECK(!client_count_); |
32 update_target_list_callback_.Cancel(); | |
33 } | 28 } |
34 | 29 |
35 void DevToolsManager::RenderViewCreated( | 30 void DevToolsManager::OnClientAttached() { |
36 WebContents* web_contents, RenderViewHost* rvh) { | 31 if (!client_count_) { |
37 if (observer_list_.might_have_observers()) { | 32 BrowserThread::PostTask( |
38 // Force agent host creation. | 33 BrowserThread::IO, |
39 DevToolsAgentHost::GetOrCreateFor(web_contents); | 34 FROM_HERE, |
| 35 base::Bind(&DevToolsNetLogObserver::Attach)); |
| 36 } |
| 37 client_count_++; |
| 38 } |
| 39 |
| 40 void DevToolsManager::OnClientDetached() { |
| 41 client_count_--; |
| 42 if (!client_count_) { |
| 43 BrowserThread::PostTask( |
| 44 BrowserThread::IO, |
| 45 FROM_HERE, |
| 46 base::Bind(&DevToolsNetLogObserver::Detach)); |
40 } | 47 } |
41 } | 48 } |
42 | 49 |
43 void DevToolsManager::AgentHostChanged( | |
44 scoped_refptr<DevToolsAgentHost> agent_host) { | |
45 bool was_attached = | |
46 attached_hosts_.find(agent_host.get()) != attached_hosts_.end(); | |
47 if (agent_host->IsAttached() && !was_attached) { | |
48 if (!attached_hosts_.size()) { | |
49 BrowserThread::PostTask( | |
50 BrowserThread::IO, | |
51 FROM_HERE, | |
52 base::Bind(&DevToolsNetLogObserver::Attach)); | |
53 } | |
54 attached_hosts_.insert(agent_host.get()); | |
55 } else if (!agent_host->IsAttached() && was_attached) { | |
56 attached_hosts_.erase(agent_host.get()); | |
57 if (!attached_hosts_.size()) { | |
58 BrowserThread::PostTask( | |
59 BrowserThread::IO, | |
60 FROM_HERE, | |
61 base::Bind(&DevToolsNetLogObserver::Detach)); | |
62 } | |
63 } | |
64 | |
65 UpdateTargetList(); | |
66 } | |
67 | |
68 void DevToolsManager::AddObserver(Observer* observer) { | |
69 observer_list_.AddObserver(observer); | |
70 UpdateTargetList(); | |
71 } | |
72 | |
73 void DevToolsManager::RemoveObserver(Observer* observer) { | |
74 observer_list_.RemoveObserver(observer); | |
75 } | |
76 | |
77 void DevToolsManager::UpdateTargetList() { | |
78 if (!observer_list_.might_have_observers()) | |
79 return; | |
80 | |
81 update_target_list_required_ = true; | |
82 if (!update_target_list_scheduled_) | |
83 UpdateTargetListThrottled(); | |
84 } | |
85 | |
86 void DevToolsManager::UpdateTargetListThrottled() { | |
87 if (!update_target_list_required_) { | |
88 update_target_list_scheduled_ = false; | |
89 return; | |
90 } | |
91 | |
92 update_target_list_scheduled_ = true; | |
93 base::MessageLoop::current()->PostDelayedTask( | |
94 FROM_HERE, | |
95 update_target_list_callback_.callback(), | |
96 observer_throttle_interval_); | |
97 | |
98 update_target_list_required_ = false; | |
99 if (!delegate_) { | |
100 Observer::TargetList empty_list; | |
101 NotifyTargetListChanged(empty_list); | |
102 return; | |
103 } | |
104 delegate_->EnumerateTargets(base::Bind( | |
105 &DevToolsManager::NotifyTargetListChanged, | |
106 base::Unretained(this))); | |
107 } | |
108 | |
109 void DevToolsManager::NotifyTargetListChanged( | |
110 const Observer::TargetList& targets) { | |
111 FOR_EACH_OBSERVER(Observer, observer_list_, TargetListChanged(targets)); | |
112 } | |
113 | |
114 // static | |
115 base::TimeDelta DevToolsManager::observer_throttle_interval_ = | |
116 base::TimeDelta::FromMilliseconds(500); | |
117 | |
118 // static | |
119 void DevToolsManager::SetObserverThrottleIntervalForTest( | |
120 base::TimeDelta interval) { | |
121 observer_throttle_interval_ = interval; | |
122 } | |
123 | |
124 } // namespace content | 50 } // namespace content |
OLD | NEW |