| /packages/modules/adb/ |
| 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*>();
109 void TrackTransport(atransport* transport);
120 atransport* transport;
170 void ReconnectHandler::TrackTransport(atransport* transport) { in TrackTransport()
550 void send_packet(apacket* p, atransport* t) { in send_packet()
571 void kick_transport(atransport* t, bool reset) { in kick_transport()
687 bool iterate_transports(std::function<bool(const atransport*)> fn) { in iterate_transports()
[all …]
|
| D | adb.h | 69 class atransport; variable
79 void (*func)(void* opaque, atransport* t);
133 void handle_packet(apacket* p, atransport* t);
139 int init_socket_transport(atransport* t, unique_fd s, int port, int local);
143 atransport* find_emulator_transport_by_adb_port(int adb_port);
144 atransport* find_emulator_transport_by_console_port(int console_port);
147 unique_fd service_to_fd(std::string_view name, atransport* transport);
149 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 | transport.h | 255 class atransport : public enable_weak_from_this<atransport> {
262 using ReconnectCallback = std::function<ReconnectResult(atransport*)>;
264 atransport(ReconnectCallback reconnect, ConnectionState state) in atransport() function
279 atransport(ConnectionState state = kCsOffline)
280 : atransport([](atransport*) { return ReconnectResult::Abort; }, state) {}
281 ~atransport();
420 DISALLOW_COPY_AND_ASSIGN(atransport);
431 atransport* acquire_one_transport(TransportType type, const char* serial, TransportId transport_id,
434 void kick_transport(atransport* t, bool reset = false);
439 bool iterate_transports(std::function<bool(const atransport*)> fn);
[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_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()
138 atransport t; in TEST_F()
165 atransport t; in TEST_F()
|
| D | adb.cpp | 127 void handle_online(atransport *t) in handle_online()
138 void handle_offline(atransport *t) in handle_offline()
206 static void send_ready(unsigned local, unsigned remote, atransport *t) in send_ready()
216 static void send_close(unsigned local, unsigned remote, atransport *t) in send_close()
250 void send_tls_request(atransport* t) { in send_tls_request()
259 void send_connect(atransport* t) { in send_connect()
283 void parse_banner(const std::string& banner, atransport* t) { in parse_banner()
339 static void handle_new_connection(atransport* t, apacket* p) { in handle_new_connection()
369 void handle_packet(apacket *p, atransport *t) in handle_packet()
977 bool handle_forward_request(const char* service, atransport* transport, int reply_fd) { in handle_forward_request()
[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 | adb_listeners.cpp | 50 atransport* transport = nullptr;
114 static void listener_disconnect(void* arg, atransport*) EXCLUDES(listener_list_mutex) { in listener_disconnect() argument
144 InstallStatus remove_listener(const char* local_name, atransport* transport) in remove_listener()
189 atransport* transport, int flags, int* resolved_tcp_port, in install_listener()
|
| D | adb_listeners.h | 38 atransport* transport, int flags, int* resolved_tcp_port,
43 InstallStatus remove_listener(const char* local_name, atransport* transport);
|
| D | services.cpp | 77 unique_fd service_to_fd(std::string_view name, atransport* transport) { in service_to_fd()
120 atransport* known_emulator = find_emulator_transport_by_adb_port(adb_port); in connect_emulator()
200 atransport* t = in wait_service()
|
| D | adb_wifi.h | 36 void adbd_wifi_secure_connect(atransport* t);
|
| 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()
|
| D | adb_listeners_test.cpp | 64 atransport transport_;
|
| /packages/modules/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()
263 unique_fd daemon_service_to_fd(std::string_view name, atransport* transport) { in daemon_service_to_fd()
|
| D | transport_local.cpp | 85 [](atransport*) { return ReconnectResult::Abort; }, false); in server_socket_thread() argument
100 int init_socket_transport(atransport* t, unique_fd fd, int adb_port, int local) { in init_socket_transport()
|
| D | usb.cpp | 758 atransport* transport = new atransport(); in usb_ffs_open_thread()
|
| /packages/modules/adb/client/ |
| D | transport_local.cpp | 73 static std::unordered_map<int, atransport*> local_transports
103 auto reconnect = [prefix_addr](atransport* t) { in connect_device()
160 [](atransport*) { return ReconnectResult::Abort; }, false)) { in local_connect_arbitrary_ports() argument
262 static atransport* find_emulator_transport_by_adb_port_locked(int adb_port) in find_emulator_transport_by_adb_port_locked()
271 atransport* find_emulator_transport_by_adb_port(int adb_port) { in find_emulator_transport_by_adb_port()
276 atransport* find_emulator_transport_by_console_port(int console_port) { in find_emulator_transport_by_console_port()
284 int init_socket_transport(atransport* t, unique_fd fd, int adb_port, int local) { in init_socket_transport()
295 atransport* existing_transport = find_emulator_transport_by_adb_port_locked(adb_port); in init_socket_transport()
|
| D | auth.cpp | 435 static void send_auth_publickey(atransport* t) { in send_auth_publickey()
459 void send_auth_response(const char* token, size_t token_size, atransport* t) { in send_auth_response()
486 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()
|