| /packages/modules/adb/ |
| D | adb.h | 73 class atransport; variable
83 void (*func)(void* opaque, atransport* t);
142 void handle_packet(apacket* p, atransport* t);
149 int init_socket_transport(atransport* t, unique_fd s, int port, int local);
153 atransport* find_emulator_transport_by_adb_port(int adb_port);
154 atransport* find_emulator_transport_by_console_port(int console_port);
157 unique_fd service_to_fd(std::string_view name, atransport* transport);
159 unique_fd daemon_service_to_fd(std::string_view name, atransport* transport);
168 asocket* daemon_service_to_socket(std::string_view name, atransport* transport);
175 bool handle_forward_request(const char* service, atransport* transport, int reply_fd);
[all …]
|
| D | transport.cpp | 68 static void remove_transport(atransport* transport);
69 static void transport_destroy(atransport* transport);
72 static auto& transport_list = *new std::list<atransport*>();
73 static auto& pending_list = *new std::list<atransport*>();
116 void TrackTransport(atransport* transport);
127 atransport* transport;
177 void ReconnectHandler::TrackTransport(atransport* transport) { in TrackTransport()
555 void send_packet(apacket* p, atransport* t) { in send_packet()
576 void kick_transport(atransport* t, bool reset) { in kick_transport()
692 bool iterate_transports(std::function<bool(const atransport*)> fn) { in iterate_transports()
[all …]
|
| D | transport.h | 112 void SetTransport(atransport* transport) { transport_ = transport; } in SetTransport()
136 atransport* transport_ = nullptr;
253 class atransport : public enable_weak_from_this<atransport> {
260 using ReconnectCallback = std::function<ReconnectResult(atransport*)>;
262 atransport(ReconnectCallback reconnect, ConnectionState state) in atransport() function
277 atransport(ConnectionState state = kCsOffline)
278 : atransport([](atransport*) { return ReconnectResult::Abort; }, state) {}
279 ~atransport();
442 DISALLOW_COPY_AND_ASSIGN(atransport);
465 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 | 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 | 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 | adb.cpp | 159 void handle_online(atransport *t) in handle_online()
170 void handle_offline(atransport *t) in handle_offline()
238 void send_ready(unsigned local, unsigned remote, atransport* t, uint32_t ack_bytes) { in send_ready()
253 static void send_close(unsigned local, unsigned remote, atransport *t) in send_close()
287 void send_tls_request(atransport* t) { in send_tls_request()
296 void send_connect(atransport* t) { in send_connect()
320 void parse_banner(const std::string& banner, atransport* t) { in parse_banner()
376 static void handle_new_connection(atransport* t, apacket* p) { in handle_new_connection()
404 void handle_packet(apacket *p, atransport *t) in handle_packet()
1074 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;
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 | 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 | 62 void reconnect_service(unique_fd fd, atransport* t) { in reconnect_service()
67 unique_fd reverse_service(std::string_view command, atransport* transport) { in reverse_service()
86 unique_fd ShellService(std::string_view args, const atransport* transport) { in ShellService()
167 explicit ServiceSocket(atransport* transport) { in ServiceSocket()
203 explicit SinkSocket(atransport* transport, size_t byte_count) in SinkSocket()
225 explicit SourceSocket(atransport* transport, size_t byte_count) in SourceSocket()
250 asocket* daemon_service_to_socket(std::string_view name, atransport* transport) { in daemon_service_to_socket()
274 unique_fd daemon_service_to_fd(std::string_view name, atransport* transport) { in daemon_service_to_fd()
|
| 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
221 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 | 193 void init_usb_transport(atransport* t, usb_handle* h) { in init_usb_transport()
|