| /packages/modules/adb/ |
| D | adb.h | 74 class atransport; variable
84 void (*func)(void* opaque, atransport* t);
143 void handle_packet(apacket* p, atransport* t);
151 int init_socket_transport(atransport* t, unique_fd s, int port, int local);
155 atransport* find_emulator_transport_by_adb_port(int adb_port);
156 atransport* find_emulator_transport_by_console_port(int console_port);
159 unique_fd service_to_fd(std::string_view name, atransport* transport);
161 unique_fd daemon_service_to_fd(std::string_view name, atransport* transport);
170 asocket* daemon_service_to_socket(std::string_view name, atransport* transport);
177 bool handle_forward_request(const char* service, atransport* transport, int reply_fd);
[all …]
|
| D | transport.cpp | 70 static void remove_transport(atransport* transport);
71 static void transport_destroy(atransport* transport);
74 static auto& transport_list = *new std::list<atransport*>();
75 static auto& pending_list = *new std::list<atransport*>();
121 void TrackTransport(atransport* transport);
132 atransport* transport;
182 void ReconnectHandler::TrackTransport(atransport* transport) { in TrackTransport()
560 void send_packet(apacket* p, atransport* t) { in send_packet()
581 void kick_transport(atransport* t, bool reset) { in kick_transport()
693 bool iterate_transports(std::function<bool(const atransport*)> fn) { in iterate_transports()
[all …]
|
| D | transport.h | 114 void SetTransport(atransport* transport) { transport_ = transport; } in SetTransport()
138 atransport* transport_ = nullptr;
258 class atransport : public enable_weak_from_this<atransport> {
265 using ReconnectCallback = std::function<ReconnectResult(atransport*)>;
267 atransport(ReconnectCallback reconnect, ConnectionState state) in atransport() function
282 atransport(ConnectionState state = kCsOffline)
283 : atransport([](atransport*) { return ReconnectResult::Abort; }, state) {}
284 ~atransport();
447 DISALLOW_COPY_AND_ASSIGN(atransport);
470 atransport* acquire_one_transport(TransportType type, const char* serial, TransportId transport_id,
[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);
55 void adbd_auth_verified(atransport *t);
60 void adbd_auth_confirm_key(atransport* t);
61 void adbd_notify_framework_connected_key(atransport* t);
63 void send_auth_request(atransport *t);
65 void adbd_auth_tls_handshake(atransport* t);
|
| D | socket.h | 31 class atransport; variable
112 atransport* transport = nullptr;
141 void close_all_sockets(atransport *t);
146 asocket* create_local_service_socket(std::string_view destination, atransport* transport);
148 asocket *create_remote_socket(unsigned id, atransport *t);
|
| D | transport_test.cpp | 39 static void DisconnectFunc(void* arg, atransport*) { in DisconnectFunc() argument
45 atransport t; in TEST_F()
69 atransport t; in TEST_F()
97 atransport t; in TEST_F()
110 atransport t; in TEST_F()
126 atransport t; in TEST_F()
151 atransport t; in TEST_F()
178 atransport t; in TEST_F()
|
| D | adb.cpp | 162 void handle_online(atransport *t) in handle_online()
173 void handle_offline(atransport *t) in handle_offline()
241 void send_ready(unsigned local, unsigned remote, atransport* t, uint32_t ack_bytes) { in send_ready()
256 static void send_close(unsigned local, unsigned remote, atransport *t) in send_close()
290 void send_tls_request(atransport* t) { in send_tls_request()
299 void send_connect(atransport* t) { in send_connect()
323 void parse_banner(const std::string& banner, atransport* t) { in parse_banner()
379 static void handle_new_connection(atransport* t, apacket* p) { in handle_new_connection()
407 void handle_packet(apacket *p, atransport *t) in handle_packet()
1100 bool handle_forward_request(const char* service, atransport* transport, int reply_fd) { in handle_forward_request()
[all …]
|
| D | adb_listeners.h | 40 atransport* transport, int flags, int* resolved_tcp_port,
45 InstallStatus remove_listener(const char* local_name, atransport* transport);
|
| D | adb_listeners.cpp | 53 atransport* transport = nullptr;
117 static void listener_disconnect(void* arg, atransport*) EXCLUDES(listener_list_mutex) { in listener_disconnect() argument
146 InstallStatus remove_listener(const char* local_name, atransport* transport) in remove_listener()
191 atransport* transport, int flags, int* resolved_tcp_port, in install_listener()
|
| 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()
204 atransport* t = in wait_service()
|
| D | adb_wifi.h | 35 void adbd_wifi_secure_connect(atransport* t);
|
| D | adb_listeners_test.cpp | 64 atransport transport_;
|
| D | sockets.cpp | 102 void close_all_sockets(atransport* t) { in close_all_sockets()
459 asocket* create_local_service_socket(std::string_view name, atransport* transport) { in create_local_service_socket()
544 asocket* create_remote_socket(unsigned id, atransport* t) { in create_remote_socket()
|
| /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;
69 static void* transport_to_callback_arg(atransport* transport) { in transport_to_callback_arg()
75 static atransport* transport_from_callback_arg(void* id) { in transport_from_callback_arg()
88 atransport* t = it->second.get(); in transport_from_callback_arg()
257 void send_auth_request(atransport* t) { in send_auth_request()
273 void adbd_auth_verified(atransport* t) { in adbd_auth_verified()
279 static void adb_disconnected(void* unused, atransport* t) { in adb_disconnected()
285 void adbd_auth_confirm_key(atransport* t) { in adbd_auth_confirm_key()
297 void adbd_notify_framework_connected_key(atransport* t) { in adbd_notify_framework_connected_key()
[all …]
|
| 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()
168 explicit ServiceSocket(atransport* transport) { in ServiceSocket()
204 explicit SinkSocket(atransport* transport, size_t byte_count) in SinkSocket()
226 explicit SourceSocket(atransport* transport, size_t byte_count) in SourceSocket()
251 asocket* daemon_service_to_socket(std::string_view name, atransport* transport) { in daemon_service_to_socket()
275 unique_fd daemon_service_to_fd(std::string_view name, atransport* transport) { in daemon_service_to_fd()
|
| D | adb_wifi.cpp | 36 static void adb_disconnected(void* unused, atransport* t);
39 static void adb_disconnected(void* unused, atransport* t) { in adb_disconnected()
144 [](atransport*) { return ReconnectResult::Abort; }, true); in OnFdEvent() argument
217 void adbd_wifi_secure_connect(atransport* t) { in adbd_wifi_secure_connect()
|
| 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 | 776 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 | 434 static void send_auth_publickey(atransport* t) { in send_auth_publickey()
458 void send_auth_response(const char* token, size_t token_size, atransport* t) { in send_auth_response()
485 void adb_auth_tls_handshake(atransport* t) { in adb_auth_tls_handshake()
|
| D | transport_usb.cpp | 163 void init_usb_transport(atransport* t, usb_handle* h) { in init_usb_transport()
|