OLD | NEW |
1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 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/devtools/device/devtools_android_bridge.h" | 5 #include "chrome/browser/devtools/device/devtools_android_bridge.h" |
6 | 6 |
7 #include <map> | 7 #include <map> |
8 #include <vector> | 8 #include <vector> |
9 | 9 |
10 #include "base/base64.h" | 10 #include "base/base64.h" |
(...skipping 23 matching lines...) Expand all Loading... |
34 #include "content/public/browser/devtools_agent_host.h" | 34 #include "content/public/browser/devtools_agent_host.h" |
35 #include "content/public/browser/devtools_external_agent_proxy.h" | 35 #include "content/public/browser/devtools_external_agent_proxy.h" |
36 #include "content/public/browser/devtools_external_agent_proxy_delegate.h" | 36 #include "content/public/browser/devtools_external_agent_proxy_delegate.h" |
37 #include "content/public/browser/user_metrics.h" | 37 #include "content/public/browser/user_metrics.h" |
38 #include "net/base/escape.h" | 38 #include "net/base/escape.h" |
39 | 39 |
40 using content::BrowserThread; | 40 using content::BrowserThread; |
41 | 41 |
42 namespace { | 42 namespace { |
43 | 43 |
44 const char kModelOffline[] = "Offline"; | |
45 | |
46 const char kPageListRequest[] = "/json"; | 44 const char kPageListRequest[] = "/json"; |
47 const char kVersionRequest[] = "/json/version"; | 45 const char kVersionRequest[] = "/json/version"; |
48 const char kClosePageRequest[] = "/json/close/%s"; | 46 const char kClosePageRequest[] = "/json/close/%s"; |
49 const char kNewPageRequest[] = "/json/new"; | 47 const char kNewPageRequest[] = "/json/new"; |
50 const char kNewPageRequestWithURL[] = "/json/new?%s"; | 48 const char kNewPageRequestWithURL[] = "/json/new?%s"; |
51 const char kActivatePageRequest[] = "/json/activate/%s"; | 49 const char kActivatePageRequest[] = "/json/activate/%s"; |
52 const char kBrowserTargetSocket[] = "/devtools/browser"; | 50 const char kBrowserTargetSocket[] = "/devtools/browser"; |
53 const int kAdbPollingIntervalMs = 1000; | 51 const int kAdbPollingIntervalMs = 1000; |
54 | 52 |
55 const char kUrlParam[] = "url"; | 53 const char kUrlParam[] = "url"; |
56 const char kPageReloadCommand[] = "Page.reload"; | 54 const char kPageReloadCommand[] = "Page.reload"; |
57 const char kPageNavigateCommand[] = "Page.navigate"; | 55 const char kPageNavigateCommand[] = "Page.navigate"; |
58 | 56 |
59 const int kMinVersionNewWithURL = 32; | 57 const int kMinVersionNewWithURL = 32; |
60 const int kNewPageNavigateDelayMs = 500; | 58 const int kNewPageNavigateDelayMs = 500; |
61 | 59 |
62 // DiscoveryRequest ----------------------------------------------------- | 60 // DiscoveryRequest ----------------------------------------------------- |
63 | 61 |
64 class DiscoveryRequest : public base::RefCountedThreadSafe< | 62 class DiscoveryRequest : public base::RefCountedThreadSafe< |
65 DiscoveryRequest, | 63 DiscoveryRequest, |
66 BrowserThread::DeleteOnUIThread> { | 64 BrowserThread::DeleteOnUIThread> { |
67 public: | 65 public: |
68 typedef base::Callback<void(DevToolsAndroidBridge::RemoteDevices*)> Callback; | 66 typedef base::Callback<void(scoped_ptr<DevToolsAndroidBridge::RemoteDevices>)> |
| 67 DiscoveryCallback; |
| 68 typedef AndroidDeviceManager::Device Device; |
| 69 typedef AndroidDeviceManager::Devices Devices; |
69 | 70 |
70 DiscoveryRequest( | 71 DiscoveryRequest( |
71 scoped_refptr<DevToolsAndroidBridge> android_bridge, | |
72 AndroidDeviceManager* device_manager, | 72 AndroidDeviceManager* device_manager, |
73 base::MessageLoop* device_message_loop, | 73 const DiscoveryCallback& callback); |
74 const AndroidDeviceManager::DeviceProviders& device_providers, | |
75 const Callback& callback); | |
76 | 74 |
77 private: | 75 private: |
78 friend struct BrowserThread::DeleteOnThread<BrowserThread::UI>; | 76 friend struct BrowserThread::DeleteOnThread<BrowserThread::UI>; |
79 friend class base::DeleteHelper<DiscoveryRequest>; | 77 friend class base::DeleteHelper<DiscoveryRequest>; |
80 | 78 |
81 virtual ~DiscoveryRequest(); | 79 virtual ~DiscoveryRequest(); |
82 | 80 |
83 void ReceivedSerials(const std::vector<std::string>& serials); | 81 void ReceivedDevices(const Devices& devices); |
84 void ProcessSerials(); | 82 void ProcessDevices(); |
85 void ReceivedDeviceInfo(const AndroidDeviceManager::DeviceInfo& device_info); | 83 void ReceivedDeviceInfo(const AndroidDeviceManager::DeviceInfo& device_info); |
86 void ProcessSockets(); | 84 void ProcessSockets(); |
87 void ReceivedVersion(int result, const std::string& response); | 85 void ReceivedVersion(int result, const std::string& response); |
88 void ReceivedPages(int result, const std::string& response); | 86 void ReceivedPages(int result, const std::string& response); |
89 | 87 |
90 std::string current_serial() const { return serials_.back(); } | 88 scoped_refptr<Device> current_device() { return devices_.back(); } |
91 | 89 |
92 scoped_refptr<DevToolsAndroidBridge::RemoteBrowser> current_browser() const { | 90 scoped_refptr<DevToolsAndroidBridge::RemoteBrowser> current_browser() const { |
93 return browsers_.back(); | 91 return browsers_.back(); |
94 } | 92 } |
95 | 93 |
96 void NextBrowser(); | 94 void NextBrowser(); |
97 void NextDevice(); | 95 void NextDevice(); |
98 | 96 |
99 void Respond(); | 97 void Respond(); |
100 | 98 |
101 scoped_refptr<DevToolsAndroidBridge> android_bridge_; | 99 DiscoveryCallback callback_; |
102 AndroidDeviceManager* device_manager_; | 100 Devices devices_; |
103 base::MessageLoop* device_message_loop_; | |
104 Callback callback_; | |
105 std::vector<std::string> serials_; | |
106 DevToolsAndroidBridge::RemoteBrowsers browsers_; | 101 DevToolsAndroidBridge::RemoteBrowsers browsers_; |
107 scoped_ptr<DevToolsAndroidBridge::RemoteDevices> remote_devices_; | 102 scoped_ptr<DevToolsAndroidBridge::RemoteDevices> remote_devices_; |
108 }; | 103 }; |
109 | 104 |
110 DiscoveryRequest::DiscoveryRequest( | 105 DiscoveryRequest::DiscoveryRequest( |
111 scoped_refptr<DevToolsAndroidBridge> android_bridge, | |
112 AndroidDeviceManager* device_manager, | 106 AndroidDeviceManager* device_manager, |
113 base::MessageLoop* device_message_loop, | 107 const DiscoveryCallback& callback) |
114 const AndroidDeviceManager::DeviceProviders& device_providers, | 108 : callback_(callback) { |
115 const Callback& callback) | 109 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
116 : android_bridge_(android_bridge), | |
117 device_manager_(device_manager), | |
118 device_message_loop_(device_message_loop), | |
119 callback_(callback) { | |
120 remote_devices_.reset(new DevToolsAndroidBridge::RemoteDevices()); | 110 remote_devices_.reset(new DevToolsAndroidBridge::RemoteDevices()); |
121 | 111 |
122 device_message_loop_->PostTask( | 112 device_manager->QueryDevices( |
123 FROM_HERE, base::Bind( | 113 base::Bind(&DiscoveryRequest::ReceivedDevices, this)); |
124 &AndroidDeviceManager::QueryDevices, | |
125 device_manager_, | |
126 device_providers, | |
127 base::Bind(&DiscoveryRequest::ReceivedSerials, this))); | |
128 } | 114 } |
129 | 115 |
130 DiscoveryRequest::~DiscoveryRequest() { | 116 DiscoveryRequest::~DiscoveryRequest() { |
131 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 117 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
132 } | 118 } |
133 | 119 |
134 void DiscoveryRequest::ReceivedSerials( | 120 void DiscoveryRequest::ReceivedDevices(const Devices& devices) { |
135 const std::vector<std::string>& serials) { | 121 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
136 DCHECK_EQ(device_message_loop_, base::MessageLoop::current()); | 122 devices_ = devices; |
137 serials_ = serials; | 123 ProcessDevices(); |
138 ProcessSerials(); | |
139 } | 124 } |
140 | 125 |
141 void DiscoveryRequest::ProcessSerials() { | 126 void DiscoveryRequest::ProcessDevices() { |
142 DCHECK_EQ(device_message_loop_, base::MessageLoop::current()); | 127 if (devices_.size() == 0) { |
143 if (serials_.size() == 0) { | 128 Respond(); |
144 BrowserThread::PostTask( | |
145 BrowserThread::UI, FROM_HERE, | |
146 base::Bind(&DiscoveryRequest::Respond, this)); | |
147 return; | 129 return; |
148 } | 130 } |
149 | 131 |
150 if (device_manager_->IsConnected(current_serial())) { | 132 current_device()->QueryDeviceInfo( |
151 device_manager_->QueryDeviceInfo(current_serial(), | 133 base::Bind(&DiscoveryRequest::ReceivedDeviceInfo, this)); |
152 base::Bind(&DiscoveryRequest::ReceivedDeviceInfo, this)); | |
153 } else { | |
154 AndroidDeviceManager::DeviceInfo offline_info; | |
155 offline_info.model = kModelOffline; | |
156 remote_devices_->push_back(new DevToolsAndroidBridge::RemoteDevice( | |
157 android_bridge_, current_serial(), offline_info, false)); | |
158 NextDevice(); | |
159 } | |
160 } | 134 } |
161 | 135 |
162 void DiscoveryRequest::ReceivedDeviceInfo( | 136 void DiscoveryRequest::ReceivedDeviceInfo( |
163 const AndroidDeviceManager::DeviceInfo& device_info) { | 137 const AndroidDeviceManager::DeviceInfo& device_info) { |
164 remote_devices_->push_back(new DevToolsAndroidBridge::RemoteDevice( | 138 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
165 android_bridge_, current_serial(), device_info, true)); | 139 remote_devices_->push_back( |
| 140 new DevToolsAndroidBridge::RemoteDevice(current_device(), device_info)); |
166 browsers_ = remote_devices_->back()->browsers(); | 141 browsers_ = remote_devices_->back()->browsers(); |
167 ProcessSockets(); | 142 ProcessSockets(); |
168 } | 143 } |
169 | 144 |
170 void DiscoveryRequest::ProcessSockets() { | 145 void DiscoveryRequest::ProcessSockets() { |
171 DCHECK_EQ(device_message_loop_, base::MessageLoop::current()); | |
172 if (browsers_.size() == 0) { | 146 if (browsers_.size() == 0) { |
173 NextDevice(); | 147 NextDevice(); |
174 return; | 148 return; |
175 } | 149 } |
176 | 150 |
177 device_manager_->HttpQuery( | 151 current_device()->SendJsonRequest( |
178 current_serial(), | |
179 current_browser()->socket(), | 152 current_browser()->socket(), |
180 kVersionRequest, | 153 kVersionRequest, |
181 base::Bind(&DiscoveryRequest::ReceivedVersion, this)); | 154 base::Bind(&DiscoveryRequest::ReceivedVersion, this)); |
182 } | 155 } |
183 | 156 |
184 void DiscoveryRequest::ReceivedVersion(int result, | 157 void DiscoveryRequest::ReceivedVersion(int result, |
185 const std::string& response) { | 158 const std::string& response) { |
186 DCHECK_EQ(device_message_loop_, base::MessageLoop::current()); | 159 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
187 if (result < 0) { | 160 if (result < 0) { |
188 NextBrowser(); | 161 NextBrowser(); |
189 return; | 162 return; |
190 } | 163 } |
191 | 164 |
192 // Parse version, append to package name if available, | 165 // Parse version, append to package name if available, |
193 scoped_ptr<base::Value> value(base::JSONReader::Read(response)); | 166 scoped_ptr<base::Value> value(base::JSONReader::Read(response)); |
194 base::DictionaryValue* dict; | 167 base::DictionaryValue* dict; |
195 if (value && value->GetAsDictionary(&dict)) { | 168 if (value && value->GetAsDictionary(&dict)) { |
196 std::string browser; | 169 std::string browser; |
197 if (dict->GetString("Browser", &browser)) { | 170 if (dict->GetString("Browser", &browser)) { |
198 std::vector<std::string> parts; | 171 std::vector<std::string> parts; |
199 Tokenize(browser, "/", &parts); | 172 Tokenize(browser, "/", &parts); |
200 if (parts.size() == 2) | 173 if (parts.size() == 2) |
201 current_browser()->set_version(parts[1]); | 174 current_browser()->set_version(parts[1]); |
202 else | 175 else |
203 current_browser()->set_version(browser); | 176 current_browser()->set_version(browser); |
204 } | 177 } |
205 std::string package; | 178 std::string package; |
206 if (dict->GetString("Android-Package", &package)) { | 179 if (dict->GetString("Android-Package", &package)) { |
207 current_browser()->set_display_name( | 180 current_browser()->set_display_name( |
208 AdbDeviceInfoQuery::GetDisplayName(current_browser()->socket(), | 181 AdbDeviceInfoQuery::GetDisplayName(current_browser()->socket(), |
209 package)); | 182 package)); |
210 } | 183 } |
211 } | 184 } |
212 | 185 |
213 device_manager_->HttpQuery( | 186 current_device()->SendJsonRequest( |
214 current_serial(), | |
215 current_browser()->socket(), | 187 current_browser()->socket(), |
216 kPageListRequest, | 188 kPageListRequest, |
217 base::Bind(&DiscoveryRequest::ReceivedPages, this)); | 189 base::Bind(&DiscoveryRequest::ReceivedPages, this)); |
218 } | 190 } |
219 | 191 |
220 void DiscoveryRequest::ReceivedPages(int result, | 192 void DiscoveryRequest::ReceivedPages(int result, |
221 const std::string& response) { | 193 const std::string& response) { |
222 DCHECK_EQ(device_message_loop_, base::MessageLoop::current()); | 194 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
223 if (result >= 0) { | 195 if (result >= 0) { |
224 scoped_ptr<base::Value> value(base::JSONReader::Read(response)); | 196 scoped_ptr<base::Value> value(base::JSONReader::Read(response)); |
225 base::ListValue* list_value; | 197 base::ListValue* list_value; |
226 if (value && value->GetAsList(&list_value)) | 198 if (value && value->GetAsList(&list_value)) |
227 current_browser()->SetPageDescriptors(*list_value); | 199 current_browser()->SetPageDescriptors(*list_value); |
228 } | 200 } |
229 NextBrowser(); | 201 NextBrowser(); |
230 } | 202 } |
231 | 203 |
232 void DiscoveryRequest::NextBrowser() { | 204 void DiscoveryRequest::NextBrowser() { |
233 browsers_.pop_back(); | 205 browsers_.pop_back(); |
234 ProcessSockets(); | 206 ProcessSockets(); |
235 } | 207 } |
236 | 208 |
237 void DiscoveryRequest::NextDevice() { | 209 void DiscoveryRequest::NextDevice() { |
238 serials_.pop_back(); | 210 devices_.pop_back(); |
239 ProcessSerials(); | 211 ProcessDevices(); |
240 } | 212 } |
241 | 213 |
242 void DiscoveryRequest::Respond() { | 214 void DiscoveryRequest::Respond() { |
243 callback_.Run(remote_devices_.release()); | 215 callback_.Run(remote_devices_.Pass()); |
244 } | 216 } |
245 | 217 |
246 // ProtocolCommand ------------------------------------------------------------ | 218 // ProtocolCommand ------------------------------------------------------------ |
247 | 219 |
248 class ProtocolCommand | 220 class ProtocolCommand |
249 : public DevToolsAndroidBridge::AndroidWebSocket::Delegate { | 221 : public DevToolsAndroidBridge::AndroidWebSocket::Delegate { |
250 public: | 222 public: |
251 ProtocolCommand( | 223 ProtocolCommand( |
252 scoped_refptr<DevToolsAndroidBridge::RemoteBrowser> browser, | 224 scoped_refptr<DevToolsAndroidBridge::RemoteBrowser> browser, |
253 const std::string& debug_url, | 225 const std::string& debug_url, |
(...skipping 327 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
581 base::Closure callback) const { | 553 base::Closure callback) const { |
582 base::DictionaryValue params; | 554 base::DictionaryValue params; |
583 params.SetString(kUrlParam, url); | 555 params.SetString(kUrlParam, url); |
584 browser_->SendProtocolCommand(debug_url_, kPageNavigateCommand, ¶ms, | 556 browser_->SendProtocolCommand(debug_url_, kPageNavigateCommand, ¶ms, |
585 callback); | 557 callback); |
586 } | 558 } |
587 | 559 |
588 // DevToolsAndroidBridge::RemoteBrowser --------------------------------------- | 560 // DevToolsAndroidBridge::RemoteBrowser --------------------------------------- |
589 | 561 |
590 DevToolsAndroidBridge::RemoteBrowser::RemoteBrowser( | 562 DevToolsAndroidBridge::RemoteBrowser::RemoteBrowser( |
591 scoped_refptr<DevToolsAndroidBridge> android_bridge, | 563 scoped_refptr<Device> device, |
592 const std::string& serial, | |
593 const AndroidDeviceManager::BrowserInfo& browser_info) | 564 const AndroidDeviceManager::BrowserInfo& browser_info) |
594 : android_bridge_(android_bridge), | 565 : device_(device), |
595 serial_(serial), | |
596 socket_(browser_info.socket_name), | 566 socket_(browser_info.socket_name), |
597 display_name_(browser_info.display_name), | 567 display_name_(browser_info.display_name), |
598 type_(browser_info.type), | 568 type_(browser_info.type), |
599 page_descriptors_(new base::ListValue()) { | 569 page_descriptors_(new base::ListValue()) { |
600 } | 570 } |
601 | 571 |
602 bool DevToolsAndroidBridge::RemoteBrowser::IsChrome() const { | 572 bool DevToolsAndroidBridge::RemoteBrowser::IsChrome() const { |
603 return type_ == AndroidDeviceManager::BrowserInfo::kTypeChrome; | 573 return type_ == AndroidDeviceManager::BrowserInfo::kTypeChrome; |
604 } | 574 } |
605 | 575 |
(...skipping 29 matching lines...) Expand all Loading... |
635 } | 605 } |
636 return result; | 606 return result; |
637 } | 607 } |
638 | 608 |
639 void DevToolsAndroidBridge::RemoteBrowser::SetPageDescriptors( | 609 void DevToolsAndroidBridge::RemoteBrowser::SetPageDescriptors( |
640 const base::ListValue& list) { | 610 const base::ListValue& list) { |
641 page_descriptors_.reset(list.DeepCopy()); | 611 page_descriptors_.reset(list.DeepCopy()); |
642 } | 612 } |
643 | 613 |
644 static void RespondOnUIThread( | 614 static void RespondOnUIThread( |
645 const DevToolsAndroidBridge::RemoteBrowser::JsonRequestCallback& callback, | 615 const DevToolsAndroidBridge::JsonRequestCallback& callback, |
646 int result, | 616 int result, |
647 const std::string& response) { | 617 const std::string& response) { |
648 if (callback.is_null()) | 618 if (callback.is_null()) |
649 return; | 619 return; |
650 BrowserThread::PostTask( | 620 BrowserThread::PostTask( |
651 BrowserThread::UI, FROM_HERE, base::Bind(callback, result, response)); | 621 BrowserThread::UI, FROM_HERE, base::Bind(callback, result, response)); |
652 } | 622 } |
653 | 623 |
654 void DevToolsAndroidBridge::RemoteBrowser::SendJsonRequest( | 624 void DevToolsAndroidBridge::RemoteBrowser::SendJsonRequest( |
655 const std::string& request, const JsonRequestCallback& callback) { | 625 const std::string& request, const JsonRequestCallback& callback) { |
656 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 626 device_->SendJsonRequest(socket_, request, callback); |
657 android_bridge_->device_message_loop()->PostTask( | |
658 FROM_HERE, | |
659 base::Bind(&AndroidDeviceManager::HttpQuery, | |
660 android_bridge_->device_manager(), serial_, socket_, request, | |
661 base::Bind(&RespondOnUIThread, callback))); | |
662 } | 627 } |
663 | 628 |
664 void DevToolsAndroidBridge::RemoteBrowser::SendProtocolCommand( | 629 void DevToolsAndroidBridge::RemoteBrowser::SendProtocolCommand( |
665 const std::string& debug_url, | 630 const std::string& debug_url, |
666 const std::string& method, | 631 const std::string& method, |
667 base::DictionaryValue* params, | 632 base::DictionaryValue* params, |
668 const base::Closure callback) { | 633 const base::Closure callback) { |
669 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 634 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
670 if (debug_url.empty()) | 635 if (debug_url.empty()) |
671 return; | 636 return; |
672 DevToolsProtocol::Command command(1, method, params); | 637 DevToolsProtocol::Command command(1, method, params); |
673 new ProtocolCommand(this, debug_url, command.Serialize(), callback); | 638 new ProtocolCommand(this, debug_url, command.Serialize(), callback); |
674 } | 639 } |
675 | 640 |
676 void DevToolsAndroidBridge::RemoteBrowser::Open( | 641 void DevToolsAndroidBridge::RemoteBrowser::Open( |
677 const std::string& url, | 642 const std::string& url, |
678 const DevToolsAndroidBridge::RemotePageCallback& callback) { | 643 const DevToolsAndroidBridge::RemotePageCallback& callback) { |
679 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 644 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
680 InnerOpen(url, base::Bind(&RemoteBrowser::RespondToOpenOnUIThread, | 645 InnerOpen(url, base::Bind(&RemoteBrowser::RespondToOpenOnUIThread, |
681 this, callback)); | 646 this, callback)); |
682 } | 647 } |
683 | 648 |
684 scoped_refptr<content::DevToolsAgentHost> | 649 scoped_refptr<content::DevToolsAgentHost> |
685 DevToolsAndroidBridge::RemoteBrowser::GetAgentHost() { | 650 DevToolsAndroidBridge::RemoteBrowser::GetAgentHost() { |
686 return AgentHostDelegate::GetOrCreateAgentHost( | 651 return AgentHostDelegate::GetOrCreateAgentHost( |
687 "adb:" + serial_ + ":" + socket_, this, kBrowserTargetSocket); | 652 "adb:" + device_->serial() + ":" + socket_, this, kBrowserTargetSocket); |
| 653 } |
| 654 |
| 655 scoped_refptr<DevToolsAndroidBridge::AndroidWebSocket> |
| 656 DevToolsAndroidBridge::RemoteBrowser::CreateWebSocket( |
| 657 const std::string& url, |
| 658 DevToolsAndroidBridge::AndroidWebSocket::Delegate* delegate) { |
| 659 return device_->CreateWebSocket(socket_, url, delegate); |
688 } | 660 } |
689 | 661 |
690 void DevToolsAndroidBridge::RemoteBrowser::RespondToOpenOnUIThread( | 662 void DevToolsAndroidBridge::RemoteBrowser::RespondToOpenOnUIThread( |
691 const DevToolsAndroidBridge::RemotePageCallback& callback, | 663 const DevToolsAndroidBridge::RemotePageCallback& callback, |
692 int result, | 664 int result, |
693 const std::string& response) { | 665 const std::string& response) { |
694 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 666 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
695 if (result < 0) { | 667 if (result < 0) { |
696 callback.Run(NULL); | 668 callback.Run(NULL); |
697 return; | 669 return; |
(...skipping 59 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
757 if (value && value->GetAsDictionary(&dict)) { | 729 if (value && value->GetAsDictionary(&dict)) { |
758 RemotePageTarget new_page(this, *dict); | 730 RemotePageTarget new_page(this, *dict); |
759 new_page.Navigate(url, | 731 new_page.Navigate(url, |
760 base::Bind(&RespondOnUIThread, callback, result, response)); | 732 base::Bind(&RespondOnUIThread, callback, result, response)); |
761 } | 733 } |
762 } | 734 } |
763 | 735 |
764 DevToolsAndroidBridge::RemoteBrowser::~RemoteBrowser() { | 736 DevToolsAndroidBridge::RemoteBrowser::~RemoteBrowser() { |
765 } | 737 } |
766 | 738 |
767 | |
768 // DevToolsAndroidBridge::RemoteDevice ---------------------------------------- | 739 // DevToolsAndroidBridge::RemoteDevice ---------------------------------------- |
769 | 740 |
770 DevToolsAndroidBridge::RemoteDevice::RemoteDevice( | 741 DevToolsAndroidBridge::RemoteDevice::RemoteDevice( |
771 scoped_refptr<DevToolsAndroidBridge> android_bridge, | 742 scoped_refptr<AndroidDeviceManager::Device> device, |
772 const std::string& serial, | 743 const AndroidDeviceManager::DeviceInfo& device_info) |
773 const AndroidDeviceManager::DeviceInfo& device_info, | 744 : device_(device), |
774 bool connected) | |
775 : android_bridge_(android_bridge), | |
776 serial_(serial), | |
777 model_(device_info.model), | 745 model_(device_info.model), |
778 connected_(connected), | 746 connected_(device_info.connected), |
779 screen_size_(device_info.screen_size) { | 747 screen_size_(device_info.screen_size) { |
780 for (std::vector<AndroidDeviceManager::BrowserInfo>::const_iterator it = | 748 for (std::vector<AndroidDeviceManager::BrowserInfo>::const_iterator it = |
781 device_info.browser_info.begin(); | 749 device_info.browser_info.begin(); |
782 it != device_info.browser_info.end(); | 750 it != device_info.browser_info.end(); |
783 ++it) { | 751 ++it) { |
784 browsers_.push_back(new DevToolsAndroidBridge::RemoteBrowser( | 752 browsers_.push_back(new DevToolsAndroidBridge::RemoteBrowser(device, *it)); |
785 android_bridge_, serial_, *it)); | |
786 } | 753 } |
787 } | 754 } |
788 | 755 |
789 void DevToolsAndroidBridge::RemoteDevice::OpenSocket( | 756 void DevToolsAndroidBridge::RemoteDevice::OpenSocket( |
790 const std::string& socket_name, | 757 const std::string& socket_name, |
791 const AndroidDeviceManager::SocketCallback& callback) { | 758 const AndroidDeviceManager::SocketCallback& callback) { |
792 android_bridge_->device_message_loop()->PostTask(FROM_HERE, | 759 device_->OpenSocket(socket_name, callback); |
793 base::Bind(&AndroidDeviceManager::OpenSocket, | |
794 android_bridge_->device_manager(), | |
795 serial_, | |
796 socket_name, | |
797 callback)); | |
798 } | 760 } |
799 | 761 |
800 DevToolsAndroidBridge::RemoteDevice::~RemoteDevice() { | 762 DevToolsAndroidBridge::RemoteDevice::~RemoteDevice() { |
801 } | 763 } |
802 | 764 |
803 // DevToolsAndroidBridge::HandlerThread --------------------------------- | |
804 | |
805 const char kDevToolsAdbBridgeThreadName[] = "Chrome_DevToolsADBThread"; | |
806 | |
807 DevToolsAndroidBridge::HandlerThread* | |
808 DevToolsAndroidBridge::HandlerThread::instance_ = NULL; | |
809 | |
810 // static | |
811 scoped_refptr<DevToolsAndroidBridge::HandlerThread> | |
812 DevToolsAndroidBridge::HandlerThread::GetInstance() { | |
813 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | |
814 if (!instance_) | |
815 new HandlerThread(); | |
816 return instance_; | |
817 } | |
818 | |
819 DevToolsAndroidBridge::HandlerThread::HandlerThread() { | |
820 instance_ = this; | |
821 thread_ = new base::Thread(kDevToolsAdbBridgeThreadName); | |
822 base::Thread::Options options; | |
823 options.message_loop_type = base::MessageLoop::TYPE_IO; | |
824 if (!thread_->StartWithOptions(options)) { | |
825 delete thread_; | |
826 thread_ = NULL; | |
827 } | |
828 } | |
829 | |
830 base::MessageLoop* DevToolsAndroidBridge::HandlerThread::message_loop() { | |
831 return thread_ ? thread_->message_loop() : NULL; | |
832 } | |
833 | |
834 // static | |
835 void DevToolsAndroidBridge::HandlerThread::StopThread( | |
836 base::Thread* thread) { | |
837 thread->Stop(); | |
838 } | |
839 | |
840 DevToolsAndroidBridge::HandlerThread::~HandlerThread() { | |
841 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | |
842 instance_ = NULL; | |
843 if (!thread_) | |
844 return; | |
845 // Shut down thread on FILE thread to join into IO. | |
846 BrowserThread::PostTask( | |
847 BrowserThread::FILE, FROM_HERE, | |
848 base::Bind(&HandlerThread::StopThread, thread_)); | |
849 } | |
850 | |
851 // DevToolsAndroidBridge ------------------------------------------------------ | 765 // DevToolsAndroidBridge ------------------------------------------------------ |
852 | 766 |
853 DevToolsAndroidBridge::DevToolsAndroidBridge(Profile* profile) | 767 DevToolsAndroidBridge::DevToolsAndroidBridge(Profile* profile) |
854 : profile_(profile), | 768 : profile_(profile), |
855 handler_thread_(HandlerThread::GetInstance()) { | 769 device_manager_(AndroidDeviceManager::Create()) { |
856 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 770 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
857 pref_change_registrar_.Init(profile_->GetPrefs()); | 771 pref_change_registrar_.Init(profile_->GetPrefs()); |
858 pref_change_registrar_.Add(prefs::kDevToolsDiscoverUsbDevicesEnabled, | 772 pref_change_registrar_.Add(prefs::kDevToolsDiscoverUsbDevicesEnabled, |
859 base::Bind(&DevToolsAndroidBridge::CreateDeviceProviders, | 773 base::Bind(&DevToolsAndroidBridge::CreateDeviceProviders, |
860 base::Unretained(this))); | 774 base::Unretained(this))); |
861 CreateDeviceProviders(); | 775 CreateDeviceProviders(); |
862 base::PostTaskAndReplyWithResult( | |
863 device_message_loop()->message_loop_proxy(), | |
864 FROM_HERE, | |
865 base::Bind(&AndroidDeviceManager::Create), | |
866 base::Bind(&DevToolsAndroidBridge::CreatedDeviceManager, this)); | |
867 } | 776 } |
868 | 777 |
869 void DevToolsAndroidBridge::AddDeviceListListener( | 778 void DevToolsAndroidBridge::AddDeviceListListener( |
870 DeviceListListener* listener) { | 779 DeviceListListener* listener) { |
871 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 780 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
872 device_list_listeners_.push_back(listener); | 781 device_list_listeners_.push_back(listener); |
873 if (device_list_listeners_.size() == 1 && device_manager_) | 782 if (device_list_listeners_.size() == 1) |
874 RequestDeviceList(); | 783 RequestDeviceList(); |
875 } | 784 } |
876 | 785 |
877 void DevToolsAndroidBridge::RemoveDeviceListListener( | 786 void DevToolsAndroidBridge::RemoveDeviceListListener( |
878 DeviceListListener* listener) { | 787 DeviceListListener* listener) { |
879 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 788 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
880 DeviceListListeners::iterator it = std::find( | 789 DeviceListListeners::iterator it = std::find( |
881 device_list_listeners_.begin(), device_list_listeners_.end(), listener); | 790 device_list_listeners_.begin(), device_list_listeners_.end(), listener); |
882 DCHECK(it != device_list_listeners_.end()); | 791 DCHECK(it != device_list_listeners_.end()); |
883 device_list_listeners_.erase(it); | 792 device_list_listeners_.erase(it); |
884 if (device_list_listeners_.empty() && device_manager_) { | 793 if (device_list_listeners_.empty()) |
885 device_message_loop()->PostTask(FROM_HERE, | 794 devices_.clear(); |
886 base::Bind(&AndroidDeviceManager::Stop, device_manager_)); | |
887 } | |
888 } | 795 } |
889 | 796 |
890 void DevToolsAndroidBridge::AddDeviceCountListener( | 797 void DevToolsAndroidBridge::AddDeviceCountListener( |
891 DeviceCountListener* listener) { | 798 DeviceCountListener* listener) { |
892 device_count_listeners_.push_back(listener); | 799 device_count_listeners_.push_back(listener); |
893 if (device_count_listeners_.size() == 1 && device_manager_) | 800 if (device_count_listeners_.size() == 1) |
894 RequestDeviceCount(); | 801 RequestDeviceCount(); |
895 } | 802 } |
896 | 803 |
897 void DevToolsAndroidBridge::RemoveDeviceCountListener( | 804 void DevToolsAndroidBridge::RemoveDeviceCountListener( |
898 DeviceCountListener* listener) { | 805 DeviceCountListener* listener) { |
899 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 806 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
900 DeviceCountListeners::iterator it = std::find( | 807 DeviceCountListeners::iterator it = std::find( |
901 device_count_listeners_.begin(), device_count_listeners_.end(), listener); | 808 device_count_listeners_.begin(), device_count_listeners_.end(), listener); |
902 DCHECK(it != device_count_listeners_.end()); | 809 DCHECK(it != device_count_listeners_.end()); |
903 device_count_listeners_.erase(it); | 810 device_count_listeners_.erase(it); |
904 } | 811 } |
905 | 812 |
906 // static | 813 // static |
907 bool DevToolsAndroidBridge::HasDevToolsWindow(const std::string& agent_id) { | 814 bool DevToolsAndroidBridge::HasDevToolsWindow(const std::string& agent_id) { |
908 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 815 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
909 return g_host_delegates.Get().find(agent_id) != g_host_delegates.Get().end(); | 816 return g_host_delegates.Get().find(agent_id) != g_host_delegates.Get().end(); |
910 } | 817 } |
911 | 818 |
912 DevToolsAndroidBridge::~DevToolsAndroidBridge() { | 819 DevToolsAndroidBridge::~DevToolsAndroidBridge() { |
913 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 820 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
914 DCHECK(device_list_listeners_.empty()); | 821 DCHECK(device_list_listeners_.empty()); |
915 DCHECK(device_count_listeners_.empty()); | 822 DCHECK(device_count_listeners_.empty()); |
916 if (device_manager_) { | |
917 AndroidDeviceManager* raw_ptr = device_manager_.get(); | |
918 device_manager_->AddRef(); | |
919 device_manager_ = NULL; | |
920 device_message_loop()->ReleaseSoon(FROM_HERE, raw_ptr); | |
921 } | |
922 } | 823 } |
923 | 824 |
924 void DevToolsAndroidBridge::RequestDeviceList() { | 825 void DevToolsAndroidBridge::RequestDeviceList() { |
925 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 826 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
926 DCHECK(device_manager_); | |
927 | 827 |
928 if (device_list_listeners_.empty()) | 828 if (device_list_listeners_.empty()) |
929 return; | 829 return; |
930 | 830 |
931 new DiscoveryRequest( | 831 new DiscoveryRequest( |
932 this, | 832 device_manager_.get(), |
933 device_manager(), | |
934 device_message_loop(), | |
935 device_providers_, | |
936 base::Bind(&DevToolsAndroidBridge::ReceivedDeviceList, this)); | 833 base::Bind(&DevToolsAndroidBridge::ReceivedDeviceList, this)); |
937 } | 834 } |
938 | 835 |
939 void DevToolsAndroidBridge::CreatedDeviceManager( | 836 void DevToolsAndroidBridge::ReceivedDeviceList( |
940 scoped_refptr<AndroidDeviceManager> device_manager) { | 837 scoped_ptr<RemoteDevices> devices) { |
941 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 838 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
942 device_manager_ = device_manager; | |
943 if (!device_list_listeners_.empty()) | |
944 RequestDeviceList(); | |
945 if (!device_count_listeners_.empty()) | |
946 RequestDeviceCount(); | |
947 } | |
948 | |
949 void DevToolsAndroidBridge::ReceivedDeviceList(RemoteDevices* devices_ptr) { | |
950 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | |
951 | |
952 scoped_ptr<RemoteDevices> devices(devices_ptr); | |
953 | 839 |
954 if (device_list_listeners_.empty()) | 840 if (device_list_listeners_.empty()) |
955 return; | 841 return; |
956 | 842 |
| 843 devices_ = *devices; |
| 844 |
957 DeviceListListeners copy(device_list_listeners_); | 845 DeviceListListeners copy(device_list_listeners_); |
958 for (DeviceListListeners::iterator it = copy.begin(); it != copy.end(); ++it) | 846 for (DeviceListListeners::iterator it = copy.begin(); it != copy.end(); ++it) |
959 (*it)->DeviceListChanged(*devices.get()); | 847 (*it)->DeviceListChanged(*devices.get()); |
960 | 848 |
961 BrowserThread::PostDelayedTask( | 849 BrowserThread::PostDelayedTask( |
962 BrowserThread::UI, | 850 BrowserThread::UI, |
963 FROM_HERE, | 851 FROM_HERE, |
964 base::Bind(&DevToolsAndroidBridge::RequestDeviceList, this), | 852 base::Bind(&DevToolsAndroidBridge::RequestDeviceList, this), |
965 base::TimeDelta::FromMilliseconds(kAdbPollingIntervalMs)); | 853 base::TimeDelta::FromMilliseconds(kAdbPollingIntervalMs)); |
966 } | 854 } |
967 | 855 |
968 void DevToolsAndroidBridge::RequestDeviceCount() { | 856 void DevToolsAndroidBridge::RequestDeviceCount() { |
969 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 857 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
970 DCHECK(device_manager_); | |
971 | 858 |
972 if (device_count_listeners_.empty()) | 859 if (device_count_listeners_.empty()) |
973 return; | 860 return; |
974 | 861 |
975 UsbDeviceProvider::CountDevices( | 862 UsbDeviceProvider::CountDevices( |
976 base::Bind(&DevToolsAndroidBridge::ReceivedDeviceCount, this)); | 863 base::Bind(&DevToolsAndroidBridge::ReceivedDeviceCount, this)); |
977 } | 864 } |
978 | 865 |
979 void DevToolsAndroidBridge::ReceivedDeviceCount(int count) { | 866 void DevToolsAndroidBridge::ReceivedDeviceCount(int count) { |
980 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 867 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
981 | 868 |
982 if (device_count_listeners_.empty()) | 869 if (device_count_listeners_.empty()) |
983 return; | 870 return; |
984 | 871 |
985 DeviceCountListeners copy(device_count_listeners_); | 872 DeviceCountListeners copy(device_count_listeners_); |
986 for (DeviceCountListeners::iterator it = copy.begin(); it != copy.end(); ++it) | 873 for (DeviceCountListeners::iterator it = copy.begin(); it != copy.end(); ++it) |
987 (*it)->DeviceCountChanged(count); | 874 (*it)->DeviceCountChanged(count); |
988 | 875 |
989 BrowserThread::PostDelayedTask( | 876 BrowserThread::PostDelayedTask( |
990 BrowserThread::UI, | 877 BrowserThread::UI, |
991 FROM_HERE, | 878 FROM_HERE, |
992 base::Bind(&DevToolsAndroidBridge::RequestDeviceCount, this), | 879 base::Bind(&DevToolsAndroidBridge::RequestDeviceCount, this), |
993 base::TimeDelta::FromMilliseconds(kAdbPollingIntervalMs)); | 880 base::TimeDelta::FromMilliseconds(kAdbPollingIntervalMs)); |
994 } | 881 } |
995 | 882 |
996 void DevToolsAndroidBridge::CreateDeviceProviders() { | 883 void DevToolsAndroidBridge::CreateDeviceProviders() { |
997 device_providers_.clear(); | 884 AndroidDeviceManager::DeviceProviders device_providers; |
998 #if defined(DEBUG_DEVTOOLS) | 885 #if defined(DEBUG_DEVTOOLS) |
999 BrowserListTabContentsProvider::EnableTethering(); | 886 BrowserListTabContentsProvider::EnableTethering(); |
1000 // We cannot rely on command line switch here as we might want to connect | 887 // We cannot rely on command line switch here as we might want to connect |
1001 // to another instance of Chrome. Using hard-coded port number instead. | 888 // to another instance of Chrome. Using hard-coded port number instead. |
1002 const int kDefaultDebuggingPort = 9222; | 889 const int kDefaultDebuggingPort = 9222; |
1003 device_providers_.push_back(new SelfAsDeviceProvider(kDefaultDebuggingPort)); | 890 device_providers.push_back(new SelfAsDeviceProvider(kDefaultDebuggingPort)); |
1004 #endif | 891 #endif |
1005 device_providers_.push_back(new AdbDeviceProvider()); | 892 device_providers.push_back(new AdbDeviceProvider()); |
1006 | 893 |
1007 PrefService* service = profile_->GetPrefs(); | 894 PrefService* service = profile_->GetPrefs(); |
1008 const PrefService::Preference* pref = | 895 const PrefService::Preference* pref = |
1009 service->FindPreference(prefs::kDevToolsDiscoverUsbDevicesEnabled); | 896 service->FindPreference(prefs::kDevToolsDiscoverUsbDevicesEnabled); |
1010 const base::Value* pref_value = pref->GetValue(); | 897 const base::Value* pref_value = pref->GetValue(); |
1011 | 898 |
1012 bool enabled; | 899 bool enabled; |
1013 if (pref_value->GetAsBoolean(&enabled) && enabled) { | 900 if (pref_value->GetAsBoolean(&enabled) && enabled) { |
1014 device_providers_.push_back(new UsbDeviceProvider(profile_)); | 901 device_providers.push_back(new UsbDeviceProvider(profile_)); |
1015 } | 902 } |
| 903 device_manager_->SetDeviceProviders(device_providers); |
1016 } | 904 } |
OLD | NEW |