Lines Matching refs:t
564 void send_packet(apacket* p, atransport* t) { in send_packet() argument
567 if (t->get_protocol_version() >= A_VERSION_SKIP_CHECKSUM) { in send_packet()
573 VLOG(TRANSPORT) << dump_packet(t->serial.c_str(), "to remote", p); in send_packet()
575 if (t == nullptr) { in send_packet()
579 if (t->Write(p) != 0) { in send_packet()
580 D("%s: failed to enqueue packet, closing transport", t->serial.c_str()); in send_packet()
581 t->Kick(); in send_packet()
585 void kick_transport(atransport* t, bool reset) { in kick_transport() argument
591 if (std::find(transport_list.begin(), transport_list.end(), t) != transport_list.end()) { in kick_transport()
593 t->Reset(); in kick_transport()
595 t->Kick(); in kick_transport()
699 for (const auto& t : transport_list) { in iterate_transports() local
700 if (!fn(t)) { in iterate_transports()
704 for (const auto& t : pending_list) { in iterate_transports() local
705 if (!fn(t)) { in iterate_transports()
734 static void fdevent_unregister_transport(atransport* t) { in fdevent_unregister_transport() argument
735 VLOG(TRANSPORT) << "unregistering transport: " << t->serial; in fdevent_unregister_transport()
739 transport_list.remove(t); in fdevent_unregister_transport()
740 pending_list.remove(t); in fdevent_unregister_transport()
743 delete t; in fdevent_unregister_transport()
748 static void fdevent_register_transport(atransport* t) { in fdevent_register_transport() argument
749 auto state = to_string(t->GetConnectionState()); in fdevent_register_transport()
750 VLOG(TRANSPORT) << "registering: " << t->serial.c_str() << " state=" << state in fdevent_register_transport()
751 << " type=" << t->type; in fdevent_register_transport()
754 if (t->GetConnectionState() != kCsNoPerm) { in fdevent_register_transport()
755 t->connection()->SetTransport(t); in fdevent_register_transport()
758 if (t->type == kTransportUsb && in fdevent_register_transport()
759 attached_devices.ShouldStartDetached(*t->connection().get())) { in fdevent_register_transport()
760 VLOG(TRANSPORT) << "Force-detaching transport:" << t->serial; in fdevent_register_transport()
761 t->SetConnectionState(kCsDetached); in fdevent_register_transport()
764 VLOG(TRANSPORT) << "transport:" << t->serial << "(" << state << ")"; in fdevent_register_transport()
765 if (t->GetConnectionState() != kCsDetached) { in fdevent_register_transport()
766 VLOG(TRANSPORT) << "Starting transport:" << t->serial; in fdevent_register_transport()
767 if (t->connection()->Start()) { in fdevent_register_transport()
768 send_connect(t); in fdevent_register_transport()
770 VLOG(TRANSPORT) << "transport:" << t->serial << " failed to start."; in fdevent_register_transport()
775 VLOG(TRANSPORT) << "Starting transport:" << t->serial; in fdevent_register_transport()
776 t->connection()->Start(); in fdevent_register_transport()
782 auto it = std::find(pending_list.begin(), pending_list.end(), t); in fdevent_register_transport()
784 pending_list.remove(t); in fdevent_register_transport()
785 transport_list.push_front(t); in fdevent_register_transport()
804 for (auto t : transport_list) { in kick_all_transports() local
805 t->Kick(); in kick_all_transports()
811 for (auto t : transport_list) { in kick_all_tcp_tls_transports() local
812 if (t->IsTcpDevice() && t->use_tls) { in kick_all_tcp_tls_transports()
813 t->Kick(); in kick_all_tcp_tls_transports()
821 for (auto t : transport_list) { in kick_all_transports_by_auth_key() local
822 if (auth_key == t->auth_key) { in kick_all_transports_by_auth_key()
823 t->Kick(); in kick_all_transports_by_auth_key()
837 static void transport_destroy(atransport* t) { in transport_destroy() argument
839 CHECK(t != nullptr); in transport_destroy()
842 VLOG(TRANSPORT) << "destroying transport " << t->serial_name(); in transport_destroy()
843 t->connection()->Stop(); in transport_destroy()
845 if (t->IsTcpDevice() && !t->kicked()) { in transport_destroy()
846 D("transport: %s destroy (attempting reconnection)", t->serial.c_str()); in transport_destroy()
850 t->ResetKeys(); in transport_destroy()
851 reconnect_handler.TrackTransport(t); in transport_destroy()
856 D("transport: %s destroy (kicking and closing)", t->serial.c_str()); in transport_destroy()
857 remove_transport(t); in transport_destroy()
931 for (const auto& t : transport_list) { in acquire_one_transport() local
932 if (t->GetConnectionState() == kCsNoPerm) { in acquire_one_transport()
938 if (t->id == transport_id) { in acquire_one_transport()
939 result = t; in acquire_one_transport()
943 if (t->MatchesTarget(serial)) { in acquire_one_transport()
950 result = t; in acquire_one_transport()
953 if (type == kTransportUsb && t->type == kTransportUsb) { in acquire_one_transport()
960 result = t; in acquire_one_transport()
961 } else if (type == kTransportLocal && t->type == kTransportLocal) { in acquire_one_transport()
968 result = t; in acquire_one_transport()
976 result = t; in acquire_one_transport()
1375 for (const auto& t : sorted_transport_list) { in transportListToProto() local
1377 device->set_serial(t->serial.c_str()); in transportListToProto()
1378 device->set_connection_type(t->type == kTransportUsb ? adb::proto::ConnectionType::USB in transportListToProto()
1380 device->set_state(adbStateFromProto(t->GetConnectionState())); in transportListToProto()
1381 device->set_bus_address(sanitize(t->devpath, false)); in transportListToProto()
1382 device->set_product(sanitize(t->product, false)); in transportListToProto()
1383 device->set_model(sanitize(t->model, true)); in transportListToProto()
1384 device->set_device(sanitize(t->device, false)); in transportListToProto()
1385 device->set_negotiated_speed(t->connection()->NegotiatedSpeedMbps()); in transportListToProto()
1386 device->set_max_speed(t->connection()->MaxSpeedMbps()); in transportListToProto()
1387 device->set_transport_id(t->id); in transportListToProto()
1410 static void append_transport(const atransport* t, std::string* result, bool long_listing) { in append_transport() argument
1411 std::string serial = t->serial; in append_transport()
1419 *result += to_string(t->GetConnectionState()); in append_transport()
1422 to_string(t->GetConnectionState()).c_str()); in append_transport()
1424 append_transport_info(result, "", t->devpath, false); in append_transport()
1425 append_transport_info(result, "product:", t->product, false); in append_transport()
1426 append_transport_info(result, "model:", t->model, true); in append_transport()
1427 append_transport_info(result, "device:", t->device, false); in append_transport()
1432 *result += std::to_string(t->id); in append_transport()
1440 for (const auto& t : sorted_transport_list) { in transportListToText() local
1441 append_transport(t, &result, long_listing); in transportListToText()
1471 for (auto& t : transport_list) { in close_usb_devices() local
1472 if (predicate(t)) { in close_usb_devices()
1474 t->Reset(); in close_usb_devices()
1476 t->Kick(); in close_usb_devices()
1489 atransport* t, int* error) { in validate_transport_list() argument
1495 delete t; in validate_transport_list()
1505 atransport* t = new atransport(kTransportLocal, std::move(reconnect), kCsOffline); in register_socket_transport() local
1506 t->use_tls = use_tls; in register_socket_transport()
1507 t->serial = std::move(serial); in register_socket_transport()
1509 D("transport: %s init'ing for socket %d, on port %d", t->serial.c_str(), s.get(), port); in register_socket_transport()
1510 if (init_socket_transport(t, std::move(s), port, is_emulator) < 0) { in register_socket_transport()
1511 delete t; in register_socket_transport()
1517 if (!validate_transport_list(pending_list, t->serial, t, error)) { in register_socket_transport()
1521 if (!validate_transport_list(transport_list, t->serial, t, error)) { in register_socket_transport()
1525 pending_list.push_front(t); in register_socket_transport()
1530 auto waitable = t->connection_waitable(); in register_socket_transport()
1532 register_transport(t); in register_socket_transport()
1544 if (t->GetConnectionState() == kCsUnauthorized) { in register_socket_transport()
1558 for (auto& t : transport_list) { in find_transport() local
1559 if (strcmp(serial, t->serial.c_str()) == 0) { in find_transport()
1560 result = t; in find_transport()
1570 for (auto& t : transport_list) { in kick_all_tcp_devices() local
1571 if (t->IsTcpDevice()) { in kick_all_tcp_devices()
1576 t->Kick(); in kick_all_tcp_devices()
1585 atransport* t = new atransport(kTransportUsb, writeable ? kCsOffline : kCsNoPerm); in register_libusb_transport() local
1587 t->serial = serial; in register_libusb_transport()
1590 t->devpath = devpath; in register_libusb_transport()
1593 t->SetConnection(std::move(connection)); in register_libusb_transport()
1597 pending_list.push_front(t); in register_libusb_transport()
1600 register_transport(t); in register_libusb_transport()
1605 atransport* t = new atransport(kTransportUsb, writeable ? kCsOffline : kCsNoPerm); in register_usb_transport() local
1607 D("transport: %p init'ing for usb_handle %p (sn='%s')", t, usb, serial ? serial : ""); in register_usb_transport()
1608 init_usb_transport(t, usb); in register_usb_transport()
1610 t->serial = serial; in register_usb_transport()
1614 t->devpath = devpath; in register_usb_transport()
1619 pending_list.push_front(t); in register_usb_transport()
1622 register_transport(t); in register_usb_transport()
1628 transport_list.remove_if([usb](atransport* t) { in unregister_usb_transport() argument
1629 return t->GetUsbHandle() == usb && t->GetConnectionState() == kCsNoPerm; in unregister_usb_transport()
1692 bool check_header(apacket* p, atransport* t) { in check_header() argument
1699 if (p->msg.data_length > t->get_max_payload()) { in check_header()
1701 << " atransport::max_payload = " << t->get_max_payload(); in check_header()