| /system/core/adb/ |
| D | adb.h | 70 class atransport; variable
80 void (*func)(void* opaque, atransport* t);
134 void handle_packet(apacket* p, atransport* t);
140 int init_socket_transport(atransport* t, unique_fd s, int port, int local);
144 atransport* find_emulator_transport_by_adb_port(int adb_port);
145 atransport* find_emulator_transport_by_console_port(int console_port);
148 unique_fd service_to_fd(std::string_view name, atransport* transport);
150 unique_fd daemon_service_to_fd(std::string_view name, atransport* transport);
173 bool handle_forward_request(const char* service, atransport* transport, int reply_fd);
175 std::function<atransport*(std::string* error)> transport_acquirer,
[all …]
|
| D | adb_auth.h | 44 void send_auth_response(const char* token, size_t token_size, atransport* t);
47 void adb_auth_tls_handshake(atransport* t);
54 void adbd_auth_verified(atransport *t);
59 void adbd_auth_confirm_key(atransport* t);
60 void adbd_notify_framework_connected_key(atransport* t);
62 void send_auth_request(atransport *t);
64 void adbd_auth_tls_handshake(atransport* t);
|
| D | transport.cpp | 63 static void remove_transport(atransport* transport);
64 static void transport_destroy(atransport* transport);
67 static auto& transport_list = *new std::list<atransport*>();
68 static auto& pending_list = *new std::list<atransport*>();
103 void TrackTransport(atransport* transport);
114 atransport* transport;
164 void ReconnectHandler::TrackTransport(atransport* transport) { in TrackTransport()
548 void send_packet(apacket* p, atransport* t) { in send_packet()
569 void kick_transport(atransport* t, bool reset) { in kick_transport()
685 bool iterate_transports(std::function<bool(const atransport*)> fn) { in iterate_transports()
[all …]
|
| D | transport.h | 244 class atransport : public enable_weak_from_this<atransport> {
251 using ReconnectCallback = std::function<ReconnectResult(atransport*)>;
253 atransport(ReconnectCallback reconnect, ConnectionState state) in atransport() function
265 atransport(ConnectionState state = kCsOffline)
266 : atransport([](atransport*) { return ReconnectResult::Abort; }, state) {}
267 ~atransport();
404 DISALLOW_COPY_AND_ASSIGN(atransport);
415 atransport* acquire_one_transport(TransportType type, const char* serial, TransportId transport_id,
418 void kick_transport(atransport* t, bool reset = false);
423 bool iterate_transports(std::function<bool(const atransport*)> fn);
[all …]
|
| D | socket.h | 30 class atransport; variable
96 atransport* transport = nullptr;
104 void close_all_sockets(atransport *t);
107 asocket* create_local_service_socket(std::string_view destination, atransport* transport);
109 asocket *create_remote_socket(unsigned id, atransport *t);
|
| D | transport_test.cpp | 26 static void DisconnectFunc(void* arg, atransport*) { in DisconnectFunc() argument
32 atransport t; in TEST_F()
56 atransport t; in TEST_F()
84 atransport t; in TEST_F()
97 atransport t; in TEST_F()
113 atransport t; in TEST_F()
137 atransport t; in TEST_F()
164 atransport t; in TEST_F()
|
| D | adb_listeners.h | 36 atransport* transport, int no_rebind, int* resolved_tcp_port,
41 InstallStatus remove_listener(const char* local_name, atransport* transport);
|
| D | transport_local.cpp | 80 *new std::unordered_map<int, atransport*>();
110 auto reconnect = [prefix_addr](atransport* t) { in connect_device()
169 [](atransport*) { return ReconnectResult::Abort; }, false)) { in local_connect_arbitrary_ports() argument
278 [](atransport*) { return ReconnectResult::Abort; }, false); in server_socket_thread() argument
338 static atransport* find_emulator_transport_by_adb_port_locked(int adb_port) in find_emulator_transport_by_adb_port_locked()
347 atransport* find_emulator_transport_by_adb_port(int adb_port) { in find_emulator_transport_by_adb_port()
352 atransport* find_emulator_transport_by_console_port(int console_port) { in find_emulator_transport_by_console_port()
361 int init_socket_transport(atransport* t, unique_fd fd, int adb_port, int local) { in init_socket_transport()
373 atransport* existing_transport = find_emulator_transport_by_adb_port_locked(adb_port); in init_socket_transport()
|
| D | adb.cpp | 108 void handle_online(atransport *t) in handle_online()
115 void handle_offline(atransport *t) in handle_offline()
179 static void send_ready(unsigned local, unsigned remote, atransport *t) in send_ready()
189 static void send_close(unsigned local, unsigned remote, atransport *t) in send_close()
223 void send_tls_request(atransport* t) { in send_tls_request()
232 void send_connect(atransport* t) { in send_connect()
256 void parse_banner(const std::string& banner, atransport* t) { in parse_banner()
312 static void handle_new_connection(atransport* t, apacket* p) { in handle_new_connection()
342 void handle_packet(apacket *p, atransport *t) in handle_packet()
950 bool handle_forward_request(const char* service, atransport* transport, int reply_fd) { in handle_forward_request()
[all …]
|
| D | adb_listeners.cpp | 50 atransport* transport = nullptr;
112 static void listener_disconnect(void* arg, atransport*) EXCLUDES(listener_list_mutex) { in listener_disconnect() argument
142 InstallStatus remove_listener(const char* local_name, atransport* transport) in remove_listener()
176 atransport* transport, int no_rebind, int* resolved_tcp_port, in install_listener()
|
| D | adb_wifi.h | 35 void adbd_wifi_secure_connect(atransport* t);
|
| D | services.cpp | 77 unique_fd service_to_fd(std::string_view name, atransport* transport) { in service_to_fd()
112 atransport* t = acquire_one_transport(sinfo->transport_type, serial, sinfo->transport_id, in wait_for_state()
170 atransport* known_emulator = find_emulator_transport_by_adb_port(adb_port); in connect_emulator()
|
| D | adb_listeners_test.cpp | 64 atransport transport_;
|
| D | sockets.cpp | 101 void close_all_sockets(atransport* t) { in close_all_sockets()
403 asocket* create_local_service_socket(std::string_view name, atransport* transport) { in create_local_service_socket()
487 asocket* create_remote_socket(unsigned id, atransport* t) { in create_remote_socket()
|
| /system/core/adb/daemon/ |
| D | auth.cpp | 60 static void adb_disconnected(void* unused, atransport* t);
63 static android::base::NoDestructor<std::map<uint32_t, weak_ptr<atransport>>> transports;
68 static void* transport_to_callback_arg(atransport* transport) { in transport_to_callback_arg()
74 static atransport* transport_from_callback_arg(void* id) { in transport_from_callback_arg()
87 atransport* t = it->second.get(); in transport_from_callback_arg()
256 void send_auth_request(atransport* t) { in send_auth_request()
272 void adbd_auth_verified(atransport* t) { in adbd_auth_verified()
278 static void adb_disconnected(void* unused, atransport* t) { in adb_disconnected()
284 void adbd_auth_confirm_key(atransport* t) { in adbd_auth_confirm_key()
296 void adbd_notify_framework_connected_key(atransport* t) { in adbd_notify_framework_connected_key()
[all …]
|
| D | adb_wifi.cpp | 40 static void adb_disconnected(void* unused, atransport* t);
43 static void adb_disconnected(void* unused, atransport* t) { in adb_disconnected()
148 [](atransport*) { return ReconnectResult::Abort; }, true); in OnFdEvent() argument
220 void adbd_wifi_secure_connect(atransport* t) { in adbd_wifi_secure_connect()
|
| D | services.cpp | 61 void reconnect_service(unique_fd fd, atransport* t) { in reconnect_service()
66 unique_fd reverse_service(std::string_view command, atransport* transport) { in reverse_service()
85 unique_fd ShellService(std::string_view args, const atransport* transport) { in ShellService()
261 unique_fd daemon_service_to_fd(std::string_view name, atransport* transport) { in daemon_service_to_fd()
|
| D | transport_qemu.cpp | 110 [](atransport*) { return ReconnectResult::Abort; }, false); in qemu_socket_thread() argument
|
| D | usb.cpp | 752 atransport* transport = new atransport(); in usb_ffs_open_thread()
|
| /system/core/adb/client/ |
| D | auth.cpp | 433 static void send_auth_publickey(atransport* t) { in send_auth_publickey()
457 void send_auth_response(const char* token, size_t token_size, atransport* t) { in send_auth_response()
484 void adb_auth_tls_handshake(atransport* t) { in adb_auth_tls_handshake()
|
| D | transport_usb.cpp | 193 void init_usb_transport(atransport* t, usb_handle* h) { in init_usb_transport()
|