143         if(read_packet(fd, t->serial, &p)){  in transport_socket_events()
144             D("%s: failed to read packet from transport socket on fd %d", t->serial, fd);  in transport_socket_events()
176     if(write_packet(t->transport_socket, t->serial, &p)){  in send_packet()
199 …                                                (t->serial != nullptr ? t->serial : "transport")));  in read_transport_thread()
201        t->serial, t->fd, t->sync_token + 1);  in read_transport_thread()
207     if(write_packet(t->fd, t->serial, &p)) {  in read_transport_thread()
209         D("%s: failed to write SYNC packet", t->serial);  in read_transport_thread()
213     D("%s: data pump started", t->serial);  in read_transport_thread()
219               t->serial);  in read_transport_thread()
220             if(write_packet(t->fd, t->serial, &p)){  in read_transport_thread()
222                 D("%s: failed to write apacket to transport", t->serial);  in read_transport_thread()
226             D("%s: remote read failed for transport", t->serial);  in read_transport_thread()
232     D("%s: SYNC offline for transport", t->serial);  in read_transport_thread()
238     if(write_packet(t->fd, t->serial, &p)) {  in read_transport_thread()
240         D("%s: failed to write SYNC apacket to transport", t->serial);  in read_transport_thread()
244     D("%s: read_transport thread is exiting", t->serial);  in read_transport_thread()
257 …                                                (t->serial != nullptr ? t->serial : "transport")));  in write_transport_thread()
259        t->serial, t->fd);  in write_transport_thread()
262         if(read_packet(t->fd, t->serial, &p)) {  in write_transport_thread()
264                t->serial, t->fd );  in write_transport_thread()
269                 D("%s: transport SYNC offline", t->serial);  in write_transport_thread()
274                     D("%s: transport SYNC online", t->serial);  in write_transport_thread()
278                       t->serial, p->msg.arg1, t->sync_token);  in write_transport_thread()
283                 D("%s: transport got packet, sending to remote", t->serial);  in write_transport_thread()
286                 D("%s: transport ignoring packet while offline", t->serial);  in write_transport_thread()
293     D("%s: write_transport thread is exiting, fd %d", t->serial, t->fd);  in write_transport_thread()
498         D("transport: %s removing and free'ing %d", t->serial, t->transport_socket);  in transport_registration_func()
512         if (t->serial)  in transport_registration_func()
513             free(t->serial);  in transport_registration_func()
536         D("transport: %s socketpair: (%d,%d) starting", t->serial, s[0], s[1]);  in transport_registration_func()
591     D("transport: %s registered", transport->serial);  in register_transport()
602     D("transport: %s removed", transport->serial);  in remove_transport()
615         D("transport: %s unref (kicking and closing)", t->serial);  in transport_unref()
619         D("transport: %s unref (count=%zu)", t->serial, t->ref_count);  in transport_unref()
653 atransport* acquire_one_transport(TransportType type, const char* serial,  in acquire_one_transport()  argument
657     if (serial) {  in acquire_one_transport()
658         *error_out = android::base::StringPrintf("device '%s' not found", serial);  in acquire_one_transport()
677         if (serial) {  in acquire_one_transport()
678             if (t->MatchesTarget(serial)) {  in acquire_one_transport()
839     if (serial) {  in MatchesTarget()
840         if (target == serial) {  in MatchesTarget()
855             if (android::base::ParseNetAddress(serial, &serial_host, &serial_port, nullptr,  in MatchesTarget()
893     const char* serial = t->serial;  in append_transport()  local
894     if (!serial || !serial[0]) {  in append_transport()
895         serial = "(no serial number)";  in append_transport()
899         *result += serial;  in append_transport()
903         android::base::StringAppendF(result, "%-22s %s", serial,  in append_transport()
934 int register_socket_transport(int s, const char *serial, int port, int local) {  in register_socket_transport()  argument
937     if (!serial) {  in register_socket_transport()
940         serial = buf;  in register_socket_transport()
943     D("transport: %s init'ing for socket %d, on port %d", serial, s, port);  in register_socket_transport()
951         if (transport->serial && strcmp(serial, transport->serial) == 0) {  in register_socket_transport()
959         if (transport->serial && strcmp(serial, transport->serial) == 0) {  in register_socket_transport()
967     t->serial = strdup(serial);  in register_socket_transport()
975 atransport *find_transport(const char *serial) {  in find_transport()  argument
980         if (t->serial && strcmp(serial, t->serial) == 0) {  in find_transport()
1007 void register_usb_transport(usb_handle* usb, const char* serial,  in register_usb_transport()  argument
1012       serial ? serial : "");  in register_usb_transport()
1014     if(serial) {  in register_usb_transport()
1015         t->serial = strdup(serial);  in register_usb_transport()