Chromium Code Reviews| 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 |