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/self_device_provider.h" | 5 #include "chrome/browser/devtools/device/self_device_provider.h" |
6 | 6 |
7 #include <algorithm> | |
8 | |
7 #include "base/location.h" | 9 #include "base/location.h" |
8 #include "base/single_thread_task_runner.h" | 10 #include "base/single_thread_task_runner.h" |
9 #include "base/strings/string_number_conversions.h" | 11 #include "base/strings/string_number_conversions.h" |
10 #include "base/strings/stringprintf.h" | 12 #include "base/strings/stringprintf.h" |
11 #include "base/thread_task_runner_handle.h" | 13 #include "base/thread_task_runner_handle.h" |
12 #include "net/socket/tcp_client_socket.h" | 14 #include "net/socket/tcp_client_socket.h" |
13 | 15 |
14 namespace { | 16 namespace { |
15 | 17 |
16 const char kDeviceModel[] = "Local Chrome"; | 18 const char kDeviceModel[] = "Local Chrome"; |
dgozman
2015/07/06 10:08:34
It's not Chrome anymore, let's update.
yurys
2015/07/06 12:49:00
Done.
| |
17 const char kBrowserName[] = "Chrome"; | 19 const char kBrowserName[] = "Chrome"; |
dgozman
2015/07/06 10:08:34
ditto
yurys
2015/07/06 12:49:00
Done.
| |
18 const char kLocalhost[] = "127.0.0.1"; | |
19 const char kSerial[] = "local"; | |
20 | 20 |
21 static void RunSocketCallback( | 21 static void RunSocketCallback( |
22 const AndroidDeviceManager::SocketCallback& callback, | 22 const AndroidDeviceManager::SocketCallback& callback, |
23 scoped_ptr<net::StreamSocket> socket, | 23 scoped_ptr<net::StreamSocket> socket, |
24 int result) { | 24 int result) { |
25 callback.Run(result, socket.Pass()); | 25 callback.Run(result, socket.Pass()); |
26 } | 26 } |
27 | 27 |
28 } // namespace | 28 } // namespace |
29 | 29 |
30 SelfAsDeviceProvider::SelfAsDeviceProvider(int port) : port_(port) { | 30 SelfAsDeviceProvider::SelfAsDeviceProvider(const RemoteTargets& targets) |
31 : targets_(targets) { | |
31 } | 32 } |
32 | 33 |
33 void SelfAsDeviceProvider::QueryDevices(const SerialsCallback& callback) { | 34 void SelfAsDeviceProvider::QueryDevices(const SerialsCallback& callback) { |
34 std::vector<std::string> result; | 35 std::vector<std::string> result; |
35 result.push_back(kSerial); | 36 for (const net::HostPortPair& target : targets_) { |
37 const std::string& host = target.host(); | |
38 if (std::find(result.begin(), result.end(), host) != result.end()) { | |
dgozman
2015/07/06 10:08:34
nit: we don't usually wrap one-liners with {}
yurys
2015/07/06 12:49:00
Done.
| |
39 continue; | |
40 } | |
41 result.push_back(host); | |
42 } | |
36 callback.Run(result); | 43 callback.Run(result); |
37 } | 44 } |
38 | 45 |
39 void SelfAsDeviceProvider::QueryDeviceInfo(const std::string& serial, | 46 void SelfAsDeviceProvider::QueryDeviceInfo(const std::string& serial, |
40 const DeviceInfoCallback& callback) { | 47 const DeviceInfoCallback& callback) { |
41 AndroidDeviceManager::DeviceInfo device_info; | 48 AndroidDeviceManager::DeviceInfo device_info; |
42 device_info.model = kDeviceModel; | 49 device_info.model = kDeviceModel; |
43 device_info.connected = true; | 50 device_info.connected = true; |
44 | 51 |
45 AndroidDeviceManager::BrowserInfo browser_info; | 52 for (const net::HostPortPair& target : targets_) { |
46 browser_info.socket_name = base::IntToString(port_); | 53 if (serial != target.host()) { |
pfeldman
2015/07/06 10:10:04
ditto
yurys
2015/07/06 12:49:00
Done.
| |
47 browser_info.display_name = kBrowserName; | 54 continue; |
48 browser_info.type = AndroidDeviceManager::BrowserInfo::kTypeChrome; | 55 } |
56 AndroidDeviceManager::BrowserInfo browser_info; | |
57 browser_info.socket_name = base::IntToString(target.port()); | |
58 browser_info.display_name = kBrowserName; | |
59 browser_info.type = AndroidDeviceManager::BrowserInfo::kTypeChrome; | |
49 | 60 |
50 device_info.browser_info.push_back(browser_info); | 61 device_info.browser_info.push_back(browser_info); |
62 } | |
51 | 63 |
52 base::ThreadTaskRunnerHandle::Get()->PostTask( | 64 base::ThreadTaskRunnerHandle::Get()->PostTask( |
53 FROM_HERE, base::Bind(callback, device_info)); | 65 FROM_HERE, base::Bind(callback, device_info)); |
54 } | 66 } |
55 | 67 |
56 void SelfAsDeviceProvider::OpenSocket(const std::string& serial, | 68 void SelfAsDeviceProvider::OpenSocket(const std::string& serial, |
57 const std::string& socket_name, | 69 const std::string& socket_name, |
58 const SocketCallback& callback) { | 70 const SocketCallback& callback) { |
59 // Use plain socket for remote debugging and port forwarding on Desktop | 71 // Use plain socket for remote debugging and port forwarding on Desktop |
60 // (debugging purposes). | 72 // (debugging purposes). |
61 net::IPAddressNumber ip_number; | 73 net::IPAddressNumber ip_number; |
62 net::ParseIPLiteralToNumber(kLocalhost, &ip_number); | 74 if (!net::ParseIPLiteralToNumber(serial, &ip_number)) { |
pfeldman
2015/07/06 10:10:04
ditto
yurys
2015/07/06 12:49:00
Done.
| |
75 LOG(ERROR) << "Failed to parse IP address: " << serial; | |
dgozman
2015/07/06 10:08:34
We should |callback(nullptr)| probably.
yurys
2015/07/06 12:49:00
Done.
| |
76 } | |
63 int port; | 77 int port; |
64 base::StringToInt(socket_name, &port); | 78 base::StringToInt(socket_name, &port); |
65 net::AddressList address_list = | 79 net::AddressList address_list = |
66 net::AddressList::CreateFromIPAddress(ip_number, port); | 80 net::AddressList::CreateFromIPAddress(ip_number, port); |
67 scoped_ptr<net::StreamSocket> socket(new net::TCPClientSocket( | 81 scoped_ptr<net::StreamSocket> socket(new net::TCPClientSocket( |
68 address_list, NULL, net::NetLog::Source())); | 82 address_list, NULL, net::NetLog::Source())); |
69 socket->Connect( | 83 socket->Connect( |
70 base::Bind(&RunSocketCallback, callback, base::Passed(&socket))); | 84 base::Bind(&RunSocketCallback, callback, base::Passed(&socket))); |
71 } | 85 } |
72 | 86 |
73 void SelfAsDeviceProvider::ReleaseDevice(const std::string& serial) { | 87 void SelfAsDeviceProvider::ReleaseDevice(const std::string& serial) { |
74 DCHECK(serial == kSerial); | |
75 if (!release_callback_.is_null()) | 88 if (!release_callback_.is_null()) |
76 release_callback_.Run(); | 89 release_callback_.Run(); |
77 } | 90 } |
78 | 91 |
79 void SelfAsDeviceProvider::set_release_callback_for_test( | 92 void SelfAsDeviceProvider::set_release_callback_for_test( |
80 const base::Closure& callback) { | 93 const base::Closure& callback) { |
81 release_callback_ = callback; | 94 release_callback_ = callback; |
82 } | 95 } |
83 | 96 |
84 SelfAsDeviceProvider::~SelfAsDeviceProvider() { | 97 SelfAsDeviceProvider::~SelfAsDeviceProvider() { |
85 } | 98 } |
OLD | NEW |