Lines Matching refs:t
560 void send_packet(apacket* p, atransport* t) { in send_packet() argument
563 if (t->get_protocol_version() >= A_VERSION_SKIP_CHECKSUM) { in send_packet()
569 VLOG(TRANSPORT) << dump_packet(t->serial.c_str(), "to remote", p); in send_packet()
571 if (t == nullptr) { in send_packet()
575 if (t->Write(p) != 0) { in send_packet()
576 D("%s: failed to enqueue packet, closing transport", t->serial.c_str()); in send_packet()
577 t->Kick(); in send_packet()
581 void kick_transport(atransport* t, bool reset) { in kick_transport() argument
587 if (std::find(transport_list.begin(), transport_list.end(), t) != transport_list.end()) { in kick_transport()
589 t->Reset(); in kick_transport()
591 t->Kick(); in kick_transport()
695 for (const auto& t : transport_list) { in iterate_transports() local
696 if (!fn(t)) { in iterate_transports()
700 for (const auto& t : pending_list) { in iterate_transports() local
701 if (!fn(t)) { in iterate_transports()
738 static void fdevent_unregister_transport(atransport* t) { in fdevent_unregister_transport() argument
739 D("transport: %s deleting", t->serial.c_str()); in fdevent_unregister_transport()
743 transport_list.remove(t); in fdevent_unregister_transport()
746 delete t; in fdevent_unregister_transport()
751 static void fdevent_register_transport(atransport* t) { in fdevent_register_transport() argument
753 if (t->GetConnectionState() != kCsNoPerm) { in fdevent_register_transport()
754 t->connection()->SetTransport(t); in fdevent_register_transport()
756 if (t->type == kTransportUsb in fdevent_register_transport()
762 t->SetConnectionState(kCsDetached); in fdevent_register_transport()
764 t->connection()->Start(); in fdevent_register_transport()
766 send_connect(t); in fdevent_register_transport()
773 auto it = std::find(pending_list.begin(), pending_list.end(), t); in fdevent_register_transport()
775 pending_list.remove(t); in fdevent_register_transport()
776 transport_list.push_front(t); in fdevent_register_transport()
795 for (auto t : transport_list) { in kick_all_transports() local
796 t->Kick(); in kick_all_transports()
802 for (auto t : transport_list) { in kick_all_tcp_tls_transports() local
803 if (t->IsTcpDevice() && t->use_tls) { in kick_all_tcp_tls_transports()
804 t->Kick(); in kick_all_tcp_tls_transports()
812 for (auto t : transport_list) { in kick_all_transports_by_auth_key() local
813 if (auth_key == t->auth_key) { in kick_all_transports_by_auth_key()
814 t->Kick(); in kick_all_transports_by_auth_key()
830 static void transport_destroy(atransport* t) { in transport_destroy() argument
832 CHECK(t != nullptr); in transport_destroy()
835 LOG(INFO) << "destroying transport " << t->serial_name(); in transport_destroy()
836 t->connection()->Stop(); in transport_destroy()
838 if (t->IsTcpDevice() && !t->kicked()) { in transport_destroy()
839 D("transport: %s destroy (attempting reconnection)", t->serial.c_str()); in transport_destroy()
843 t->ResetKeys(); in transport_destroy()
844 reconnect_handler.TrackTransport(t); in transport_destroy()
849 D("transport: %s destroy (kicking and closing)", t->serial.c_str()); in transport_destroy()
850 remove_transport(t); in transport_destroy()
924 for (const auto& t : transport_list) { in acquire_one_transport() local
925 if (t->GetConnectionState() == kCsNoPerm) { in acquire_one_transport()
931 if (t->id == transport_id) { in acquire_one_transport()
932 result = t; in acquire_one_transport()
936 if (t->MatchesTarget(serial)) { in acquire_one_transport()
943 result = t; in acquire_one_transport()
946 if (type == kTransportUsb && t->type == kTransportUsb) { in acquire_one_transport()
953 result = t; in acquire_one_transport()
954 } else if (type == kTransportLocal && t->type == kTransportLocal) { in acquire_one_transport()
961 result = t; in acquire_one_transport()
969 result = t; in acquire_one_transport()
1361 for (const auto& t : sorted_transport_list) { in transportListToProto() local
1363 device->set_serial(t->serial.c_str()); in transportListToProto()
1364 device->set_connection_type(t->type == kTransportUsb ? adb::proto::ConnectionType::USB in transportListToProto()
1366 device->set_state(adbStateFromProto(t->GetConnectionState())); in transportListToProto()
1367 device->set_bus_address(sanitize(t->devpath, false)); in transportListToProto()
1368 device->set_product(sanitize(t->product, false)); in transportListToProto()
1369 device->set_model(sanitize(t->model, true)); in transportListToProto()
1370 device->set_device(sanitize(t->device, false)); in transportListToProto()
1371 device->set_negotiated_speed(t->connection()->NegotiatedSpeedMbps()); in transportListToProto()
1372 device->set_max_speed(t->connection()->MaxSpeedMbps()); in transportListToProto()
1373 device->set_transport_id(t->id); in transportListToProto()
1396 static void append_transport(const atransport* t, std::string* result, bool long_listing) { in append_transport() argument
1397 std::string serial = t->serial; in append_transport()
1405 *result += to_string(t->GetConnectionState()); in append_transport()
1408 to_string(t->GetConnectionState()).c_str()); in append_transport()
1410 append_transport_info(result, "", t->devpath, false); in append_transport()
1411 append_transport_info(result, "product:", t->product, false); in append_transport()
1412 append_transport_info(result, "model:", t->model, true); in append_transport()
1413 append_transport_info(result, "device:", t->device, false); in append_transport()
1418 *result += std::to_string(t->id); in append_transport()
1426 for (const auto& t : sorted_transport_list) { in transportListToText() local
1427 append_transport(t, &result, long_listing); in transportListToText()
1457 for (auto& t : transport_list) { in close_usb_devices() local
1458 if (predicate(t)) { in close_usb_devices()
1460 t->Reset(); in close_usb_devices()
1462 t->Kick(); in close_usb_devices()
1475 atransport* t, int* error) { in validate_transport_list() argument
1481 delete t; in validate_transport_list()
1491 atransport* t = new atransport(std::move(reconnect), kCsOffline); in register_socket_transport() local
1492 t->use_tls = use_tls; in register_socket_transport()
1493 t->serial = std::move(serial); in register_socket_transport()
1495 D("transport: %s init'ing for socket %d, on port %d", t->serial.c_str(), s.get(), port); in register_socket_transport()
1496 if (init_socket_transport(t, std::move(s), port, local) < 0) { in register_socket_transport()
1497 delete t; in register_socket_transport()
1503 if (!validate_transport_list(pending_list, t->serial, t, error)) { in register_socket_transport()
1507 if (!validate_transport_list(transport_list, t->serial, t, error)) { in register_socket_transport()
1511 pending_list.push_front(t); in register_socket_transport()
1516 auto waitable = t->connection_waitable(); in register_socket_transport()
1518 register_transport(t); in register_socket_transport()
1531 if (t->GetConnectionState() == kCsUnauthorized) { in register_socket_transport()
1545 for (auto& t : transport_list) { in find_transport() local
1546 if (strcmp(serial, t->serial.c_str()) == 0) { in find_transport()
1547 result = t; in find_transport()
1557 for (auto& t : transport_list) { in kick_all_tcp_devices() local
1558 if (t->IsTcpDevice()) { in kick_all_tcp_devices()
1563 t->Kick(); in kick_all_tcp_devices()
1572 atransport* t = new atransport(writeable ? kCsOffline : kCsNoPerm); in register_usb_transport() local
1574 t->serial = serial; in register_usb_transport()
1577 t->devpath = devpath; in register_usb_transport()
1580 t->SetConnection(std::move(connection)); in register_usb_transport()
1581 t->type = kTransportUsb; in register_usb_transport()
1585 pending_list.push_front(t); in register_usb_transport()
1588 register_transport(t); in register_usb_transport()
1593 atransport* t = new atransport(writeable ? kCsOffline : kCsNoPerm); in register_usb_transport() local
1595 D("transport: %p init'ing for usb_handle %p (sn='%s')", t, usb, serial ? serial : ""); in register_usb_transport()
1596 init_usb_transport(t, usb); in register_usb_transport()
1598 t->serial = serial; in register_usb_transport()
1602 t->devpath = devpath; in register_usb_transport()
1607 pending_list.push_front(t); in register_usb_transport()
1610 register_transport(t); in register_usb_transport()
1616 transport_list.remove_if([usb](atransport* t) { in unregister_usb_transport() argument
1617 return t->GetUsbHandle() == usb && t->GetConnectionState() == kCsNoPerm; in unregister_usb_transport()
1680 bool check_header(apacket* p, atransport* t) { in check_header() argument
1687 if (p->msg.data_length > t->get_max_payload()) { in check_header()
1689 << " atransport::max_payload = " << t->get_max_payload(); in check_header()