| /system/core/adb/ |
| D | adb.h | 66 class atransport; variable
76 void (*func)(void* opaque, atransport* t);
130 void handle_packet(apacket* p, atransport* t);
136 int init_socket_transport(atransport* t, unique_fd s, int port, int local);
137 void init_usb_transport(atransport* t, usb_handle* usb);
141 atransport* find_emulator_transport_by_adb_port(int adb_port);
142 atransport* find_emulator_transport_by_console_port(int console_port);
145 unique_fd service_to_fd(std::string_view name, atransport* transport);
147 unique_fd daemon_service_to_fd(std::string_view name, atransport* transport);
170 bool handle_forward_request(const char* service, atransport* transport, int reply_fd);
[all …]
|
| D | adb_auth.h | 43 void send_auth_response(const char* token, size_t token_size, atransport* t);
50 void adbd_auth_verified(atransport *t);
55 void adbd_auth_confirm_key(atransport* t);
56 void adbd_notify_framework_connected_key(atransport* t);
58 void send_auth_request(atransport *t);
|
| D | transport.cpp | 57 static void remove_transport(atransport* transport);
58 static void transport_unref(atransport* transport);
61 static auto& transport_list = *new std::list<atransport*>();
62 static auto& pending_list = *new std::list<atransport*>();
93 void TrackTransport(atransport* transport);
104 atransport* transport;
154 void ReconnectHandler::TrackTransport(atransport* transport) { in TrackTransport()
431 void send_packet(apacket* p, atransport* t) { in send_packet()
452 void kick_transport(atransport* t, bool reset) { in kick_transport()
570 bool iterate_transports(std::function<bool(const atransport*)> fn) { in iterate_transports()
[all …]
|
| D | transport.h | 222 class atransport {
229 using ReconnectCallback = std::function<ReconnectResult(atransport*)>;
231 atransport(ReconnectCallback reconnect, ConnectionState state) in atransport() function
243 atransport(ConnectionState state = kCsOffline)
244 : atransport([](atransport*) { return ReconnectResult::Abort; }, state) {}
245 virtual ~atransport();
367 DISALLOW_COPY_AND_ASSIGN(atransport);
378 atransport* acquire_one_transport(TransportType type, const char* serial, TransportId transport_id,
381 void kick_transport(atransport* t, bool reset = false);
386 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*>();
118 auto reconnect = [address](atransport* t) { in connect_device()
175 [](atransport*) { return ReconnectResult::Abort; })) { in local_connect_arbitrary_ports() argument
280 [](atransport*) { return ReconnectResult::Abort; }); in server_socket_thread() argument
348 static atransport* find_emulator_transport_by_adb_port_locked(int adb_port) in find_emulator_transport_by_adb_port_locked()
357 atransport* find_emulator_transport_by_adb_port(int adb_port) { in find_emulator_transport_by_adb_port()
362 atransport* find_emulator_transport_by_console_port(int console_port) { in find_emulator_transport_by_console_port()
371 int init_socket_transport(atransport* t, unique_fd fd, int adb_port, int local) { in init_socket_transport()
383 atransport* existing_transport = find_emulator_transport_by_adb_port_locked(adb_port); in init_socket_transport()
|
| D | adb.cpp | 100 void handle_online(atransport *t) in handle_online()
107 void handle_offline(atransport *t) in handle_offline()
168 static void send_ready(unsigned local, unsigned remote, atransport *t) in send_ready()
178 static void send_close(unsigned local, unsigned remote, atransport *t) in send_close()
212 void send_connect(atransport* t) { in send_connect()
236 void parse_banner(const std::string& banner, atransport* t) { in parse_banner()
292 static void handle_new_connection(atransport* t, apacket* p) { in handle_new_connection()
313 void handle_packet(apacket *p, atransport *t) in handle_packet()
908 bool handle_forward_request(const char* service, atransport* transport, int reply_fd) { in handle_forward_request()
915 std::function<atransport*(std::string* error)> transport_acquirer, 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 | services.cpp | 75 unique_fd service_to_fd(std::string_view name, atransport* transport) { in service_to_fd()
110 atransport* t = acquire_one_transport(sinfo->transport_type, serial, sinfo->transport_id, in wait_for_state()
169 atransport* known_emulator = find_emulator_transport_by_adb_port(adb_port); in connect_emulator()
|
| D | adb_listeners_test.cpp | 64 atransport transport_;
|
| D | transport_usb.cpp | 183 void init_usb_transport(atransport* t, usb_handle* h) { in init_usb_transport()
|
| D | sockets.cpp | 99 void close_all_sockets(atransport* t) { in close_all_sockets()
402 asocket* create_local_service_socket(std::string_view name, atransport* transport) { in create_local_service_socket()
486 asocket* create_remote_socket(unsigned id, atransport* t) { in create_remote_socket()
|
| /system/core/adb/daemon/ |
| D | auth.cpp | 47 static void adb_disconnected(void* unused, atransport* t);
49 static atransport* adb_transport;
130 static void adb_disconnected(void* unused, atransport* t) { in adb_disconnected()
169 void adbd_auth_confirm_key(atransport* t) { in adbd_auth_confirm_key()
220 void adbd_notify_framework_connected_key(atransport* t) { in adbd_notify_framework_connected_key()
262 void send_auth_request(atransport* t) { in send_auth_request()
278 void adbd_auth_verified(atransport* t) { in adbd_auth_verified()
|
| D | services.cpp | 63 void reconnect_service(unique_fd fd, atransport* t) { in reconnect_service()
68 unique_fd reverse_service(std::string_view command, atransport* transport) { in reverse_service()
87 unique_fd ShellService(std::string_view args, const atransport* transport) { in ShellService()
243 unique_fd daemon_service_to_fd(std::string_view name, atransport* transport) { in daemon_service_to_fd()
|
| D | transport_qemu.cpp | 102 [](atransport*) { return ReconnectResult::Abort; }); in qemu_socket_thread() argument
|
| D | usb.cpp | 728 atransport* transport = new atransport(); in usb_ffs_open_thread()
|
| /system/core/adb/client/ |
| D | auth.cpp | 423 static void send_auth_publickey(atransport* t) { in send_auth_publickey()
447 void send_auth_response(const char* token, size_t token_size, atransport* t) { in send_auth_response()
|