Lines Matching refs:t
41 static void transport_unref(atransport *t);
139 atransport *t = reinterpret_cast<atransport*>(_t); in transport_socket_events() local
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()
151 void send_packet(apacket *p, atransport *t) in send_packet() argument
169 if (t == NULL) { in send_packet()
176 if(write_packet(t->transport_socket, t->serial, &p)){ in send_packet()
195 atransport *t = reinterpret_cast<atransport*>(_t); in read_transport_thread() local
199 … (t->serial != nullptr ? t->serial : "transport"))); in read_transport_thread()
201 t->serial, t->fd, t->sync_token + 1); in read_transport_thread()
205 p->msg.arg1 = ++(t->sync_token); 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()
217 if(t->read_from_remote(p, t) == 0){ 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()
245 kick_transport(t); in read_transport_thread()
246 transport_unref(t); in read_transport_thread()
252 atransport *t = reinterpret_cast<atransport*>(_t); in write_transport_thread() local
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()
273 if(p->msg.arg1 == t->sync_token) { 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()
284 t->write_to_remote(p, t); 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()
294 kick_transport(t); in write_transport_thread()
295 transport_unref(t); in write_transport_thread()
298 void kick_transport(atransport* t) { in kick_transport() argument
302 if (std::find(transport_list.begin(), transport_list.end(), t) != transport_list.end()) { in kick_transport()
303 t->Kick(); in kick_transport()
485 atransport *t; in transport_registration_func() local
495 t = m.transport; in transport_registration_func()
498 D("transport: %s removing and free'ing %d", t->serial, t->transport_socket); in transport_registration_func()
503 fdevent_remove(&(t->transport_fde)); in transport_registration_func()
504 adb_close(t->fd); in transport_registration_func()
507 transport_list.remove(t); in transport_registration_func()
510 if (t->product) in transport_registration_func()
511 free(t->product); in transport_registration_func()
512 if (t->serial) in transport_registration_func()
513 free(t->serial); in transport_registration_func()
514 if (t->model) in transport_registration_func()
515 free(t->model); in transport_registration_func()
516 if (t->device) in transport_registration_func()
517 free(t->device); in transport_registration_func()
518 if (t->devpath) in transport_registration_func()
519 free(t->devpath); in transport_registration_func()
521 delete t; in transport_registration_func()
528 if (t->connection_state != kCsNoPerm) { in transport_registration_func()
530 t->ref_count = 2; in transport_registration_func()
536 D("transport: %s socketpair: (%d,%d) starting", t->serial, s[0], s[1]); in transport_registration_func()
538 t->transport_socket = s[0]; in transport_registration_func()
539 t->fd = s[1]; in transport_registration_func()
541 fdevent_install(&(t->transport_fde), in transport_registration_func()
542 t->transport_socket, in transport_registration_func()
544 t); in transport_registration_func()
546 fdevent_set(&(t->transport_fde), FDE_READ); in transport_registration_func()
548 if (!adb_thread_create(write_transport_thread, t)) { in transport_registration_func()
552 if (!adb_thread_create(read_transport_thread, t)) { in transport_registration_func()
558 pending_list.remove(t); in transport_registration_func()
559 transport_list.push_front(t); in transport_registration_func()
609 static void transport_unref(atransport* t) { in transport_unref() argument
610 CHECK(t != nullptr); in transport_unref()
612 CHECK_GT(t->ref_count, 0u); in transport_unref()
613 t->ref_count--; in transport_unref()
614 if (t->ref_count == 0) { in transport_unref()
615 D("transport: %s unref (kicking and closing)", t->serial); in transport_unref()
616 t->close(t); in transport_unref()
617 remove_transport(t); in transport_unref()
619 D("transport: %s unref (count=%zu)", t->serial, t->ref_count); in transport_unref()
668 for (const auto& t : transport_list) { in acquire_one_transport() local
669 if (t->connection_state == kCsNoPerm) { in acquire_one_transport()
678 if (t->MatchesTarget(serial)) { in acquire_one_transport()
685 result = t; in acquire_one_transport()
688 if (type == kTransportUsb && t->type == kTransportUsb) { in acquire_one_transport()
695 result = t; in acquire_one_transport()
696 } else if (type == kTransportLocal && t->type == kTransportLocal) { in acquire_one_transport()
703 result = t; in acquire_one_transport()
711 result = t; in acquire_one_transport()
891 static void append_transport(const atransport* t, std::string* result, in append_transport() argument
893 const char* serial = t->serial; in append_transport()
901 *result += t->connection_state_name(); in append_transport()
904 t->connection_state_name().c_str()); in append_transport()
906 append_transport_info(result, "", t->devpath, false); in append_transport()
907 append_transport_info(result, "product:", t->product, false); in append_transport()
908 append_transport_info(result, "model:", t->model, true); in append_transport()
909 append_transport_info(result, "device:", t->device, false); in append_transport()
917 for (const auto& t : transport_list) { in list_transports() local
918 append_transport(t, &result, long_listing); in list_transports()
927 for (const auto& t : transport_list) { in close_usb_devices() local
928 t->Kick(); in close_usb_devices()
935 atransport* t = new atransport(); in register_socket_transport() local
939 snprintf(buf, sizeof(buf), "T-%p", t); in register_socket_transport()
944 if (init_socket_transport(t, s, port, local) < 0) { in register_socket_transport()
945 delete t; in register_socket_transport()
953 delete t; in register_socket_transport()
961 delete t; in register_socket_transport()
966 pending_list.push_front(t); in register_socket_transport()
967 t->serial = strdup(serial); in register_socket_transport()
970 register_transport(t); in register_socket_transport()
979 for (auto& t : transport_list) { in find_transport() local
980 if (t->serial && strcmp(serial, t->serial) == 0) { in find_transport()
981 result = t; in find_transport()
992 for (auto& t : transport_list) { in kick_all_tcp_devices() local
994 if (t->type == kTransportLocal && t->adb_port == 0) { in kick_all_tcp_devices()
999 t->Kick(); in kick_all_tcp_devices()
1009 atransport* t = new atransport(); in register_usb_transport() local
1011 D("transport: %p init'ing for usb_handle %p (sn='%s')", t, usb, in register_usb_transport()
1013 init_usb_transport(t, usb, (writeable ? kCsOffline : kCsNoPerm)); in register_usb_transport()
1015 t->serial = strdup(serial); in register_usb_transport()
1019 t->devpath = strdup(devpath); in register_usb_transport()
1023 pending_list.push_front(t); in register_usb_transport()
1026 register_transport(t); in register_usb_transport()
1032 transport_list.remove_if([usb](atransport* t) { in unregister_usb_transport() argument
1033 return t->usb == usb && t->connection_state == kCsNoPerm; in unregister_usb_transport()
1038 int check_header(apacket *p, atransport *t) in check_header() argument
1045 if(p->msg.data_length > t->get_max_payload()) { in check_header()
1047 << t->get_max_payload(); in check_header()