The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 1 | /* |
| 2 | * Copyright (C) 2007 The Android Open Source Project |
| 3 | * |
| 4 | * Licensed under the Apache License, Version 2.0 (the "License"); |
| 5 | * you may not use this file except in compliance with the License. |
| 6 | * You may obtain a copy of the License at |
| 7 | * |
| 8 | * http://www.apache.org/licenses/LICENSE-2.0 |
| 9 | * |
| 10 | * Unless required by applicable law or agreed to in writing, software |
| 11 | * distributed under the License is distributed on an "AS IS" BASIS, |
| 12 | * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| 13 | * See the License for the specific language governing permissions and |
| 14 | * limitations under the License. |
| 15 | */ |
| 16 | |
Yabin Cui | aed3c61 | 2015-09-22 15:52:57 -0700 | [diff] [blame] | 17 | #define TRACE_TAG ADB |
Dan Albert | 3313426 | 2015-03-19 15:21:08 -0700 | [diff] [blame] | 18 | |
| 19 | #include "sysdeps.h" |
| 20 | #include "adb.h" |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 21 | |
Dan Albert | ea2175a | 2015-03-08 21:12:08 -0700 | [diff] [blame] | 22 | #include <ctype.h> |
| 23 | #include <errno.h> |
| 24 | #include <stdarg.h> |
| 25 | #include <stddef.h> |
| 26 | #include <stdint.h> |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 27 | #include <stdio.h> |
| 28 | #include <stdlib.h> |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 29 | #include <string.h> |
Mike Lockwood | 1f546e6 | 2009-05-25 18:17:55 -0400 | [diff] [blame] | 30 | #include <sys/time.h> |
Dan Albert | ea2175a | 2015-03-08 21:12:08 -0700 | [diff] [blame] | 31 | #include <time.h> |
| 32 | |
Elliott Hughes | dbe91ee | 2016-11-15 12:37:32 -0800 | [diff] [blame] | 33 | #include <chrono> |
Josh Gao | fd713e5 | 2017-05-03 22:37:10 -0700 | [diff] [blame] | 34 | #include <condition_variable> |
| 35 | #include <mutex> |
Dan Albert | ea2175a | 2015-03-08 21:12:08 -0700 | [diff] [blame] | 36 | #include <string> |
Elliott Hughes | dbe91ee | 2016-11-15 12:37:32 -0800 | [diff] [blame] | 37 | #include <thread> |
Dan Albert | e246219 | 2015-03-19 13:25:27 -0700 | [diff] [blame] | 38 | #include <vector> |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 39 | |
David Pursell | 5f787ed | 2016-01-27 08:52:53 -0800 | [diff] [blame] | 40 | #include <android-base/errors.h> |
Elliott Hughes | 82ff315 | 2016-08-31 15:07:18 -0700 | [diff] [blame] | 41 | #include <android-base/file.h> |
Elliott Hughes | 4f71319 | 2015-12-04 22:00:26 -0800 | [diff] [blame] | 42 | #include <android-base/logging.h> |
| 43 | #include <android-base/macros.h> |
David Pursell | 706955f | 2016-01-21 08:40:59 -0800 | [diff] [blame] | 44 | #include <android-base/parsenetaddress.h> |
Elliott Hughes | 4f71319 | 2015-12-04 22:00:26 -0800 | [diff] [blame] | 45 | #include <android-base/stringprintf.h> |
| 46 | #include <android-base/strings.h> |
Josh Gao | c7567fa | 2018-02-27 15:49:23 -0800 | [diff] [blame] | 47 | #include <build/version.h> |
Dan Willemsen | ab971b5 | 2018-08-29 14:58:02 -0700 | [diff] [blame] | 48 | #include <platform_tools_version.h> |
Elliott Hughes | 7b50609 | 2015-04-20 08:09:20 -0700 | [diff] [blame] | 49 | |
Benoit Goby | d5fcafa | 2012-04-12 12:23:49 -0700 | [diff] [blame] | 50 | #include "adb_auth.h" |
Dan Albert | cc731cc | 2015-02-24 21:26:58 -0800 | [diff] [blame] | 51 | #include "adb_io.h" |
Dan Albert | e9fca14 | 2015-02-18 18:03:26 -0800 | [diff] [blame] | 52 | #include "adb_listeners.h" |
Elliott Hughes | 6eadee8 | 2017-06-15 08:35:24 -0700 | [diff] [blame] | 53 | #include "adb_unique_fd.h" |
Elliott Hughes | 3d5f60d | 2015-07-18 12:21:30 -0700 | [diff] [blame] | 54 | #include "adb_utils.h" |
Joshua Duong | 5cf7868 | 2020-01-21 13:19:42 -0800 | [diff] [blame] | 55 | #include "adb_wifi.h" |
Josh Gao | fd713e5 | 2017-05-03 22:37:10 -0700 | [diff] [blame] | 56 | #include "sysdeps/chrono.h" |
Dan Albert | 7664901 | 2015-02-24 15:51:19 -0800 | [diff] [blame] | 57 | #include "transport.h" |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 58 | |
| 59 | #if !ADB_HOST |
Nick Kralevich | e2864bf | 2013-02-28 14:12:58 -0800 | [diff] [blame] | 60 | #include <sys/capability.h> |
Jeff Sharkey | 885342a | 2012-08-14 21:00:22 -0700 | [diff] [blame] | 61 | #include <sys/mount.h> |
Elliott Hughes | ffdec18 | 2016-09-23 15:40:03 -0700 | [diff] [blame] | 62 | #include <android-base/properties.h> |
Elliott Hughes | dbe91ee | 2016-11-15 12:37:32 -0800 | [diff] [blame] | 63 | using namespace std::chrono_literals; |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 64 | #endif |
| 65 | |
Elliott Hughes | 42ae260 | 2015-08-12 08:32:10 -0700 | [diff] [blame] | 66 | std::string adb_version() { |
| 67 | // Don't change the format of this --- it's parsed by ddmlib. |
Elliott Hughes | 1fd46df | 2017-03-30 15:08:28 -0700 | [diff] [blame] | 68 | return android::base::StringPrintf( |
| 69 | "Android Debug Bridge version %d.%d.%d\n" |
Dan Willemsen | ab971b5 | 2018-08-29 14:58:02 -0700 | [diff] [blame] | 70 | "Version %s-%s\n" |
Elliott Hughes | 1fd46df | 2017-03-30 15:08:28 -0700 | [diff] [blame] | 71 | "Installed as %s\n", |
Josh Gao | 2776845 | 2018-01-02 12:01:43 -0800 | [diff] [blame] | 72 | ADB_VERSION_MAJOR, ADB_VERSION_MINOR, ADB_SERVER_VERSION, |
Dan Willemsen | ab971b5 | 2018-08-29 14:58:02 -0700 | [diff] [blame] | 73 | PLATFORM_TOOLS_VERSION, android::build::GetBuildNumber().c_str(), |
| 74 | android::base::GetExecutablePath().c_str()); |
Elliott Hughes | 42ae260 | 2015-08-12 08:32:10 -0700 | [diff] [blame] | 75 | } |
| 76 | |
Josh Gao | 06d61d4 | 2016-10-06 13:31:44 -0700 | [diff] [blame] | 77 | uint32_t calculate_apacket_checksum(const apacket* p) { |
Josh Gao | 06d61d4 | 2016-10-06 13:31:44 -0700 | [diff] [blame] | 78 | uint32_t sum = 0; |
Josh Gao | f571fcb | 2018-02-05 18:49:10 -0800 | [diff] [blame] | 79 | for (size_t i = 0; i < p->msg.data_length; ++i) { |
| 80 | sum += static_cast<uint8_t>(p->payload[i]); |
Josh Gao | 06d61d4 | 2016-10-06 13:31:44 -0700 | [diff] [blame] | 81 | } |
Josh Gao | 06d61d4 | 2016-10-06 13:31:44 -0700 | [diff] [blame] | 82 | return sum; |
| 83 | } |
| 84 | |
Dan Albert | bac3474 | 2015-02-25 17:51:28 -0800 | [diff] [blame] | 85 | apacket* get_apacket(void) |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 86 | { |
Josh Gao | f571fcb | 2018-02-05 18:49:10 -0800 | [diff] [blame] | 87 | apacket* p = new apacket(); |
Dan Albert | bac3474 | 2015-02-25 17:51:28 -0800 | [diff] [blame] | 88 | if (p == nullptr) { |
Elliott Hughes | 4679a39 | 2018-10-19 13:59:44 -0700 | [diff] [blame] | 89 | LOG(FATAL) << "failed to allocate an apacket"; |
Dan Albert | bac3474 | 2015-02-25 17:51:28 -0800 | [diff] [blame] | 90 | } |
| 91 | |
Josh Gao | f571fcb | 2018-02-05 18:49:10 -0800 | [diff] [blame] | 92 | memset(&p->msg, 0, sizeof(p->msg)); |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 93 | return p; |
| 94 | } |
| 95 | |
| 96 | void put_apacket(apacket *p) |
| 97 | { |
Josh Gao | f571fcb | 2018-02-05 18:49:10 -0800 | [diff] [blame] | 98 | delete p; |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 99 | } |
| 100 | |
Benoit Goby | d5fcafa | 2012-04-12 12:23:49 -0700 | [diff] [blame] | 101 | void handle_online(atransport *t) |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 102 | { |
Yabin Cui | 7a3f8d6 | 2015-09-02 17:44:28 -0700 | [diff] [blame] | 103 | D("adb: online"); |
Benoit Goby | d5fcafa | 2012-04-12 12:23:49 -0700 | [diff] [blame] | 104 | t->online = 1; |
Luis Hector Chavez | 56fe753 | 2018-04-17 14:25:04 -0700 | [diff] [blame] | 105 | t->SetConnectionEstablished(true); |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 106 | } |
| 107 | |
| 108 | void handle_offline(atransport *t) |
| 109 | { |
Josh Gao | 0bbf69c | 2018-02-16 13:24:58 -0800 | [diff] [blame] | 110 | if (t->GetConnectionState() == kCsOffline) { |
| 111 | LOG(INFO) << t->serial_name() << ": already offline"; |
| 112 | return; |
| 113 | } |
| 114 | |
| 115 | LOG(INFO) << t->serial_name() << ": offline"; |
| 116 | |
| 117 | t->SetConnectionState(kCsOffline); |
| 118 | |
| 119 | // Close the associated usb |
Benoit Goby | d5fcafa | 2012-04-12 12:23:49 -0700 | [diff] [blame] | 120 | t->online = 0; |
Yabin Cui | 34f45c5 | 2015-08-26 11:18:42 -0700 | [diff] [blame] | 121 | |
Yabin Cui | b329824 | 2015-08-28 15:09:44 -0700 | [diff] [blame] | 122 | // This is necessary to avoid a race condition that occurred when a transport closes |
Yabin Cui | 34f45c5 | 2015-08-26 11:18:42 -0700 | [diff] [blame] | 123 | // while a client socket is still active. |
| 124 | close_all_sockets(t); |
| 125 | |
Yabin Cui | b329824 | 2015-08-28 15:09:44 -0700 | [diff] [blame] | 126 | t->RunDisconnects(); |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 127 | } |
| 128 | |
Benoit Goby | d5fcafa | 2012-04-12 12:23:49 -0700 | [diff] [blame] | 129 | #if DEBUG_PACKETS |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 130 | #define DUMPMAX 32 |
| 131 | void print_packet(const char *label, apacket *p) |
| 132 | { |
Josh Gao | f571fcb | 2018-02-05 18:49:10 -0800 | [diff] [blame] | 133 | const char* tag; |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 134 | unsigned count; |
| 135 | |
| 136 | switch(p->msg.command){ |
| 137 | case A_SYNC: tag = "SYNC"; break; |
| 138 | case A_CNXN: tag = "CNXN" ; break; |
| 139 | case A_OPEN: tag = "OPEN"; break; |
| 140 | case A_OKAY: tag = "OKAY"; break; |
| 141 | case A_CLSE: tag = "CLSE"; break; |
| 142 | case A_WRTE: tag = "WRTE"; break; |
Benoit Goby | d5fcafa | 2012-04-12 12:23:49 -0700 | [diff] [blame] | 143 | case A_AUTH: tag = "AUTH"; break; |
Joshua Duong | 5cf7868 | 2020-01-21 13:19:42 -0800 | [diff] [blame] | 144 | case A_STLS: |
| 145 | tag = "ATLS"; |
| 146 | break; |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 147 | default: tag = "????"; break; |
| 148 | } |
| 149 | |
| 150 | fprintf(stderr, "%s: %s %08x %08x %04x \"", |
| 151 | label, tag, p->msg.arg0, p->msg.arg1, p->msg.data_length); |
| 152 | count = p->msg.data_length; |
Josh Gao | f571fcb | 2018-02-05 18:49:10 -0800 | [diff] [blame] | 153 | const char* x = p->payload.data(); |
| 154 | if (count > DUMPMAX) { |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 155 | count = DUMPMAX; |
| 156 | tag = "\n"; |
| 157 | } else { |
| 158 | tag = "\"\n"; |
| 159 | } |
Josh Gao | f571fcb | 2018-02-05 18:49:10 -0800 | [diff] [blame] | 160 | while (count-- > 0) { |
| 161 | if ((*x >= ' ') && (*x < 127)) { |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 162 | fputc(*x, stderr); |
| 163 | } else { |
| 164 | fputc('.', stderr); |
| 165 | } |
| 166 | x++; |
| 167 | } |
Benoit Goby | d5fcafa | 2012-04-12 12:23:49 -0700 | [diff] [blame] | 168 | fputs(tag, stderr); |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 169 | } |
| 170 | #endif |
| 171 | |
| 172 | static void send_ready(unsigned local, unsigned remote, atransport *t) |
| 173 | { |
Yabin Cui | 7a3f8d6 | 2015-09-02 17:44:28 -0700 | [diff] [blame] | 174 | D("Calling send_ready"); |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 175 | apacket *p = get_apacket(); |
| 176 | p->msg.command = A_OKAY; |
| 177 | p->msg.arg0 = local; |
| 178 | p->msg.arg1 = remote; |
| 179 | send_packet(p, t); |
| 180 | } |
| 181 | |
| 182 | static void send_close(unsigned local, unsigned remote, atransport *t) |
| 183 | { |
Yabin Cui | 7a3f8d6 | 2015-09-02 17:44:28 -0700 | [diff] [blame] | 184 | D("Calling send_close"); |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 185 | apacket *p = get_apacket(); |
| 186 | p->msg.command = A_CLSE; |
| 187 | p->msg.arg0 = local; |
| 188 | p->msg.arg1 = remote; |
| 189 | send_packet(p, t); |
| 190 | } |
| 191 | |
Dan Albert | 1792c23 | 2015-05-18 13:06:53 -0700 | [diff] [blame] | 192 | std::string get_connection_string() { |
| 193 | std::vector<std::string> connection_properties; |
| 194 | |
| 195 | #if !ADB_HOST |
| 196 | static const char* cnxn_props[] = { |
Scott Anderson | e82c2db | 2012-05-25 14:10:02 -0700 | [diff] [blame] | 197 | "ro.product.name", |
| 198 | "ro.product.model", |
| 199 | "ro.product.device", |
| 200 | }; |
Scott Anderson | e82c2db | 2012-05-25 14:10:02 -0700 | [diff] [blame] | 201 | |
Elliott Hughes | ffdec18 | 2016-09-23 15:40:03 -0700 | [diff] [blame] | 202 | for (const auto& prop : cnxn_props) { |
| 203 | std::string value = std::string(prop) + "=" + android::base::GetProperty(prop, ""); |
| 204 | connection_properties.push_back(value); |
Scott Anderson | e82c2db | 2012-05-25 14:10:02 -0700 | [diff] [blame] | 205 | } |
Scott Anderson | e82c2db | 2012-05-25 14:10:02 -0700 | [diff] [blame] | 206 | #endif |
Dan Albert | 1792c23 | 2015-05-18 13:06:53 -0700 | [diff] [blame] | 207 | |
| 208 | connection_properties.push_back(android::base::StringPrintf( |
David Pursell | 4e2fd36 | 2015-09-22 10:43:08 -0700 | [diff] [blame] | 209 | "features=%s", FeatureSetToString(supported_features()).c_str())); |
Dan Albert | 1792c23 | 2015-05-18 13:06:53 -0700 | [diff] [blame] | 210 | |
| 211 | return android::base::StringPrintf( |
| 212 | "%s::%s", adb_device_banner, |
| 213 | android::base::Join(connection_properties, ';').c_str()); |
Scott Anderson | e82c2db | 2012-05-25 14:10:02 -0700 | [diff] [blame] | 214 | } |
| 215 | |
Joshua Duong | 5cf7868 | 2020-01-21 13:19:42 -0800 | [diff] [blame] | 216 | void send_tls_request(atransport* t) { |
| 217 | D("Calling send_tls_request"); |
| 218 | apacket* p = get_apacket(); |
| 219 | p->msg.command = A_STLS; |
| 220 | p->msg.arg0 = A_STLS_VERSION; |
| 221 | p->msg.data_length = 0; |
| 222 | send_packet(p, t); |
| 223 | } |
| 224 | |
Dan Albert | 1792c23 | 2015-05-18 13:06:53 -0700 | [diff] [blame] | 225 | void send_connect(atransport* t) { |
Yabin Cui | 7a3f8d6 | 2015-09-02 17:44:28 -0700 | [diff] [blame] | 226 | D("Calling send_connect"); |
Dan Albert | 1792c23 | 2015-05-18 13:06:53 -0700 | [diff] [blame] | 227 | apacket* cp = get_apacket(); |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 228 | cp->msg.command = A_CNXN; |
Tim Murray | de47194 | 2017-12-07 11:40:00 -0800 | [diff] [blame] | 229 | // Send the max supported version, but because the transport is |
| 230 | // initialized to A_VERSION_MIN, this will be compatible with every |
| 231 | // device. |
| 232 | cp->msg.arg0 = A_VERSION; |
Tamas Berghammer | 3d2904c | 2015-07-13 19:12:28 +0100 | [diff] [blame] | 233 | cp->msg.arg1 = t->get_max_payload(); |
Dan Albert | 1792c23 | 2015-05-18 13:06:53 -0700 | [diff] [blame] | 234 | |
| 235 | std::string connection_str = get_connection_string(); |
| 236 | // Connect and auth packets are limited to MAX_PAYLOAD_V1 because we don't |
| 237 | // yet know how much data the other size is willing to accept. |
| 238 | if (connection_str.length() > MAX_PAYLOAD_V1) { |
| 239 | LOG(FATAL) << "Connection banner is too long (length = " |
| 240 | << connection_str.length() << ")"; |
| 241 | } |
| 242 | |
Josh Gao | 1ce9957 | 2018-03-07 16:52:28 -0800 | [diff] [blame] | 243 | cp->payload.assign(connection_str.begin(), connection_str.end()); |
Josh Gao | f571fcb | 2018-02-05 18:49:10 -0800 | [diff] [blame] | 244 | cp->msg.data_length = cp->payload.size(); |
Dan Albert | 1792c23 | 2015-05-18 13:06:53 -0700 | [diff] [blame] | 245 | |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 246 | send_packet(cp, t); |
Benoit Goby | d5fcafa | 2012-04-12 12:23:49 -0700 | [diff] [blame] | 247 | } |
| 248 | |
Dan Albert | 1792c23 | 2015-05-18 13:06:53 -0700 | [diff] [blame] | 249 | void parse_banner(const std::string& banner, atransport* t) { |
Yabin Cui | 7a3f8d6 | 2015-09-02 17:44:28 -0700 | [diff] [blame] | 250 | D("parse_banner: %s", banner.c_str()); |
Elliott Hughes | 8d5fa6d | 2015-04-24 23:02:00 -0700 | [diff] [blame] | 251 | |
| 252 | // The format is something like: |
| 253 | // "device::ro.product.name=x;ro.product.model=y;ro.product.device=z;". |
| 254 | std::vector<std::string> pieces = android::base::Split(banner, ":"); |
| 255 | |
David Pursell | d2b588e | 2015-09-25 13:04:21 -0700 | [diff] [blame] | 256 | // Reset the features list or else if the server sends no features we may |
| 257 | // keep the existing feature set (http://b/24405971). |
| 258 | t->SetFeatures(""); |
| 259 | |
Elliott Hughes | 8d5fa6d | 2015-04-24 23:02:00 -0700 | [diff] [blame] | 260 | if (pieces.size() > 2) { |
| 261 | const std::string& props = pieces[2]; |
Elliott Hughes | 65fe251 | 2015-10-07 15:59:35 -0700 | [diff] [blame] | 262 | for (const auto& prop : android::base::Split(props, ";")) { |
Elliott Hughes | 8d5fa6d | 2015-04-24 23:02:00 -0700 | [diff] [blame] | 263 | // The list of properties was traditionally ;-terminated rather than ;-separated. |
| 264 | if (prop.empty()) continue; |
| 265 | |
| 266 | std::vector<std::string> key_value = android::base::Split(prop, "="); |
| 267 | if (key_value.size() != 2) continue; |
| 268 | |
| 269 | const std::string& key = key_value[0]; |
| 270 | const std::string& value = key_value[1]; |
| 271 | if (key == "ro.product.name") { |
Luis Hector Chavez | 6150a37 | 2018-07-18 21:18:27 -0700 | [diff] [blame] | 272 | t->product = value; |
Elliott Hughes | 8d5fa6d | 2015-04-24 23:02:00 -0700 | [diff] [blame] | 273 | } else if (key == "ro.product.model") { |
Luis Hector Chavez | 6150a37 | 2018-07-18 21:18:27 -0700 | [diff] [blame] | 274 | t->model = value; |
Elliott Hughes | 8d5fa6d | 2015-04-24 23:02:00 -0700 | [diff] [blame] | 275 | } else if (key == "ro.product.device") { |
Luis Hector Chavez | 6150a37 | 2018-07-18 21:18:27 -0700 | [diff] [blame] | 276 | t->device = value; |
Dan Albert | 1792c23 | 2015-05-18 13:06:53 -0700 | [diff] [blame] | 277 | } else if (key == "features") { |
David Pursell | 4e2fd36 | 2015-09-22 10:43:08 -0700 | [diff] [blame] | 278 | t->SetFeatures(value); |
Scott Anderson | e82c2db | 2012-05-25 14:10:02 -0700 | [diff] [blame] | 279 | } |
| 280 | } |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 281 | } |
| 282 | |
Elliott Hughes | 8d5fa6d | 2015-04-24 23:02:00 -0700 | [diff] [blame] | 283 | const std::string& type = pieces[0]; |
| 284 | if (type == "bootloader") { |
Yabin Cui | 7a3f8d6 | 2015-09-02 17:44:28 -0700 | [diff] [blame] | 285 | D("setting connection_state to kCsBootloader"); |
Yabin Cui | b5e1141 | 2017-03-10 16:01:01 -0800 | [diff] [blame] | 286 | t->SetConnectionState(kCsBootloader); |
Elliott Hughes | 8d5fa6d | 2015-04-24 23:02:00 -0700 | [diff] [blame] | 287 | } else if (type == "device") { |
Yabin Cui | 7a3f8d6 | 2015-09-02 17:44:28 -0700 | [diff] [blame] | 288 | D("setting connection_state to kCsDevice"); |
Yabin Cui | b5e1141 | 2017-03-10 16:01:01 -0800 | [diff] [blame] | 289 | t->SetConnectionState(kCsDevice); |
Elliott Hughes | 8d5fa6d | 2015-04-24 23:02:00 -0700 | [diff] [blame] | 290 | } else if (type == "recovery") { |
Yabin Cui | 7a3f8d6 | 2015-09-02 17:44:28 -0700 | [diff] [blame] | 291 | D("setting connection_state to kCsRecovery"); |
Yabin Cui | b5e1141 | 2017-03-10 16:01:01 -0800 | [diff] [blame] | 292 | t->SetConnectionState(kCsRecovery); |
Elliott Hughes | 8d5fa6d | 2015-04-24 23:02:00 -0700 | [diff] [blame] | 293 | } else if (type == "sideload") { |
Yabin Cui | 7a3f8d6 | 2015-09-02 17:44:28 -0700 | [diff] [blame] | 294 | D("setting connection_state to kCsSideload"); |
Yabin Cui | b5e1141 | 2017-03-10 16:01:01 -0800 | [diff] [blame] | 295 | t->SetConnectionState(kCsSideload); |
Tao Bao | 55d407e | 2019-04-07 23:24:03 -0700 | [diff] [blame] | 296 | } else if (type == "rescue") { |
| 297 | D("setting connection_state to kCsRescue"); |
| 298 | t->SetConnectionState(kCsRescue); |
Elliott Hughes | 3ce9575 | 2015-04-29 22:37:25 -0700 | [diff] [blame] | 299 | } else { |
Yabin Cui | 7a3f8d6 | 2015-09-02 17:44:28 -0700 | [diff] [blame] | 300 | D("setting connection_state to kCsHost"); |
Yabin Cui | b5e1141 | 2017-03-10 16:01:01 -0800 | [diff] [blame] | 301 | t->SetConnectionState(kCsHost); |
Doug Zongker | 447f061 | 2012-01-09 14:54:53 -0800 | [diff] [blame] | 302 | } |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 303 | } |
| 304 | |
Dan Albert | 1792c23 | 2015-05-18 13:06:53 -0700 | [diff] [blame] | 305 | static void handle_new_connection(atransport* t, apacket* p) { |
Josh Gao | 0bbf69c | 2018-02-16 13:24:58 -0800 | [diff] [blame] | 306 | handle_offline(t); |
Dan Albert | 1792c23 | 2015-05-18 13:06:53 -0700 | [diff] [blame] | 307 | |
| 308 | t->update_version(p->msg.arg0, p->msg.arg1); |
Josh Gao | 1ce9957 | 2018-03-07 16:52:28 -0800 | [diff] [blame] | 309 | std::string banner(p->payload.begin(), p->payload.end()); |
| 310 | parse_banner(banner, t); |
Dan Albert | 1792c23 | 2015-05-18 13:06:53 -0700 | [diff] [blame] | 311 | |
| 312 | #if ADB_HOST |
| 313 | handle_online(t); |
| 314 | #else |
Joshua Duong | 5cf7868 | 2020-01-21 13:19:42 -0800 | [diff] [blame] | 315 | if (t->use_tls) { |
| 316 | // We still handshake in TLS mode. If auth_required is disabled, |
| 317 | // we'll just not verify the client's certificate. This should be the |
| 318 | // first packet the client receives to indicate the new protocol. |
| 319 | send_tls_request(t); |
| 320 | } else if (!auth_required) { |
Josh Gao | 2752326 | 2019-10-22 12:30:39 -0700 | [diff] [blame] | 321 | LOG(INFO) << "authentication not required"; |
Dan Albert | 1792c23 | 2015-05-18 13:06:53 -0700 | [diff] [blame] | 322 | handle_online(t); |
| 323 | send_connect(t); |
| 324 | } else { |
| 325 | send_auth_request(t); |
| 326 | } |
| 327 | #endif |
Josh Gao | fd713e5 | 2017-05-03 22:37:10 -0700 | [diff] [blame] | 328 | |
| 329 | update_transports(); |
Dan Albert | 1792c23 | 2015-05-18 13:06:53 -0700 | [diff] [blame] | 330 | } |
| 331 | |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 332 | void handle_packet(apacket *p, atransport *t) |
| 333 | { |
Yabin Cui | 7a3f8d6 | 2015-09-02 17:44:28 -0700 | [diff] [blame] | 334 | D("handle_packet() %c%c%c%c", ((char*) (&(p->msg.command)))[0], |
Viral Mehta | 899913f | 2010-06-16 18:41:28 +0530 | [diff] [blame] | 335 | ((char*) (&(p->msg.command)))[1], |
| 336 | ((char*) (&(p->msg.command)))[2], |
| 337 | ((char*) (&(p->msg.command)))[3]); |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 338 | print_packet("recv", p); |
Josh Gao | f571fcb | 2018-02-05 18:49:10 -0800 | [diff] [blame] | 339 | CHECK_EQ(p->payload.size(), p->msg.data_length); |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 340 | |
| 341 | switch(p->msg.command){ |
Dan Albert | 1792c23 | 2015-05-18 13:06:53 -0700 | [diff] [blame] | 342 | case A_CNXN: // CONNECT(version, maxdata, "system-id-string") |
| 343 | handle_new_connection(t, p); |
Benoit Goby | d5fcafa | 2012-04-12 12:23:49 -0700 | [diff] [blame] | 344 | break; |
Joshua Duong | 5cf7868 | 2020-01-21 13:19:42 -0800 | [diff] [blame] | 345 | case A_STLS: // TLS(version, "") |
| 346 | t->use_tls = true; |
| 347 | #if ADB_HOST |
| 348 | send_tls_request(t); |
| 349 | adb_auth_tls_handshake(t); |
| 350 | #else |
| 351 | adbd_auth_tls_handshake(t); |
| 352 | #endif |
| 353 | break; |
Benoit Goby | d5fcafa | 2012-04-12 12:23:49 -0700 | [diff] [blame] | 354 | |
| 355 | case A_AUTH: |
Joshua Duong | 5cf7868 | 2020-01-21 13:19:42 -0800 | [diff] [blame] | 356 | // All AUTH commands are ignored in TLS mode |
| 357 | if (t->use_tls) { |
| 358 | break; |
| 359 | } |
Josh Gao | 3bd2879 | 2016-10-05 19:02:29 -0700 | [diff] [blame] | 360 | switch (p->msg.arg0) { |
| 361 | #if ADB_HOST |
| 362 | case ADB_AUTH_TOKEN: |
Josh Gao | 704494b | 2018-05-04 16:04:49 -0700 | [diff] [blame] | 363 | if (t->GetConnectionState() != kCsAuthorizing) { |
| 364 | t->SetConnectionState(kCsAuthorizing); |
Yabin Cui | b5e1141 | 2017-03-10 16:01:01 -0800 | [diff] [blame] | 365 | } |
Josh Gao | f571fcb | 2018-02-05 18:49:10 -0800 | [diff] [blame] | 366 | send_auth_response(p->payload.data(), p->msg.data_length, t); |
Josh Gao | 3bd2879 | 2016-10-05 19:02:29 -0700 | [diff] [blame] | 367 | break; |
| 368 | #else |
Josh Gao | 1ce9957 | 2018-03-07 16:52:28 -0800 | [diff] [blame] | 369 | case ADB_AUTH_SIGNATURE: { |
| 370 | // TODO: Switch to string_view. |
| 371 | std::string signature(p->payload.begin(), p->payload.end()); |
Michael Groover | 7eeda6b | 2019-04-25 18:33:35 -0700 | [diff] [blame] | 372 | std::string auth_key; |
| 373 | if (adbd_auth_verify(t->token, sizeof(t->token), signature, &auth_key)) { |
Josh Gao | 3bd2879 | 2016-10-05 19:02:29 -0700 | [diff] [blame] | 374 | adbd_auth_verified(t); |
| 375 | t->failed_auth_attempts = 0; |
Michael Groover | 7eeda6b | 2019-04-25 18:33:35 -0700 | [diff] [blame] | 376 | t->auth_key = auth_key; |
| 377 | adbd_notify_framework_connected_key(t); |
Josh Gao | 3bd2879 | 2016-10-05 19:02:29 -0700 | [diff] [blame] | 378 | } else { |
Elliott Hughes | dbe91ee | 2016-11-15 12:37:32 -0800 | [diff] [blame] | 379 | if (t->failed_auth_attempts++ > 256) std::this_thread::sleep_for(1s); |
Josh Gao | 3bd2879 | 2016-10-05 19:02:29 -0700 | [diff] [blame] | 380 | send_auth_request(t); |
| 381 | } |
| 382 | break; |
Josh Gao | 1ce9957 | 2018-03-07 16:52:28 -0800 | [diff] [blame] | 383 | } |
Josh Gao | 3bd2879 | 2016-10-05 19:02:29 -0700 | [diff] [blame] | 384 | |
| 385 | case ADB_AUTH_RSAPUBLICKEY: |
Michael Groover | 7eeda6b | 2019-04-25 18:33:35 -0700 | [diff] [blame] | 386 | t->auth_key = std::string(p->payload.data()); |
| 387 | adbd_auth_confirm_key(t); |
Josh Gao | 3bd2879 | 2016-10-05 19:02:29 -0700 | [diff] [blame] | 388 | break; |
| 389 | #endif |
| 390 | default: |
Yabin Cui | b5e1141 | 2017-03-10 16:01:01 -0800 | [diff] [blame] | 391 | t->SetConnectionState(kCsOffline); |
Josh Gao | 3bd2879 | 2016-10-05 19:02:29 -0700 | [diff] [blame] | 392 | handle_offline(t); |
| 393 | break; |
Benoit Goby | d5fcafa | 2012-04-12 12:23:49 -0700 | [diff] [blame] | 394 | } |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 395 | break; |
| 396 | |
| 397 | case A_OPEN: /* OPEN(local-id, 0, "destination") */ |
David 'Digit' Turner | 818d641 | 2013-12-13 14:09:44 +0100 | [diff] [blame] | 398 | if (t->online && p->msg.arg0 != 0 && p->msg.arg1 == 0) { |
Josh Gao | d19b77a | 2018-12-13 14:21:00 -0800 | [diff] [blame] | 399 | std::string_view address(p->payload.begin(), p->payload.size()); |
| 400 | |
Josh Gao | 6bd16b1 | 2018-12-27 11:16:27 -0800 | [diff] [blame] | 401 | // Historically, we received service names as a char*, and stopped at the first NUL |
| 402 | // byte. The client sent strings with null termination, which post-string_view, start |
| 403 | // being interpreted as part of the string, unless we explicitly strip them. |
| 404 | address = StripTrailingNulls(address); |
| 405 | |
Josh Gao | d19b77a | 2018-12-13 14:21:00 -0800 | [diff] [blame] | 406 | asocket* s = create_local_service_socket(address, t); |
Elliott Hughes | ffc73a3 | 2016-06-15 14:46:56 -0700 | [diff] [blame] | 407 | if (s == nullptr) { |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 408 | send_close(0, p->msg.arg0, t); |
| 409 | } else { |
| 410 | s->peer = create_remote_socket(p->msg.arg0, t); |
| 411 | s->peer->peer = s; |
| 412 | send_ready(s->id, s->peer->id, t); |
| 413 | s->ready(s); |
| 414 | } |
| 415 | } |
| 416 | break; |
| 417 | |
| 418 | case A_OKAY: /* READY(local-id, remote-id, "") */ |
David 'Digit' Turner | 818d641 | 2013-12-13 14:09:44 +0100 | [diff] [blame] | 419 | if (t->online && p->msg.arg0 != 0 && p->msg.arg1 != 0) { |
Elliott Hughes | ffc73a3 | 2016-06-15 14:46:56 -0700 | [diff] [blame] | 420 | asocket* s = find_local_socket(p->msg.arg1, 0); |
| 421 | if (s) { |
Yi Kong | aed415c | 2018-07-13 18:15:16 -0700 | [diff] [blame] | 422 | if(s->peer == nullptr) { |
David 'Digit' Turner | 818d641 | 2013-12-13 14:09:44 +0100 | [diff] [blame] | 423 | /* On first READY message, create the connection. */ |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 424 | s->peer = create_remote_socket(p->msg.arg0, t); |
| 425 | s->peer->peer = s; |
David 'Digit' Turner | 818d641 | 2013-12-13 14:09:44 +0100 | [diff] [blame] | 426 | s->ready(s); |
| 427 | } else if (s->peer->id == p->msg.arg0) { |
| 428 | /* Other READY messages must use the same local-id */ |
| 429 | s->ready(s); |
| 430 | } else { |
Luis Hector Chavez | 6150a37 | 2018-07-18 21:18:27 -0700 | [diff] [blame] | 431 | D("Invalid A_OKAY(%d,%d), expected A_OKAY(%d,%d) on transport %s", p->msg.arg0, |
| 432 | p->msg.arg1, s->peer->id, p->msg.arg1, t->serial.c_str()); |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 433 | } |
Yabin Cui | aa77e22 | 2015-09-29 12:25:33 -0700 | [diff] [blame] | 434 | } else { |
| 435 | // When receiving A_OKAY from device for A_OPEN request, the host server may |
| 436 | // have closed the local socket because of client disconnection. Then we need |
| 437 | // to send A_CLSE back to device to close the service on device. |
| 438 | send_close(p->msg.arg1, p->msg.arg0, t); |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 439 | } |
| 440 | } |
| 441 | break; |
| 442 | |
David 'Digit' Turner | 818d641 | 2013-12-13 14:09:44 +0100 | [diff] [blame] | 443 | case A_CLSE: /* CLOSE(local-id, remote-id, "") or CLOSE(0, remote-id, "") */ |
| 444 | if (t->online && p->msg.arg1 != 0) { |
Elliott Hughes | ffc73a3 | 2016-06-15 14:46:56 -0700 | [diff] [blame] | 445 | asocket* s = find_local_socket(p->msg.arg1, p->msg.arg0); |
| 446 | if (s) { |
David 'Digit' Turner | 818d641 | 2013-12-13 14:09:44 +0100 | [diff] [blame] | 447 | /* According to protocol.txt, p->msg.arg0 might be 0 to indicate |
| 448 | * a failed OPEN only. However, due to a bug in previous ADB |
| 449 | * versions, CLOSE(0, remote-id, "") was also used for normal |
| 450 | * CLOSE() operations. |
| 451 | * |
| 452 | * This is bad because it means a compromised adbd could |
| 453 | * send packets to close connections between the host and |
| 454 | * other devices. To avoid this, only allow this if the local |
| 455 | * socket has a peer on the same transport. |
| 456 | */ |
| 457 | if (p->msg.arg0 == 0 && s->peer && s->peer->transport != t) { |
Luis Hector Chavez | 6150a37 | 2018-07-18 21:18:27 -0700 | [diff] [blame] | 458 | D("Invalid A_CLSE(0, %u) from transport %s, expected transport %s", p->msg.arg1, |
| 459 | t->serial.c_str(), s->peer->transport->serial.c_str()); |
David 'Digit' Turner | 818d641 | 2013-12-13 14:09:44 +0100 | [diff] [blame] | 460 | } else { |
| 461 | s->close(s); |
| 462 | } |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 463 | } |
| 464 | } |
| 465 | break; |
| 466 | |
David 'Digit' Turner | 818d641 | 2013-12-13 14:09:44 +0100 | [diff] [blame] | 467 | case A_WRTE: /* WRITE(local-id, remote-id, <data>) */ |
| 468 | if (t->online && p->msg.arg0 != 0 && p->msg.arg1 != 0) { |
Elliott Hughes | ffc73a3 | 2016-06-15 14:46:56 -0700 | [diff] [blame] | 469 | asocket* s = find_local_socket(p->msg.arg1, p->msg.arg0); |
| 470 | if (s) { |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 471 | unsigned rid = p->msg.arg0; |
Josh Gao | f571fcb | 2018-02-05 18:49:10 -0800 | [diff] [blame] | 472 | if (s->enqueue(s, std::move(p->payload)) == 0) { |
Yabin Cui | 7a3f8d6 | 2015-09-02 17:44:28 -0700 | [diff] [blame] | 473 | D("Enqueue the socket"); |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 474 | send_ready(s->id, rid, t); |
| 475 | } |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 476 | } |
| 477 | } |
| 478 | break; |
| 479 | |
| 480 | default: |
| 481 | printf("handle_packet: what is %08x?!\n", p->msg.command); |
| 482 | } |
| 483 | |
| 484 | put_apacket(p); |
| 485 | } |
| 486 | |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 487 | #if ADB_HOST |
JP Abgrall | 571c136 | 2012-12-06 18:18:12 -0800 | [diff] [blame] | 488 | |
Spencer Low | 2122c7a | 2015-08-26 18:46:09 -0700 | [diff] [blame] | 489 | #ifdef _WIN32 |
| 490 | |
Spencer Low | bc36bdb | 2015-09-16 16:40:06 -0700 | [diff] [blame] | 491 | // Try to make a handle non-inheritable and if there is an error, don't output |
| 492 | // any error info, but leave GetLastError() for the caller to read. This is |
| 493 | // convenient if the caller is expecting that this may fail and they'd like to |
| 494 | // ignore such a failure. |
| 495 | static bool _try_make_handle_noninheritable(HANDLE h) { |
Spencer Low | 2122c7a | 2015-08-26 18:46:09 -0700 | [diff] [blame] | 496 | if (h != INVALID_HANDLE_VALUE && h != NULL) { |
Spencer Low | bc36bdb | 2015-09-16 16:40:06 -0700 | [diff] [blame] | 497 | return SetHandleInformation(h, HANDLE_FLAG_INHERIT, 0) ? true : false; |
| 498 | } |
| 499 | |
| 500 | return true; |
| 501 | } |
| 502 | |
| 503 | // Try to make a handle non-inheritable with the expectation that this should |
| 504 | // succeed, so if this fails, output error info. |
| 505 | static bool _make_handle_noninheritable(HANDLE h) { |
| 506 | if (!_try_make_handle_noninheritable(h)) { |
| 507 | // Show the handle value to give us a clue in case we have problems |
| 508 | // with pseudo-handle values. |
Elliott Hughes | 1fc8f6e | 2017-04-18 14:34:16 -0700 | [diff] [blame] | 509 | fprintf(stderr, "adb: cannot make handle 0x%p non-inheritable: %s\n", h, |
| 510 | android::base::SystemErrorCodeToString(GetLastError()).c_str()); |
Spencer Low | bc36bdb | 2015-09-16 16:40:06 -0700 | [diff] [blame] | 511 | return false; |
Spencer Low | 2122c7a | 2015-08-26 18:46:09 -0700 | [diff] [blame] | 512 | } |
| 513 | |
| 514 | return true; |
| 515 | } |
| 516 | |
| 517 | // Create anonymous pipe, preventing inheritance of the read pipe and setting |
| 518 | // security of the write pipe to sa. |
| 519 | static bool _create_anonymous_pipe(unique_handle* pipe_read_out, |
| 520 | unique_handle* pipe_write_out, |
| 521 | SECURITY_ATTRIBUTES* sa) { |
| 522 | HANDLE pipe_read_raw = NULL; |
| 523 | HANDLE pipe_write_raw = NULL; |
| 524 | if (!CreatePipe(&pipe_read_raw, &pipe_write_raw, sa, 0)) { |
Elliott Hughes | 1fc8f6e | 2017-04-18 14:34:16 -0700 | [diff] [blame] | 525 | fprintf(stderr, "adb: CreatePipe failed: %s\n", |
David Pursell | 5f787ed | 2016-01-27 08:52:53 -0800 | [diff] [blame] | 526 | android::base::SystemErrorCodeToString(GetLastError()).c_str()); |
Spencer Low | 2122c7a | 2015-08-26 18:46:09 -0700 | [diff] [blame] | 527 | return false; |
| 528 | } |
| 529 | |
| 530 | unique_handle pipe_read(pipe_read_raw); |
| 531 | pipe_read_raw = NULL; |
| 532 | unique_handle pipe_write(pipe_write_raw); |
| 533 | pipe_write_raw = NULL; |
| 534 | |
| 535 | if (!_make_handle_noninheritable(pipe_read.get())) { |
| 536 | return false; |
| 537 | } |
| 538 | |
| 539 | *pipe_read_out = std::move(pipe_read); |
| 540 | *pipe_write_out = std::move(pipe_write); |
| 541 | |
| 542 | return true; |
| 543 | } |
| 544 | |
Spencer Low | 53a0a99 | 2015-11-21 17:23:51 -0800 | [diff] [blame] | 545 | // Read from a pipe (that we take ownership of) and write the result to stdout/stderr. Return on |
| 546 | // error or when the pipe is closed. Internally makes inheritable handles, so this should not be |
| 547 | // called if subprocesses may be started concurrently. |
Spencer Low | 2122c7a | 2015-08-26 18:46:09 -0700 | [diff] [blame] | 548 | static unsigned _redirect_pipe_thread(HANDLE h, DWORD nStdHandle) { |
| 549 | // Take ownership of the HANDLE and close when we're done. |
| 550 | unique_handle read_pipe(h); |
Spencer Low | 53a0a99 | 2015-11-21 17:23:51 -0800 | [diff] [blame] | 551 | const char* output_name = nStdHandle == STD_OUTPUT_HANDLE ? "stdout" : "stderr"; |
| 552 | const int original_fd = fileno(nStdHandle == STD_OUTPUT_HANDLE ? stdout : stderr); |
| 553 | std::unique_ptr<FILE, decltype(&fclose)> stream(nullptr, fclose); |
| 554 | |
| 555 | if (original_fd == -1) { |
Elliott Hughes | 1fc8f6e | 2017-04-18 14:34:16 -0700 | [diff] [blame] | 556 | fprintf(stderr, "adb: failed to get file descriptor for %s: %s\n", output_name, |
| 557 | strerror(errno)); |
Spencer Low | 53a0a99 | 2015-11-21 17:23:51 -0800 | [diff] [blame] | 558 | return EXIT_FAILURE; |
| 559 | } |
| 560 | |
| 561 | // If fileno() is -2, stdout/stderr is not associated with an output stream, so we should read, |
| 562 | // but don't write. Otherwise, make a FILE* identical to stdout/stderr except that it is in |
| 563 | // binary mode with no CR/LR translation since we're reading raw. |
| 564 | if (original_fd >= 0) { |
| 565 | // This internally makes a duplicate file handle that is inheritable, so callers should not |
| 566 | // call this function if subprocesses may be started concurrently. |
| 567 | const int fd = dup(original_fd); |
| 568 | if (fd == -1) { |
Elliott Hughes | 1fc8f6e | 2017-04-18 14:34:16 -0700 | [diff] [blame] | 569 | fprintf(stderr, "adb: failed to duplicate file descriptor for %s: %s\n", output_name, |
Spencer Low | 53a0a99 | 2015-11-21 17:23:51 -0800 | [diff] [blame] | 570 | strerror(errno)); |
| 571 | return EXIT_FAILURE; |
| 572 | } |
| 573 | |
| 574 | // Note that although we call fdopen() below with a binary flag, it may not adhere to that |
| 575 | // flag, so we have to set the mode manually. |
| 576 | if (_setmode(fd, _O_BINARY) == -1) { |
Elliott Hughes | 1fc8f6e | 2017-04-18 14:34:16 -0700 | [diff] [blame] | 577 | fprintf(stderr, "adb: failed to set binary mode for duplicate of %s: %s\n", output_name, |
Spencer Low | 53a0a99 | 2015-11-21 17:23:51 -0800 | [diff] [blame] | 578 | strerror(errno)); |
| 579 | unix_close(fd); |
| 580 | return EXIT_FAILURE; |
| 581 | } |
| 582 | |
| 583 | stream.reset(fdopen(fd, "wb")); |
| 584 | if (stream.get() == nullptr) { |
Elliott Hughes | 1fc8f6e | 2017-04-18 14:34:16 -0700 | [diff] [blame] | 585 | fprintf(stderr, "adb: failed to open duplicate stream for %s: %s\n", output_name, |
Spencer Low | 53a0a99 | 2015-11-21 17:23:51 -0800 | [diff] [blame] | 586 | strerror(errno)); |
| 587 | unix_close(fd); |
| 588 | return EXIT_FAILURE; |
| 589 | } |
| 590 | |
| 591 | // Unbuffer the stream because it will be buffered by default and we want subprocess output |
| 592 | // to be shown immediately. |
| 593 | if (setvbuf(stream.get(), NULL, _IONBF, 0) == -1) { |
Elliott Hughes | 1fc8f6e | 2017-04-18 14:34:16 -0700 | [diff] [blame] | 594 | fprintf(stderr, "adb: failed to unbuffer %s: %s\n", output_name, strerror(errno)); |
Spencer Low | 53a0a99 | 2015-11-21 17:23:51 -0800 | [diff] [blame] | 595 | return EXIT_FAILURE; |
| 596 | } |
| 597 | |
| 598 | // fd will be closed when stream is closed. |
| 599 | } |
Spencer Low | 2122c7a | 2015-08-26 18:46:09 -0700 | [diff] [blame] | 600 | |
| 601 | while (true) { |
| 602 | char buf[64 * 1024]; |
| 603 | DWORD bytes_read = 0; |
| 604 | if (!ReadFile(read_pipe.get(), buf, sizeof(buf), &bytes_read, NULL)) { |
| 605 | const DWORD err = GetLastError(); |
| 606 | // ERROR_BROKEN_PIPE is expected when the subprocess closes |
| 607 | // the other end of the pipe. |
| 608 | if (err == ERROR_BROKEN_PIPE) { |
| 609 | return EXIT_SUCCESS; |
| 610 | } else { |
Elliott Hughes | 1fc8f6e | 2017-04-18 14:34:16 -0700 | [diff] [blame] | 611 | fprintf(stderr, "adb: failed to read from %s: %s\n", output_name, |
David Pursell | 5f787ed | 2016-01-27 08:52:53 -0800 | [diff] [blame] | 612 | android::base::SystemErrorCodeToString(err).c_str()); |
Spencer Low | 2122c7a | 2015-08-26 18:46:09 -0700 | [diff] [blame] | 613 | return EXIT_FAILURE; |
| 614 | } |
| 615 | } |
| 616 | |
Spencer Low | 53a0a99 | 2015-11-21 17:23:51 -0800 | [diff] [blame] | 617 | // Don't try to write if our stdout/stderr was not setup by the parent process. |
| 618 | if (stream) { |
| 619 | // fwrite() actually calls adb_fwrite() which can write UTF-8 to the console. |
| 620 | const size_t bytes_written = fwrite(buf, 1, bytes_read, stream.get()); |
Spencer Low | 2122c7a | 2015-08-26 18:46:09 -0700 | [diff] [blame] | 621 | if (bytes_written != bytes_read) { |
Elliott Hughes | 1fc8f6e | 2017-04-18 14:34:16 -0700 | [diff] [blame] | 622 | fprintf(stderr, "adb: error: only wrote %zu of %lu bytes to %s\n", bytes_written, |
| 623 | bytes_read, output_name); |
Spencer Low | 2122c7a | 2015-08-26 18:46:09 -0700 | [diff] [blame] | 624 | return EXIT_FAILURE; |
| 625 | } |
| 626 | } |
| 627 | } |
| 628 | } |
| 629 | |
| 630 | static unsigned __stdcall _redirect_stdout_thread(HANDLE h) { |
Siva Velusamy | 49ee7cf | 2015-08-28 16:37:29 -0700 | [diff] [blame] | 631 | adb_thread_setname("stdout redirect"); |
Spencer Low | 2122c7a | 2015-08-26 18:46:09 -0700 | [diff] [blame] | 632 | return _redirect_pipe_thread(h, STD_OUTPUT_HANDLE); |
| 633 | } |
| 634 | |
| 635 | static unsigned __stdcall _redirect_stderr_thread(HANDLE h) { |
Siva Velusamy | 49ee7cf | 2015-08-28 16:37:29 -0700 | [diff] [blame] | 636 | adb_thread_setname("stderr redirect"); |
Spencer Low | 2122c7a | 2015-08-26 18:46:09 -0700 | [diff] [blame] | 637 | return _redirect_pipe_thread(h, STD_ERROR_HANDLE); |
| 638 | } |
| 639 | |
| 640 | #endif |
| 641 | |
Elliott Hughes | 6eadee8 | 2017-06-15 08:35:24 -0700 | [diff] [blame] | 642 | static void ReportServerStartupFailure(pid_t pid) { |
| 643 | fprintf(stderr, "ADB server didn't ACK\n"); |
| 644 | fprintf(stderr, "Full server startup log: %s\n", GetLogFilePath().c_str()); |
| 645 | fprintf(stderr, "Server had pid: %d\n", pid); |
| 646 | |
Josh Gao | 0f29cbc | 2018-12-12 16:12:28 -0800 | [diff] [blame] | 647 | android::base::unique_fd fd(unix_open(GetLogFilePath(), O_RDONLY)); |
Elliott Hughes | 6eadee8 | 2017-06-15 08:35:24 -0700 | [diff] [blame] | 648 | if (fd == -1) return; |
| 649 | |
| 650 | // Let's not show more than 128KiB of log... |
Spencer Low | 40babf0 | 2018-09-02 19:19:39 -0700 | [diff] [blame] | 651 | unix_lseek(fd, -128 * 1024, SEEK_END); |
Elliott Hughes | 6eadee8 | 2017-06-15 08:35:24 -0700 | [diff] [blame] | 652 | std::string content; |
| 653 | if (!android::base::ReadFdToString(fd, &content)) return; |
| 654 | |
| 655 | std::string header = android::base::StringPrintf("--- adb starting (pid %d) ---", pid); |
| 656 | std::vector<std::string> lines = android::base::Split(content, "\n"); |
| 657 | int i = lines.size() - 1; |
| 658 | while (i >= 0 && lines[i] != header) --i; |
| 659 | while (static_cast<size_t>(i) < lines.size()) fprintf(stderr, "%s\n", lines[i++].c_str()); |
| 660 | } |
| 661 | |
Josh Gao | 9c869b5 | 2016-08-25 16:00:22 -0700 | [diff] [blame] | 662 | int launch_server(const std::string& socket_spec) { |
Yabin Cui | e77b6a0 | 2014-11-11 09:24:11 -0800 | [diff] [blame] | 663 | #if defined(_WIN32) |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 664 | /* we need to start the server in the background */ |
| 665 | /* we create a PIPE that will be used to wait for the server's "OK" */ |
| 666 | /* message since the pipe handles must be inheritable, we use a */ |
| 667 | /* security attribute */ |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 668 | SECURITY_ATTRIBUTES sa; |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 669 | sa.nLength = sizeof(sa); |
| 670 | sa.lpSecurityDescriptor = NULL; |
| 671 | sa.bInheritHandle = TRUE; |
| 672 | |
Spencer Low | 2122c7a | 2015-08-26 18:46:09 -0700 | [diff] [blame] | 673 | // Redirect stdin to Windows /dev/null. If we instead pass an original |
| 674 | // stdin/stdout/stderr handle and it is a console handle, when the adb |
| 675 | // server starts up, the C Runtime will see a console handle for a process |
| 676 | // that isn't connected to a console and it will configure |
| 677 | // stdin/stdout/stderr to be closed. At that point, freopen() could be used |
| 678 | // to reopen stderr/out, but it would take more massaging to fixup the file |
| 679 | // descriptor number that freopen() uses. It's simplest to avoid all of this |
| 680 | // complexity by just redirecting stdin to `nul' and then the C Runtime acts |
| 681 | // as expected. |
| 682 | unique_handle nul_read(CreateFileW(L"nul", GENERIC_READ, |
| 683 | FILE_SHARE_READ | FILE_SHARE_WRITE, &sa, OPEN_EXISTING, |
| 684 | FILE_ATTRIBUTE_NORMAL, NULL)); |
| 685 | if (nul_read.get() == INVALID_HANDLE_VALUE) { |
Elliott Hughes | 1fc8f6e | 2017-04-18 14:34:16 -0700 | [diff] [blame] | 686 | fprintf(stderr, "adb: CreateFileW 'nul' failed: %s\n", |
David Pursell | 5f787ed | 2016-01-27 08:52:53 -0800 | [diff] [blame] | 687 | android::base::SystemErrorCodeToString(GetLastError()).c_str()); |
Spencer Low | d0f66c3 | 2015-05-20 23:17:26 -0700 | [diff] [blame] | 688 | return -1; |
| 689 | } |
| 690 | |
Spencer Low | 53a0a99 | 2015-11-21 17:23:51 -0800 | [diff] [blame] | 691 | // Create pipes with non-inheritable read handle, inheritable write handle. We need to connect |
| 692 | // the subprocess to pipes instead of just letting the subprocess inherit our existing |
| 693 | // stdout/stderr handles because a DETACHED_PROCESS cannot write to a console that it is not |
| 694 | // attached to. |
Spencer Low | 2122c7a | 2015-08-26 18:46:09 -0700 | [diff] [blame] | 695 | unique_handle ack_read, ack_write; |
| 696 | if (!_create_anonymous_pipe(&ack_read, &ack_write, &sa)) { |
Spencer Low | d0f66c3 | 2015-05-20 23:17:26 -0700 | [diff] [blame] | 697 | return -1; |
| 698 | } |
Spencer Low | 2122c7a | 2015-08-26 18:46:09 -0700 | [diff] [blame] | 699 | unique_handle stdout_read, stdout_write; |
| 700 | if (!_create_anonymous_pipe(&stdout_read, &stdout_write, &sa)) { |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 701 | return -1; |
| 702 | } |
Spencer Low | 2122c7a | 2015-08-26 18:46:09 -0700 | [diff] [blame] | 703 | unique_handle stderr_read, stderr_write; |
| 704 | if (!_create_anonymous_pipe(&stderr_read, &stderr_write, &sa)) { |
| 705 | return -1; |
| 706 | } |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 707 | |
Ray Donnelly | 267aa8b | 2012-11-29 01:18:50 +0000 | [diff] [blame] | 708 | /* Some programs want to launch an adb command and collect its output by |
| 709 | * calling CreateProcess with inheritable stdout/stderr handles, then |
| 710 | * using read() to get its output. When this happens, the stdout/stderr |
| 711 | * handles passed to the adb client process will also be inheritable. |
| 712 | * When starting the adb server here, care must be taken to reset them |
| 713 | * to non-inheritable. |
| 714 | * Otherwise, something bad happens: even if the adb command completes, |
| 715 | * the calling process is stuck while read()-ing from the stdout/stderr |
| 716 | * descriptors, because they're connected to corresponding handles in the |
| 717 | * adb server process (even if the latter never uses/writes to them). |
Spencer Low | 2122c7a | 2015-08-26 18:46:09 -0700 | [diff] [blame] | 718 | * Note that even if we don't pass these handles in the STARTUPINFO struct, |
| 719 | * if they're marked inheritable, they're still inherited, requiring us to |
| 720 | * deal with this. |
| 721 | * |
| 722 | * If we're still having problems with inheriting random handles in the |
| 723 | * future, consider using PROC_THREAD_ATTRIBUTE_HANDLE_LIST to explicitly |
| 724 | * specify which handles should be inherited: http://blogs.msdn.com/b/oldnewthing/archive/2011/12/16/10248328.aspx |
Spencer Low | bc36bdb | 2015-09-16 16:40:06 -0700 | [diff] [blame] | 725 | * |
| 726 | * Older versions of Windows return console pseudo-handles that cannot be |
| 727 | * made non-inheritable, so ignore those failures. |
Ray Donnelly | 267aa8b | 2012-11-29 01:18:50 +0000 | [diff] [blame] | 728 | */ |
Spencer Low | bc36bdb | 2015-09-16 16:40:06 -0700 | [diff] [blame] | 729 | _try_make_handle_noninheritable(GetStdHandle(STD_INPUT_HANDLE)); |
| 730 | _try_make_handle_noninheritable(GetStdHandle(STD_OUTPUT_HANDLE)); |
| 731 | _try_make_handle_noninheritable(GetStdHandle(STD_ERROR_HANDLE)); |
Ray Donnelly | 267aa8b | 2012-11-29 01:18:50 +0000 | [diff] [blame] | 732 | |
Spencer Low | 2122c7a | 2015-08-26 18:46:09 -0700 | [diff] [blame] | 733 | STARTUPINFOW startup; |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 734 | ZeroMemory( &startup, sizeof(startup) ); |
| 735 | startup.cb = sizeof(startup); |
Spencer Low | 2122c7a | 2015-08-26 18:46:09 -0700 | [diff] [blame] | 736 | startup.hStdInput = nul_read.get(); |
| 737 | startup.hStdOutput = stdout_write.get(); |
| 738 | startup.hStdError = stderr_write.get(); |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 739 | startup.dwFlags = STARTF_USESTDHANDLES; |
| 740 | |
Spencer Low | 2122c7a | 2015-08-26 18:46:09 -0700 | [diff] [blame] | 741 | // Verify that the pipe_write handle value can be passed on the command line |
| 742 | // as %d and that the rest of adb code can pass it around in an int. |
| 743 | const int ack_write_as_int = cast_handle_to_int(ack_write.get()); |
| 744 | if (cast_int_to_handle(ack_write_as_int) != ack_write.get()) { |
| 745 | // If this fires, either handle values are larger than 32-bits or else |
| 746 | // there is a bug in our casting. |
| 747 | // https://msdn.microsoft.com/en-us/library/windows/desktop/aa384203%28v=vs.85%29.aspx |
Elliott Hughes | 1fc8f6e | 2017-04-18 14:34:16 -0700 | [diff] [blame] | 748 | fprintf(stderr, "adb: cannot fit pipe handle value into 32-bits: 0x%p\n", ack_write.get()); |
Spencer Low | 2122c7a | 2015-08-26 18:46:09 -0700 | [diff] [blame] | 749 | return -1; |
| 750 | } |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 751 | |
Spencer Low | 2122c7a | 2015-08-26 18:46:09 -0700 | [diff] [blame] | 752 | // get path of current program |
| 753 | WCHAR program_path[MAX_PATH]; |
| 754 | const DWORD module_result = GetModuleFileNameW(NULL, program_path, |
| 755 | arraysize(program_path)); |
| 756 | if ((module_result >= arraysize(program_path)) || (module_result == 0)) { |
Spencer Low | cf4ff64 | 2015-05-11 01:08:48 -0700 | [diff] [blame] | 757 | // String truncation or some other error. |
Elliott Hughes | 1fc8f6e | 2017-04-18 14:34:16 -0700 | [diff] [blame] | 758 | fprintf(stderr, "adb: cannot get executable path: %s\n", |
David Pursell | 5f787ed | 2016-01-27 08:52:53 -0800 | [diff] [blame] | 759 | android::base::SystemErrorCodeToString(GetLastError()).c_str()); |
Spencer Low | cf4ff64 | 2015-05-11 01:08:48 -0700 | [diff] [blame] | 760 | return -1; |
| 761 | } |
Spencer Low | 5c398d2 | 2015-08-08 15:07:07 -0700 | [diff] [blame] | 762 | |
Spencer Low | 2122c7a | 2015-08-26 18:46:09 -0700 | [diff] [blame] | 763 | WCHAR args[64]; |
Josh Gao | 9c869b5 | 2016-08-25 16:00:22 -0700 | [diff] [blame] | 764 | snwprintf(args, arraysize(args), L"adb -L %s fork-server server --reply-fd %d", |
| 765 | socket_spec.c_str(), ack_write_as_int); |
Spencer Low | 2122c7a | 2015-08-26 18:46:09 -0700 | [diff] [blame] | 766 | |
| 767 | PROCESS_INFORMATION pinfo; |
| 768 | ZeroMemory(&pinfo, sizeof(pinfo)); |
| 769 | |
| 770 | if (!CreateProcessW( |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 771 | program_path, /* program path */ |
Wenhao Li | a09558c | 2013-11-13 16:23:37 +0800 | [diff] [blame] | 772 | args, |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 773 | /* the fork-server argument will set the |
| 774 | debug = 2 in the child */ |
| 775 | NULL, /* process handle is not inheritable */ |
| 776 | NULL, /* thread handle is not inheritable */ |
| 777 | TRUE, /* yes, inherit some handles */ |
| 778 | DETACHED_PROCESS, /* the new process doesn't have a console */ |
| 779 | NULL, /* use parent's environment block */ |
| 780 | NULL, /* use parent's starting directory */ |
| 781 | &startup, /* startup info, i.e. std handles */ |
Spencer Low | 2122c7a | 2015-08-26 18:46:09 -0700 | [diff] [blame] | 782 | &pinfo )) { |
Elliott Hughes | 1fc8f6e | 2017-04-18 14:34:16 -0700 | [diff] [blame] | 783 | fprintf(stderr, "adb: CreateProcessW failed: %s\n", |
David Pursell | 5f787ed | 2016-01-27 08:52:53 -0800 | [diff] [blame] | 784 | android::base::SystemErrorCodeToString(GetLastError()).c_str()); |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 785 | return -1; |
| 786 | } |
| 787 | |
Spencer Low | 2122c7a | 2015-08-26 18:46:09 -0700 | [diff] [blame] | 788 | unique_handle process_handle(pinfo.hProcess); |
| 789 | pinfo.hProcess = NULL; |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 790 | |
Spencer Low | 2122c7a | 2015-08-26 18:46:09 -0700 | [diff] [blame] | 791 | // Close handles that we no longer need to complete the rest. |
| 792 | CloseHandle(pinfo.hThread); |
| 793 | pinfo.hThread = NULL; |
| 794 | |
| 795 | nul_read.reset(); |
| 796 | ack_write.reset(); |
| 797 | stdout_write.reset(); |
| 798 | stderr_write.reset(); |
| 799 | |
Spencer Low | 53a0a99 | 2015-11-21 17:23:51 -0800 | [diff] [blame] | 800 | // Start threads to read from subprocess stdout/stderr and write to ours to make subprocess |
| 801 | // errors easier to diagnose. Note that the threads internally create inheritable handles, but |
| 802 | // that is ok because we've already spawned the subprocess. |
Spencer Low | 2122c7a | 2015-08-26 18:46:09 -0700 | [diff] [blame] | 803 | |
| 804 | // In the past, reading from a pipe before the child process's C Runtime |
| 805 | // started up and called GetFileType() caused a hang: http://blogs.msdn.com/b/oldnewthing/archive/2011/12/02/10243553.aspx#10244216 |
| 806 | // This is reportedly fixed in Windows Vista: https://support.microsoft.com/en-us/kb/2009703 |
| 807 | // I was unable to reproduce the problem on Windows XP. It sounds like a |
| 808 | // Windows Update may have fixed this: https://www.duckware.com/tech/peeknamedpipe.html |
| 809 | unique_handle stdout_thread(reinterpret_cast<HANDLE>( |
| 810 | _beginthreadex(NULL, 0, _redirect_stdout_thread, stdout_read.get(), |
| 811 | 0, NULL))); |
| 812 | if (stdout_thread.get() == nullptr) { |
Elliott Hughes | 1fc8f6e | 2017-04-18 14:34:16 -0700 | [diff] [blame] | 813 | fprintf(stderr, "adb: cannot create thread: %s\n", strerror(errno)); |
Spencer Low | 2122c7a | 2015-08-26 18:46:09 -0700 | [diff] [blame] | 814 | return -1; |
| 815 | } |
| 816 | stdout_read.release(); // Transfer ownership to new thread |
| 817 | |
| 818 | unique_handle stderr_thread(reinterpret_cast<HANDLE>( |
| 819 | _beginthreadex(NULL, 0, _redirect_stderr_thread, stderr_read.get(), |
| 820 | 0, NULL))); |
| 821 | if (stderr_thread.get() == nullptr) { |
Elliott Hughes | 1fc8f6e | 2017-04-18 14:34:16 -0700 | [diff] [blame] | 822 | fprintf(stderr, "adb: cannot create thread: %s\n", strerror(errno)); |
Spencer Low | 2122c7a | 2015-08-26 18:46:09 -0700 | [diff] [blame] | 823 | return -1; |
| 824 | } |
| 825 | stderr_read.release(); // Transfer ownership to new thread |
| 826 | |
| 827 | bool got_ack = false; |
| 828 | |
| 829 | // Wait for the "OK\n" message, for the pipe to be closed, or other error. |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 830 | { |
Spencer Low | 2122c7a | 2015-08-26 18:46:09 -0700 | [diff] [blame] | 831 | char temp[3]; |
| 832 | DWORD count = 0; |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 833 | |
Spencer Low | 2122c7a | 2015-08-26 18:46:09 -0700 | [diff] [blame] | 834 | if (ReadFile(ack_read.get(), temp, sizeof(temp), &count, NULL)) { |
| 835 | const CHAR expected[] = "OK\n"; |
| 836 | const DWORD expected_length = arraysize(expected) - 1; |
| 837 | if (count == expected_length && |
| 838 | memcmp(temp, expected, expected_length) == 0) { |
| 839 | got_ack = true; |
| 840 | } else { |
Spencer Low | 40babf0 | 2018-09-02 19:19:39 -0700 | [diff] [blame] | 841 | ReportServerStartupFailure(pinfo.dwProcessId); |
Elliott Hughes | 6eadee8 | 2017-06-15 08:35:24 -0700 | [diff] [blame] | 842 | return -1; |
Spencer Low | 2122c7a | 2015-08-26 18:46:09 -0700 | [diff] [blame] | 843 | } |
| 844 | } else { |
| 845 | const DWORD err = GetLastError(); |
| 846 | // If the ACK was not written and the process exited, GetLastError() |
| 847 | // is probably ERROR_BROKEN_PIPE, in which case that info is not |
| 848 | // useful to the user. |
| 849 | fprintf(stderr, "could not read ok from ADB Server%s\n", |
| 850 | err == ERROR_BROKEN_PIPE ? "" : |
| 851 | android::base::StringPrintf(": %s", |
David Pursell | 5f787ed | 2016-01-27 08:52:53 -0800 | [diff] [blame] | 852 | android::base::SystemErrorCodeToString(err).c_str()).c_str()); |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 853 | } |
Spencer Low | 2122c7a | 2015-08-26 18:46:09 -0700 | [diff] [blame] | 854 | } |
| 855 | |
| 856 | // Always try to wait a bit for threads reading stdout/stderr to finish. |
| 857 | // If the process started ok, it should close the pipes causing the threads |
| 858 | // to finish. If the process had an error, it should exit, also causing |
| 859 | // the pipes to be closed. In that case we want to read all of the output |
| 860 | // and write it out so that the user can diagnose failures. |
| 861 | const DWORD thread_timeout_ms = 15 * 1000; |
| 862 | const HANDLE threads[] = { stdout_thread.get(), stderr_thread.get() }; |
| 863 | const DWORD wait_result = WaitForMultipleObjects(arraysize(threads), |
| 864 | threads, TRUE, thread_timeout_ms); |
| 865 | if (wait_result == WAIT_TIMEOUT) { |
| 866 | // Threads did not finish after waiting a little while. Perhaps the |
| 867 | // server didn't close pipes, or it is hung. |
Elliott Hughes | 1fc8f6e | 2017-04-18 14:34:16 -0700 | [diff] [blame] | 868 | fprintf(stderr, "adb: timed out waiting for threads to finish reading from ADB server\n"); |
Spencer Low | 2122c7a | 2015-08-26 18:46:09 -0700 | [diff] [blame] | 869 | // Process handles are signaled when the process exits, so if we wait |
| 870 | // on the handle for 0 seconds and it returns 'timeout', that means that |
| 871 | // the process is still running. |
| 872 | if (WaitForSingleObject(process_handle.get(), 0) == WAIT_TIMEOUT) { |
| 873 | // We could TerminateProcess(), but that seems somewhat presumptive. |
Elliott Hughes | 1fc8f6e | 2017-04-18 14:34:16 -0700 | [diff] [blame] | 874 | fprintf(stderr, "adb: server is running with process id %lu\n", pinfo.dwProcessId); |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 875 | } |
Spencer Low | 2122c7a | 2015-08-26 18:46:09 -0700 | [diff] [blame] | 876 | return -1; |
| 877 | } |
| 878 | |
| 879 | if (wait_result != WAIT_OBJECT_0) { |
Elliott Hughes | 1fc8f6e | 2017-04-18 14:34:16 -0700 | [diff] [blame] | 880 | fprintf(stderr, "adb: unexpected result waiting for threads: %lu: %s\n", wait_result, |
| 881 | android::base::SystemErrorCodeToString(GetLastError()).c_str()); |
Spencer Low | 2122c7a | 2015-08-26 18:46:09 -0700 | [diff] [blame] | 882 | return -1; |
| 883 | } |
| 884 | |
| 885 | // For now ignore the thread exit codes and assume they worked properly. |
| 886 | |
| 887 | if (!got_ack) { |
| 888 | return -1; |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 889 | } |
Yabin Cui | e77b6a0 | 2014-11-11 09:24:11 -0800 | [diff] [blame] | 890 | #else /* !defined(_WIN32) */ |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 891 | // set up a pipe so the child can tell us when it is ready. |
Josh Gao | ae9c1dc | 2018-05-11 12:55:56 -0700 | [diff] [blame] | 892 | unique_fd pipe_read, pipe_write; |
| 893 | if (!Pipe(&pipe_read, &pipe_write)) { |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 894 | fprintf(stderr, "pipe failed in launch_server, errno: %d\n", errno); |
| 895 | return -1; |
| 896 | } |
Elliott Hughes | 82ff315 | 2016-08-31 15:07:18 -0700 | [diff] [blame] | 897 | |
| 898 | std::string path = android::base::GetExecutablePath(); |
| 899 | |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 900 | pid_t pid = fork(); |
Elliott Hughes | 82ff315 | 2016-08-31 15:07:18 -0700 | [diff] [blame] | 901 | if (pid < 0) return -1; |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 902 | |
| 903 | if (pid == 0) { |
| 904 | // child side of the fork |
Josh Gao | ae9c1dc | 2018-05-11 12:55:56 -0700 | [diff] [blame] | 905 | pipe_read.reset(); |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 906 | |
Josh Gao | 297d9bf | 2018-08-06 18:38:47 -0700 | [diff] [blame] | 907 | // android::base::Pipe unconditionally opens the pipe with O_CLOEXEC. |
| 908 | // Undo this manually. |
| 909 | fcntl(pipe_write.get(), F_SETFD, 0); |
| 910 | |
Siva Velusamy | 9f2d1a9 | 2015-08-07 10:10:29 -0700 | [diff] [blame] | 911 | char reply_fd[30]; |
Josh Gao | ae9c1dc | 2018-05-11 12:55:56 -0700 | [diff] [blame] | 912 | snprintf(reply_fd, sizeof(reply_fd), "%d", pipe_write.get()); |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 913 | // child process |
Josh Gao | 9c869b5 | 2016-08-25 16:00:22 -0700 | [diff] [blame] | 914 | int result = execl(path.c_str(), "adb", "-L", socket_spec.c_str(), "fork-server", "server", |
| 915 | "--reply-fd", reply_fd, NULL); |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 916 | // this should not return |
Elliott Hughes | 1fc8f6e | 2017-04-18 14:34:16 -0700 | [diff] [blame] | 917 | fprintf(stderr, "adb: execl returned %d: %s\n", result, strerror(errno)); |
Elliott Hughes | 6eadee8 | 2017-06-15 08:35:24 -0700 | [diff] [blame] | 918 | } else { |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 919 | // parent side of the fork |
Elliott Hughes | 6eadee8 | 2017-06-15 08:35:24 -0700 | [diff] [blame] | 920 | char temp[3] = {}; |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 921 | // wait for the "OK\n" message |
Josh Gao | ae9c1dc | 2018-05-11 12:55:56 -0700 | [diff] [blame] | 922 | pipe_write.reset(); |
| 923 | int ret = adb_read(pipe_read.get(), temp, 3); |
JP Abgrall | 408fa57 | 2011-03-16 15:57:42 -0700 | [diff] [blame] | 924 | int saved_errno = errno; |
Josh Gao | ae9c1dc | 2018-05-11 12:55:56 -0700 | [diff] [blame] | 925 | pipe_read.reset(); |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 926 | if (ret < 0) { |
JP Abgrall | 408fa57 | 2011-03-16 15:57:42 -0700 | [diff] [blame] | 927 | fprintf(stderr, "could not read ok from ADB Server, errno = %d\n", saved_errno); |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 928 | return -1; |
| 929 | } |
| 930 | if (ret != 3 || temp[0] != 'O' || temp[1] != 'K' || temp[2] != '\n') { |
Elliott Hughes | 6eadee8 | 2017-06-15 08:35:24 -0700 | [diff] [blame] | 931 | ReportServerStartupFailure(pid); |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 932 | return -1; |
| 933 | } |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 934 | } |
Yabin Cui | e77b6a0 | 2014-11-11 09:24:11 -0800 | [diff] [blame] | 935 | #endif /* !defined(_WIN32) */ |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 936 | return 0; |
| 937 | } |
Yabin Cui | e77b6a0 | 2014-11-11 09:24:11 -0800 | [diff] [blame] | 938 | #endif /* ADB_HOST */ |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 939 | |
Josh Gao | 1906243 | 2018-07-30 18:49:03 -0700 | [diff] [blame] | 940 | bool handle_forward_request(const char* service, atransport* transport, int reply_fd) { |
| 941 | return handle_forward_request(service, [transport](std::string*) { return transport; }, |
| 942 | reply_fd); |
| 943 | } |
| 944 | |
David 'Digit' Turner | 2525869 | 2013-03-21 21:07:42 +0100 | [diff] [blame] | 945 | // Try to handle a network forwarding request. |
Josh Gao | 1906243 | 2018-07-30 18:49:03 -0700 | [diff] [blame] | 946 | bool handle_forward_request(const char* service, |
| 947 | std::function<atransport*(std::string* error)> transport_acquirer, |
| 948 | int reply_fd) { |
| 949 | if (!strcmp(service, "list-forward")) { |
| 950 | // Create the list of forward redirections. |
| 951 | std::string listeners = format_listeners(); |
| 952 | #if ADB_HOST |
| 953 | SendOkay(reply_fd); |
| 954 | #endif |
| 955 | SendProtocolString(reply_fd, listeners); |
| 956 | return true; |
| 957 | } |
| 958 | |
| 959 | if (!strcmp(service, "killforward-all")) { |
| 960 | remove_all_listeners(); |
| 961 | #if ADB_HOST |
| 962 | /* On the host: 1st OKAY is connect, 2nd OKAY is status */ |
| 963 | SendOkay(reply_fd); |
| 964 | #endif |
| 965 | SendOkay(reply_fd); |
| 966 | return true; |
| 967 | } |
| 968 | |
Elliott Hughes | 424af02 | 2015-05-29 17:55:19 -0700 | [diff] [blame] | 969 | if (!strncmp(service, "forward:", 8) || !strncmp(service, "killforward:", 12)) { |
| 970 | // killforward:local |
| 971 | // forward:(norebind:)?local;remote |
Josh Gao | 1906243 | 2018-07-30 18:49:03 -0700 | [diff] [blame] | 972 | std::string error; |
| 973 | atransport* transport = transport_acquirer(&error); |
| 974 | if (!transport) { |
| 975 | SendFail(reply_fd, error); |
| 976 | return true; |
| 977 | } |
| 978 | |
Elliott Hughes | 424af02 | 2015-05-29 17:55:19 -0700 | [diff] [blame] | 979 | bool kill_forward = false; |
| 980 | bool no_rebind = false; |
| 981 | if (android::base::StartsWith(service, "killforward:")) { |
| 982 | kill_forward = true; |
| 983 | service += 12; |
Spencer Low | a6b340a | 2015-07-29 17:21:21 -0700 | [diff] [blame] | 984 | } else { |
| 985 | service += 8; // skip past "forward:" |
Elliott Hughes | 424af02 | 2015-05-29 17:55:19 -0700 | [diff] [blame] | 986 | if (android::base::StartsWith(service, "norebind:")) { |
| 987 | no_rebind = true; |
| 988 | service += 9; |
| 989 | } |
David 'Digit' Turner | 2525869 | 2013-03-21 21:07:42 +0100 | [diff] [blame] | 990 | } |
| 991 | |
Elliott Hughes | 424af02 | 2015-05-29 17:55:19 -0700 | [diff] [blame] | 992 | std::vector<std::string> pieces = android::base::Split(service, ";"); |
David 'Digit' Turner | 2525869 | 2013-03-21 21:07:42 +0100 | [diff] [blame] | 993 | |
Elliott Hughes | 424af02 | 2015-05-29 17:55:19 -0700 | [diff] [blame] | 994 | if (kill_forward) { |
| 995 | // Check killforward: parameter format: '<local>' |
| 996 | if (pieces.size() != 1 || pieces[0].empty()) { |
| 997 | SendFail(reply_fd, android::base::StringPrintf("bad killforward: %s", service)); |
Josh Gao | 1906243 | 2018-07-30 18:49:03 -0700 | [diff] [blame] | 998 | return true; |
David 'Digit' Turner | 2525869 | 2013-03-21 21:07:42 +0100 | [diff] [blame] | 999 | } |
| 1000 | } else { |
Elliott Hughes | 424af02 | 2015-05-29 17:55:19 -0700 | [diff] [blame] | 1001 | // Check forward: parameter format: '<local>;<remote>' |
| 1002 | if (pieces.size() != 2 || pieces[0].empty() || pieces[1].empty() || pieces[1][0] == '*') { |
| 1003 | SendFail(reply_fd, android::base::StringPrintf("bad forward: %s", service)); |
Josh Gao | 1906243 | 2018-07-30 18:49:03 -0700 | [diff] [blame] | 1004 | return true; |
David 'Digit' Turner | 2525869 | 2013-03-21 21:07:42 +0100 | [diff] [blame] | 1005 | } |
| 1006 | } |
| 1007 | |
Elliott Hughes | 3bd73c1 | 2015-05-05 13:10:43 -0700 | [diff] [blame] | 1008 | InstallStatus r; |
David Pursell | eaae97e | 2016-04-07 11:25:48 -0700 | [diff] [blame] | 1009 | int resolved_tcp_port = 0; |
Elliott Hughes | 424af02 | 2015-05-29 17:55:19 -0700 | [diff] [blame] | 1010 | if (kill_forward) { |
| 1011 | r = remove_listener(pieces[0].c_str(), transport); |
David 'Digit' Turner | 2525869 | 2013-03-21 21:07:42 +0100 | [diff] [blame] | 1012 | } else { |
Raman Tenneti | b71b5af | 2019-11-12 18:57:51 +0000 | [diff] [blame] | 1013 | r = install_listener(pieces[0], pieces[1].c_str(), transport, no_rebind, |
| 1014 | &resolved_tcp_port, &error); |
David 'Digit' Turner | 2525869 | 2013-03-21 21:07:42 +0100 | [diff] [blame] | 1015 | } |
Elliott Hughes | 7b50609 | 2015-04-20 08:09:20 -0700 | [diff] [blame] | 1016 | if (r == INSTALL_STATUS_OK) { |
David 'Digit' Turner | 2525869 | 2013-03-21 21:07:42 +0100 | [diff] [blame] | 1017 | #if ADB_HOST |
David Pursell | eaae97e | 2016-04-07 11:25:48 -0700 | [diff] [blame] | 1018 | // On the host: 1st OKAY is connect, 2nd OKAY is status. |
Elliott Hughes | e67f1f8 | 2015-04-30 17:32:03 -0700 | [diff] [blame] | 1019 | SendOkay(reply_fd); |
David 'Digit' Turner | 2525869 | 2013-03-21 21:07:42 +0100 | [diff] [blame] | 1020 | #endif |
Elliott Hughes | e67f1f8 | 2015-04-30 17:32:03 -0700 | [diff] [blame] | 1021 | SendOkay(reply_fd); |
David Pursell | eaae97e | 2016-04-07 11:25:48 -0700 | [diff] [blame] | 1022 | |
| 1023 | // If a TCP port was resolved, send the actual port number back. |
| 1024 | if (resolved_tcp_port != 0) { |
| 1025 | SendProtocolString(reply_fd, android::base::StringPrintf("%d", resolved_tcp_port)); |
| 1026 | } |
| 1027 | |
Josh Gao | 1906243 | 2018-07-30 18:49:03 -0700 | [diff] [blame] | 1028 | return true; |
David 'Digit' Turner | 2525869 | 2013-03-21 21:07:42 +0100 | [diff] [blame] | 1029 | } |
| 1030 | |
Elliott Hughes | 7b50609 | 2015-04-20 08:09:20 -0700 | [diff] [blame] | 1031 | std::string message; |
| 1032 | switch (r) { |
Elliott Hughes | 424af02 | 2015-05-29 17:55:19 -0700 | [diff] [blame] | 1033 | case INSTALL_STATUS_OK: message = "success (!)"; break; |
Elliott Hughes | 7b50609 | 2015-04-20 08:09:20 -0700 | [diff] [blame] | 1034 | case INSTALL_STATUS_INTERNAL_ERROR: message = "internal error"; break; |
| 1035 | case INSTALL_STATUS_CANNOT_BIND: |
Spencer Low | bf7c605 | 2015-08-11 16:45:32 -0700 | [diff] [blame] | 1036 | message = android::base::StringPrintf("cannot bind listener: %s", |
Spencer Low | 5200c66 | 2015-07-30 23:07:55 -0700 | [diff] [blame] | 1037 | error.c_str()); |
Elliott Hughes | 7b50609 | 2015-04-20 08:09:20 -0700 | [diff] [blame] | 1038 | break; |
| 1039 | case INSTALL_STATUS_CANNOT_REBIND: |
Spencer Low | a6b340a | 2015-07-29 17:21:21 -0700 | [diff] [blame] | 1040 | message = android::base::StringPrintf("cannot rebind existing socket"); |
Elliott Hughes | 7b50609 | 2015-04-20 08:09:20 -0700 | [diff] [blame] | 1041 | break; |
Elliott Hughes | 424af02 | 2015-05-29 17:55:19 -0700 | [diff] [blame] | 1042 | case INSTALL_STATUS_LISTENER_NOT_FOUND: |
| 1043 | message = android::base::StringPrintf("listener '%s' not found", service); |
| 1044 | break; |
David 'Digit' Turner | 2525869 | 2013-03-21 21:07:42 +0100 | [diff] [blame] | 1045 | } |
Elliott Hughes | e67f1f8 | 2015-04-30 17:32:03 -0700 | [diff] [blame] | 1046 | SendFail(reply_fd, message); |
Josh Gao | 1906243 | 2018-07-30 18:49:03 -0700 | [diff] [blame] | 1047 | return true; |
David 'Digit' Turner | 2525869 | 2013-03-21 21:07:42 +0100 | [diff] [blame] | 1048 | } |
Josh Gao | 1906243 | 2018-07-30 18:49:03 -0700 | [diff] [blame] | 1049 | |
| 1050 | return false; |
David 'Digit' Turner | 2525869 | 2013-03-21 21:07:42 +0100 | [diff] [blame] | 1051 | } |
| 1052 | |
Elliott Hughes | e2d3677 | 2015-06-23 13:00:32 -0700 | [diff] [blame] | 1053 | #if ADB_HOST |
| 1054 | static int SendOkay(int fd, const std::string& s) { |
| 1055 | SendOkay(fd); |
| 1056 | SendProtocolString(fd, s); |
| 1057 | return 0; |
| 1058 | } |
Elliott Hughes | e2d3677 | 2015-06-23 13:00:32 -0700 | [diff] [blame] | 1059 | |
Josh Gao | 79797ec | 2019-02-20 20:37:26 -0800 | [diff] [blame] | 1060 | HostRequestResult handle_host_request(std::string_view service, TransportType type, |
| 1061 | const char* serial, TransportId transport_id, int reply_fd, |
| 1062 | asocket* s) { |
Josh Gao | 769f853 | 2019-02-20 19:30:59 -0800 | [diff] [blame] | 1063 | if (service == "kill") { |
Dan Albert | c89e0cc | 2015-05-08 16:13:53 -0700 | [diff] [blame] | 1064 | fprintf(stderr, "adb server killed by remote request\n"); |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 1065 | fflush(stdout); |
Josh Gao | b3c14ec | 2017-05-08 18:37:17 -0700 | [diff] [blame] | 1066 | |
| 1067 | // Send a reply even though we don't read it anymore, so that old versions |
| 1068 | // of adb that do read it don't spew error messages. |
Elliott Hughes | e67f1f8 | 2015-04-30 17:32:03 -0700 | [diff] [blame] | 1069 | SendOkay(reply_fd); |
Spencer Low | f18fc08 | 2015-08-11 17:05:02 -0700 | [diff] [blame] | 1070 | |
Josh Gao | b3c14ec | 2017-05-08 18:37:17 -0700 | [diff] [blame] | 1071 | // Rely on process exit to close the socket for us. |
Josh Gao | d51c6df | 2018-02-23 14:00:24 -0800 | [diff] [blame] | 1072 | exit(0); |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 1073 | } |
| 1074 | |
Josh Gao | 79797ec | 2019-02-20 20:37:26 -0800 | [diff] [blame] | 1075 | LOG(DEBUG) << "handle_host_request(" << service << ")"; |
| 1076 | |
| 1077 | // Transport selection: |
| 1078 | if (service.starts_with("transport") || service.starts_with("tport:")) { |
Elliott Hughes | 3bd73c1 | 2015-05-05 13:10:43 -0700 | [diff] [blame] | 1079 | TransportType type = kTransportAny; |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 1080 | |
Josh Gao | 769f853 | 2019-02-20 19:30:59 -0800 | [diff] [blame] | 1081 | std::string serial_storage; |
Josh Gao | 79797ec | 2019-02-20 20:37:26 -0800 | [diff] [blame] | 1082 | bool legacy = true; |
Josh Gao | 769f853 | 2019-02-20 19:30:59 -0800 | [diff] [blame] | 1083 | |
Josh Gao | 79797ec | 2019-02-20 20:37:26 -0800 | [diff] [blame] | 1084 | // New transport selection protocol: |
| 1085 | // This is essentially identical to the previous version, except it returns the selected |
| 1086 | // transport id to the caller as well. |
Elliott Hughes | b4dc7be | 2019-05-03 09:02:45 -0700 | [diff] [blame] | 1087 | if (android::base::ConsumePrefix(&service, "tport:")) { |
Josh Gao | 79797ec | 2019-02-20 20:37:26 -0800 | [diff] [blame] | 1088 | legacy = false; |
Elliott Hughes | b4dc7be | 2019-05-03 09:02:45 -0700 | [diff] [blame] | 1089 | if (android::base::ConsumePrefix(&service, "serial:")) { |
Josh Gao | 79797ec | 2019-02-20 20:37:26 -0800 | [diff] [blame] | 1090 | serial_storage = service; |
| 1091 | serial = serial_storage.c_str(); |
| 1092 | } else if (service == "usb") { |
| 1093 | type = kTransportUsb; |
| 1094 | } else if (service == "local") { |
| 1095 | type = kTransportLocal; |
| 1096 | } else if (service == "any") { |
| 1097 | type = kTransportAny; |
Josh Gao | b122b17 | 2017-08-16 16:57:01 -0700 | [diff] [blame] | 1098 | } |
Josh Gao | 79797ec | 2019-02-20 20:37:26 -0800 | [diff] [blame] | 1099 | |
| 1100 | // Selection by id is unimplemented, since you obviously already know the transport id |
| 1101 | // you're connecting to. |
| 1102 | } else { |
Elliott Hughes | b4dc7be | 2019-05-03 09:02:45 -0700 | [diff] [blame] | 1103 | if (android::base::ConsumePrefix(&service, "transport-id:")) { |
Josh Gao | 79797ec | 2019-02-20 20:37:26 -0800 | [diff] [blame] | 1104 | if (!ParseUint(&transport_id, service)) { |
| 1105 | SendFail(reply_fd, "invalid transport id"); |
| 1106 | return HostRequestResult::Handled; |
| 1107 | } |
| 1108 | } else if (service == "transport-usb") { |
| 1109 | type = kTransportUsb; |
| 1110 | } else if (service == "transport-local") { |
| 1111 | type = kTransportLocal; |
| 1112 | } else if (service == "transport-any") { |
| 1113 | type = kTransportAny; |
Elliott Hughes | b4dc7be | 2019-05-03 09:02:45 -0700 | [diff] [blame] | 1114 | } else if (android::base::ConsumePrefix(&service, "transport:")) { |
Josh Gao | 79797ec | 2019-02-20 20:37:26 -0800 | [diff] [blame] | 1115 | serial_storage = service; |
| 1116 | serial = serial_storage.c_str(); |
| 1117 | } |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 1118 | } |
| 1119 | |
Elliott Hughes | 8d28e19 | 2015-10-07 14:55:10 -0700 | [diff] [blame] | 1120 | std::string error; |
Josh Gao | b122b17 | 2017-08-16 16:57:01 -0700 | [diff] [blame] | 1121 | atransport* t = acquire_one_transport(type, serial, transport_id, nullptr, &error); |
Elliott Hughes | e2d3677 | 2015-06-23 13:00:32 -0700 | [diff] [blame] | 1122 | if (t != nullptr) { |
| 1123 | s->transport = t; |
Elliott Hughes | e67f1f8 | 2015-04-30 17:32:03 -0700 | [diff] [blame] | 1124 | SendOkay(reply_fd); |
Josh Gao | 4039051 | 2018-08-07 14:14:21 -0700 | [diff] [blame] | 1125 | |
Josh Gao | 79797ec | 2019-02-20 20:37:26 -0800 | [diff] [blame] | 1126 | if (!legacy) { |
| 1127 | // Nothing we can do if this fails. |
| 1128 | WriteFdExactly(reply_fd, &t->id, sizeof(t->id)); |
| 1129 | } |
| 1130 | |
| 1131 | return HostRequestResult::SwitchedTransport; |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 1132 | } else { |
Elliott Hughes | 8d28e19 | 2015-10-07 14:55:10 -0700 | [diff] [blame] | 1133 | SendFail(reply_fd, error); |
Josh Gao | 79797ec | 2019-02-20 20:37:26 -0800 | [diff] [blame] | 1134 | return HostRequestResult::Handled; |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 1135 | } |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 1136 | } |
| 1137 | |
| 1138 | // return a list of all connected devices |
Josh Gao | 769f853 | 2019-02-20 19:30:59 -0800 | [diff] [blame] | 1139 | if (service == "devices" || service == "devices-l") { |
| 1140 | bool long_listing = service == "devices-l"; |
| 1141 | D("Getting device list..."); |
| 1142 | std::string device_list = list_transports(long_listing); |
| 1143 | D("Sending device list..."); |
| 1144 | SendOkay(reply_fd, device_list); |
Josh Gao | 79797ec | 2019-02-20 20:37:26 -0800 | [diff] [blame] | 1145 | return HostRequestResult::Handled; |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 1146 | } |
| 1147 | |
Josh Gao | 769f853 | 2019-02-20 19:30:59 -0800 | [diff] [blame] | 1148 | if (service == "reconnect-offline") { |
Josh Gao | 22d2b3e | 2016-10-27 14:01:08 -0700 | [diff] [blame] | 1149 | std::string response; |
| 1150 | close_usb_devices([&response](const atransport* transport) { |
Josh Gao | 704494b | 2018-05-04 16:04:49 -0700 | [diff] [blame] | 1151 | if (!ConnectionStateIsOnline(transport->GetConnectionState())) { |
| 1152 | response += "reconnecting " + transport->serial_name() + "\n"; |
| 1153 | return true; |
Josh Gao | 22d2b3e | 2016-10-27 14:01:08 -0700 | [diff] [blame] | 1154 | } |
Josh Gao | 704494b | 2018-05-04 16:04:49 -0700 | [diff] [blame] | 1155 | return false; |
Josh Gao | 3705b34 | 2019-03-28 15:47:44 -0700 | [diff] [blame] | 1156 | }, true); |
Josh Gao | 22d2b3e | 2016-10-27 14:01:08 -0700 | [diff] [blame] | 1157 | if (!response.empty()) { |
| 1158 | response.resize(response.size() - 1); |
| 1159 | } |
| 1160 | SendOkay(reply_fd, response); |
Josh Gao | 79797ec | 2019-02-20 20:37:26 -0800 | [diff] [blame] | 1161 | return HostRequestResult::Handled; |
Josh Gao | 22d2b3e | 2016-10-27 14:01:08 -0700 | [diff] [blame] | 1162 | } |
| 1163 | |
Josh Gao | 769f853 | 2019-02-20 19:30:59 -0800 | [diff] [blame] | 1164 | if (service == "features") { |
Elliott Hughes | 8d28e19 | 2015-10-07 14:55:10 -0700 | [diff] [blame] | 1165 | std::string error; |
Josh Gao | 727b07b | 2019-09-13 00:12:26 +0800 | [diff] [blame] | 1166 | atransport* t = |
| 1167 | s->transport ? s->transport |
| 1168 | : acquire_one_transport(type, serial, transport_id, nullptr, &error); |
David Pursell | 880be43 | 2015-09-04 16:40:30 -0700 | [diff] [blame] | 1169 | if (t != nullptr) { |
David Pursell | 4e2fd36 | 2015-09-22 10:43:08 -0700 | [diff] [blame] | 1170 | SendOkay(reply_fd, FeatureSetToString(t->features())); |
David Pursell | 880be43 | 2015-09-04 16:40:30 -0700 | [diff] [blame] | 1171 | } else { |
Elliott Hughes | 8d28e19 | 2015-10-07 14:55:10 -0700 | [diff] [blame] | 1172 | SendFail(reply_fd, error); |
David Pursell | 880be43 | 2015-09-04 16:40:30 -0700 | [diff] [blame] | 1173 | } |
Josh Gao | 79797ec | 2019-02-20 20:37:26 -0800 | [diff] [blame] | 1174 | return HostRequestResult::Handled; |
David Pursell | 880be43 | 2015-09-04 16:40:30 -0700 | [diff] [blame] | 1175 | } |
| 1176 | |
Josh Gao | 769f853 | 2019-02-20 19:30:59 -0800 | [diff] [blame] | 1177 | if (service == "host-features") { |
Josh Gao | 5d1756c | 2017-02-22 17:07:01 -0800 | [diff] [blame] | 1178 | FeatureSet features = supported_features(); |
| 1179 | // Abuse features to report libusb status. |
| 1180 | if (should_use_libusb()) { |
| 1181 | features.insert(kFeatureLibusb); |
| 1182 | } |
Dan Albert | 5176df8 | 2017-05-23 14:30:00 -0700 | [diff] [blame] | 1183 | features.insert(kFeaturePushSync); |
Josh Gao | 5d1756c | 2017-02-22 17:07:01 -0800 | [diff] [blame] | 1184 | SendOkay(reply_fd, FeatureSetToString(features)); |
Josh Gao | 79797ec | 2019-02-20 20:37:26 -0800 | [diff] [blame] | 1185 | return HostRequestResult::Handled; |
Josh Gao | 5d1756c | 2017-02-22 17:07:01 -0800 | [diff] [blame] | 1186 | } |
Josh Gao | 5d1756c | 2017-02-22 17:07:01 -0800 | [diff] [blame] | 1187 | |
Mike Lockwood | 74d7ff8 | 2009-10-11 23:04:18 -0400 | [diff] [blame] | 1188 | // remove TCP transport |
Josh Gao | 769f853 | 2019-02-20 19:30:59 -0800 | [diff] [blame] | 1189 | if (service.starts_with("disconnect:")) { |
| 1190 | std::string address(service.substr(11)); |
Elliott Hughes | 3d5f60d | 2015-07-18 12:21:30 -0700 | [diff] [blame] | 1191 | if (address.empty()) { |
Yabin Cui | f4b9928 | 2015-08-27 12:03:11 -0700 | [diff] [blame] | 1192 | kick_all_tcp_devices(); |
Josh Gao | 4039051 | 2018-08-07 14:14:21 -0700 | [diff] [blame] | 1193 | SendOkay(reply_fd, "disconnected everything"); |
Josh Gao | 79797ec | 2019-02-20 20:37:26 -0800 | [diff] [blame] | 1194 | return HostRequestResult::Handled; |
Mike Lockwood | 74d7ff8 | 2009-10-11 23:04:18 -0400 | [diff] [blame] | 1195 | } |
| 1196 | |
Elliott Hughes | 3d5f60d | 2015-07-18 12:21:30 -0700 | [diff] [blame] | 1197 | std::string serial; |
| 1198 | std::string host; |
| 1199 | int port = DEFAULT_ADB_LOCAL_TRANSPORT_PORT; |
| 1200 | std::string error; |
Jason Jeremy Iman | 8bde191 | 2019-07-19 12:44:39 +0900 | [diff] [blame] | 1201 | if (address.starts_with("vsock:") || address.starts_with("localfilesystem:")) { |
Cody Schuffelen | a05b64d | 2019-01-04 18:51:11 -0800 | [diff] [blame] | 1202 | serial = address; |
| 1203 | } else if (!android::base::ParseNetAddress(address, &host, &port, &serial, &error)) { |
Josh Gao | 4039051 | 2018-08-07 14:14:21 -0700 | [diff] [blame] | 1204 | SendFail(reply_fd, android::base::StringPrintf("couldn't parse '%s': %s", |
| 1205 | address.c_str(), error.c_str())); |
Josh Gao | 79797ec | 2019-02-20 20:37:26 -0800 | [diff] [blame] | 1206 | return HostRequestResult::Handled; |
Elliott Hughes | 3d5f60d | 2015-07-18 12:21:30 -0700 | [diff] [blame] | 1207 | } |
| 1208 | atransport* t = find_transport(serial.c_str()); |
| 1209 | if (t == nullptr) { |
Josh Gao | 4039051 | 2018-08-07 14:14:21 -0700 | [diff] [blame] | 1210 | SendFail(reply_fd, android::base::StringPrintf("no such device '%s'", serial.c_str())); |
Josh Gao | 79797ec | 2019-02-20 20:37:26 -0800 | [diff] [blame] | 1211 | return HostRequestResult::Handled; |
Elliott Hughes | 3d5f60d | 2015-07-18 12:21:30 -0700 | [diff] [blame] | 1212 | } |
Yabin Cui | f4b9928 | 2015-08-27 12:03:11 -0700 | [diff] [blame] | 1213 | kick_transport(t); |
Josh Gao | 4039051 | 2018-08-07 14:14:21 -0700 | [diff] [blame] | 1214 | SendOkay(reply_fd, android::base::StringPrintf("disconnected %s", address.c_str())); |
Josh Gao | 79797ec | 2019-02-20 20:37:26 -0800 | [diff] [blame] | 1215 | return HostRequestResult::Handled; |
Mike Lockwood | 2f38b69 | 2009-08-24 15:58:40 -0700 | [diff] [blame] | 1216 | } |
| 1217 | |
Elliott Hughes | 8d28e19 | 2015-10-07 14:55:10 -0700 | [diff] [blame] | 1218 | // Returns our value for ADB_SERVER_VERSION. |
Josh Gao | 769f853 | 2019-02-20 19:30:59 -0800 | [diff] [blame] | 1219 | if (service == "version") { |
Josh Gao | 4039051 | 2018-08-07 14:14:21 -0700 | [diff] [blame] | 1220 | SendOkay(reply_fd, android::base::StringPrintf("%04x", ADB_SERVER_VERSION)); |
Josh Gao | 79797ec | 2019-02-20 20:37:26 -0800 | [diff] [blame] | 1221 | return HostRequestResult::Handled; |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 1222 | } |
| 1223 | |
Elliott Hughes | e2d3677 | 2015-06-23 13:00:32 -0700 | [diff] [blame] | 1224 | // These always report "unknown" rather than the actual error, for scripts. |
Josh Gao | 769f853 | 2019-02-20 19:30:59 -0800 | [diff] [blame] | 1225 | if (service == "get-serialno") { |
Elliott Hughes | 8d28e19 | 2015-10-07 14:55:10 -0700 | [diff] [blame] | 1226 | std::string error; |
Josh Gao | 727b07b | 2019-09-13 00:12:26 +0800 | [diff] [blame] | 1227 | atransport* t = |
| 1228 | s->transport ? s->transport |
| 1229 | : acquire_one_transport(type, serial, transport_id, nullptr, &error); |
Elliott Hughes | 8d28e19 | 2015-10-07 14:55:10 -0700 | [diff] [blame] | 1230 | if (t) { |
Josh Gao | 4039051 | 2018-08-07 14:14:21 -0700 | [diff] [blame] | 1231 | SendOkay(reply_fd, !t->serial.empty() ? t->serial : "unknown"); |
Elliott Hughes | 8d28e19 | 2015-10-07 14:55:10 -0700 | [diff] [blame] | 1232 | } else { |
Josh Gao | 4039051 | 2018-08-07 14:14:21 -0700 | [diff] [blame] | 1233 | SendFail(reply_fd, error); |
Elliott Hughes | 8d28e19 | 2015-10-07 14:55:10 -0700 | [diff] [blame] | 1234 | } |
Josh Gao | 79797ec | 2019-02-20 20:37:26 -0800 | [diff] [blame] | 1235 | return HostRequestResult::Handled; |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 1236 | } |
Josh Gao | 769f853 | 2019-02-20 19:30:59 -0800 | [diff] [blame] | 1237 | if (service == "get-devpath") { |
Elliott Hughes | 8d28e19 | 2015-10-07 14:55:10 -0700 | [diff] [blame] | 1238 | std::string error; |
Josh Gao | 727b07b | 2019-09-13 00:12:26 +0800 | [diff] [blame] | 1239 | atransport* t = |
| 1240 | s->transport ? s->transport |
| 1241 | : acquire_one_transport(type, serial, transport_id, nullptr, &error); |
Elliott Hughes | 8d28e19 | 2015-10-07 14:55:10 -0700 | [diff] [blame] | 1242 | if (t) { |
Josh Gao | 4039051 | 2018-08-07 14:14:21 -0700 | [diff] [blame] | 1243 | SendOkay(reply_fd, !t->devpath.empty() ? t->devpath : "unknown"); |
Elliott Hughes | 8d28e19 | 2015-10-07 14:55:10 -0700 | [diff] [blame] | 1244 | } else { |
Josh Gao | 4039051 | 2018-08-07 14:14:21 -0700 | [diff] [blame] | 1245 | SendFail(reply_fd, error); |
Elliott Hughes | 8d28e19 | 2015-10-07 14:55:10 -0700 | [diff] [blame] | 1246 | } |
Josh Gao | 79797ec | 2019-02-20 20:37:26 -0800 | [diff] [blame] | 1247 | return HostRequestResult::Handled; |
Scott Anderson | e109d26 | 2012-04-20 11:21:14 -0700 | [diff] [blame] | 1248 | } |
Josh Gao | 769f853 | 2019-02-20 19:30:59 -0800 | [diff] [blame] | 1249 | if (service == "get-state") { |
Elliott Hughes | 8d28e19 | 2015-10-07 14:55:10 -0700 | [diff] [blame] | 1250 | std::string error; |
Josh Gao | 727b07b | 2019-09-13 00:12:26 +0800 | [diff] [blame] | 1251 | atransport* t = |
| 1252 | s->transport ? s->transport |
| 1253 | : acquire_one_transport(type, serial, transport_id, nullptr, &error); |
Elliott Hughes | 8d28e19 | 2015-10-07 14:55:10 -0700 | [diff] [blame] | 1254 | if (t) { |
Josh Gao | 4039051 | 2018-08-07 14:14:21 -0700 | [diff] [blame] | 1255 | SendOkay(reply_fd, t->connection_state_name()); |
Elliott Hughes | 8d28e19 | 2015-10-07 14:55:10 -0700 | [diff] [blame] | 1256 | } else { |
Josh Gao | 4039051 | 2018-08-07 14:14:21 -0700 | [diff] [blame] | 1257 | SendFail(reply_fd, error); |
Elliott Hughes | 8d28e19 | 2015-10-07 14:55:10 -0700 | [diff] [blame] | 1258 | } |
Josh Gao | 79797ec | 2019-02-20 20:37:26 -0800 | [diff] [blame] | 1259 | return HostRequestResult::Handled; |
Elliott Hughes | e2d3677 | 2015-06-23 13:00:32 -0700 | [diff] [blame] | 1260 | } |
| 1261 | |
Elliott Hughes | 8d28e19 | 2015-10-07 14:55:10 -0700 | [diff] [blame] | 1262 | // Indicates a new emulator instance has started. |
Elliott Hughes | b4dc7be | 2019-05-03 09:02:45 -0700 | [diff] [blame] | 1263 | if (android::base::ConsumePrefix(&service, "emulator:")) { |
Josh Gao | 769f853 | 2019-02-20 19:30:59 -0800 | [diff] [blame] | 1264 | unsigned int port; |
| 1265 | if (!ParseUint(&port, service)) { |
| 1266 | LOG(ERROR) << "received invalid port for emulator: " << service; |
| 1267 | } else { |
| 1268 | local_connect(port); |
| 1269 | } |
| 1270 | |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 1271 | /* we don't even need to send a reply */ |
Josh Gao | 79797ec | 2019-02-20 20:37:26 -0800 | [diff] [blame] | 1272 | return HostRequestResult::Handled; |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 1273 | } |
Yabin Cui | 1f4ec19 | 2016-04-05 13:50:44 -0700 | [diff] [blame] | 1274 | |
Josh Gao | 769f853 | 2019-02-20 19:30:59 -0800 | [diff] [blame] | 1275 | if (service == "reconnect") { |
Yabin Cui | b5e1141 | 2017-03-10 16:01:01 -0800 | [diff] [blame] | 1276 | std::string response; |
Josh Gao | 727b07b | 2019-09-13 00:12:26 +0800 | [diff] [blame] | 1277 | atransport* t = s->transport ? s->transport |
| 1278 | : acquire_one_transport(type, serial, transport_id, nullptr, |
| 1279 | &response, true); |
Yabin Cui | b5e1141 | 2017-03-10 16:01:01 -0800 | [diff] [blame] | 1280 | if (t != nullptr) { |
Josh Gao | 3705b34 | 2019-03-28 15:47:44 -0700 | [diff] [blame] | 1281 | kick_transport(t, true); |
Yabin Cui | b5e1141 | 2017-03-10 16:01:01 -0800 | [diff] [blame] | 1282 | response = |
Josh Gao | 769f853 | 2019-02-20 19:30:59 -0800 | [diff] [blame] | 1283 | "reconnecting " + t->serial_name() + " [" + t->connection_state_name() + "]\n"; |
Yabin Cui | 1f4ec19 | 2016-04-05 13:50:44 -0700 | [diff] [blame] | 1284 | } |
Josh Gao | 4039051 | 2018-08-07 14:14:21 -0700 | [diff] [blame] | 1285 | SendOkay(reply_fd, response); |
Josh Gao | 79797ec | 2019-02-20 20:37:26 -0800 | [diff] [blame] | 1286 | return HostRequestResult::Handled; |
Yabin Cui | 1f4ec19 | 2016-04-05 13:50:44 -0700 | [diff] [blame] | 1287 | } |
Simon Ye | dc22c3c | 2014-07-14 17:23:06 -0700 | [diff] [blame] | 1288 | |
Josh Gao | 769f853 | 2019-02-20 19:30:59 -0800 | [diff] [blame] | 1289 | // TODO: Switch handle_forward_request to string_view. |
| 1290 | std::string service_str(service); |
Josh Gao | 727b07b | 2019-09-13 00:12:26 +0800 | [diff] [blame] | 1291 | auto transport_acquirer = [=](std::string* error) { |
| 1292 | if (s->transport) { |
| 1293 | return s->transport; |
| 1294 | } else { |
| 1295 | std::string error; |
| 1296 | return acquire_one_transport(type, serial, transport_id, nullptr, &error); |
| 1297 | } |
| 1298 | }; |
| 1299 | if (handle_forward_request(service_str.c_str(), transport_acquirer, reply_fd)) { |
Josh Gao | 79797ec | 2019-02-20 20:37:26 -0800 | [diff] [blame] | 1300 | return HostRequestResult::Handled; |
Josh Gao | 91c25c0 | 2018-07-19 17:59:45 -0700 | [diff] [blame] | 1301 | } |
| 1302 | |
Josh Gao | 79797ec | 2019-02-20 20:37:26 -0800 | [diff] [blame] | 1303 | return HostRequestResult::Unhandled; |
The Android Open Source Project | dd7bc33 | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 1304 | } |
Josh Gao | fd713e5 | 2017-05-03 22:37:10 -0700 | [diff] [blame] | 1305 | |
| 1306 | static auto& init_mutex = *new std::mutex(); |
| 1307 | static auto& init_cv = *new std::condition_variable(); |
| 1308 | static bool device_scan_complete = false; |
| 1309 | static bool transports_ready = false; |
| 1310 | |
| 1311 | void update_transport_status() { |
| 1312 | bool result = iterate_transports([](const atransport* t) { |
| 1313 | if (t->type == kTransportUsb && t->online != 1) { |
| 1314 | return false; |
| 1315 | } |
| 1316 | return true; |
| 1317 | }); |
| 1318 | |
Josh Gao | fd713e5 | 2017-05-03 22:37:10 -0700 | [diff] [blame] | 1319 | bool ready; |
Josh Gao | fd713e5 | 2017-05-03 22:37:10 -0700 | [diff] [blame] | 1320 | { |
| 1321 | std::lock_guard<std::mutex> lock(init_mutex); |
| 1322 | transports_ready = result; |
| 1323 | ready = transports_ready && device_scan_complete; |
| 1324 | } |
| 1325 | |
| 1326 | if (ready) { |
Josh Gao | fd713e5 | 2017-05-03 22:37:10 -0700 | [diff] [blame] | 1327 | init_cv.notify_all(); |
| 1328 | } |
| 1329 | } |
| 1330 | |
| 1331 | void adb_notify_device_scan_complete() { |
Josh Gao | fd713e5 | 2017-05-03 22:37:10 -0700 | [diff] [blame] | 1332 | { |
| 1333 | std::lock_guard<std::mutex> lock(init_mutex); |
Josh Gao | 0b13c89 | 2017-05-31 11:54:56 -0700 | [diff] [blame] | 1334 | if (device_scan_complete) { |
| 1335 | return; |
| 1336 | } |
| 1337 | |
Josh Gao | fd713e5 | 2017-05-03 22:37:10 -0700 | [diff] [blame] | 1338 | device_scan_complete = true; |
| 1339 | } |
| 1340 | |
| 1341 | update_transport_status(); |
| 1342 | } |
| 1343 | |
| 1344 | void adb_wait_for_device_initialization() { |
| 1345 | std::unique_lock<std::mutex> lock(init_mutex); |
| 1346 | init_cv.wait_for(lock, 3s, []() { return device_scan_complete && transports_ready; }); |
| 1347 | } |
| 1348 | |
Yabin Cui | b5e1141 | 2017-03-10 16:01:01 -0800 | [diff] [blame] | 1349 | #endif // ADB_HOST |