| /packages/modules/adb/ |
| D | transport.cpp | 66 static void remove_transport(atransport* transport);
67 static void transport_destroy(atransport* transport);
70 static auto& transport_list = *new std::list<atransport*>();
71 static auto& pending_list = *new std::list<atransport*>();
113 void TrackTransport(atransport* transport);
124 atransport* transport;
174 void ReconnectHandler::TrackTransport(atransport* transport) { in TrackTransport()
552 void send_packet(apacket* p, atransport* t) { in send_packet()
573 void kick_transport(atransport* t, bool reset) { in kick_transport()
689 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);
136 void handle_packet(apacket* p, atransport* t);
143 int init_socket_transport(atransport* t, unique_fd s, int port, int local);
147 atransport* find_emulator_transport_by_adb_port(int adb_port);
148 atransport* find_emulator_transport_by_console_port(int console_port);
151 unique_fd service_to_fd(std::string_view name, atransport* transport);
153 unique_fd daemon_service_to_fd(std::string_view name, atransport* transport);
177 bool handle_forward_request(const char* service, atransport* transport, int reply_fd);
179 std::function<atransport*(std::string* error)> transport_acquirer,
[all …]
|
| D | transport.h | 109 void SetTransport(atransport* transport) { transport_ = transport; } in SetTransport()
133 atransport* transport_ = nullptr;
250 class atransport : public enable_weak_from_this<atransport> {
257 using ReconnectCallback = std::function<ReconnectResult(atransport*)>;
259 atransport(ReconnectCallback reconnect, ConnectionState state) in atransport() function
274 atransport(ConnectionState state = kCsOffline)
275 : atransport([](atransport*) { return ReconnectResult::Abort; }, state) {}
276 ~atransport();
422 DISALLOW_COPY_AND_ASSIGN(atransport);
445 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 | 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.cpp | 157 void handle_online(atransport *t) in handle_online()
168 void handle_offline(atransport *t) in handle_offline()
236 static void send_ready(unsigned local, unsigned remote, atransport *t) in send_ready()
246 static void send_close(unsigned local, unsigned remote, atransport *t) in send_close()
280 void send_tls_request(atransport* t) { in send_tls_request()
289 void send_connect(atransport* t) { in send_connect()
313 void parse_banner(const std::string& banner, atransport* t) { in parse_banner()
369 static void handle_new_connection(atransport* t, apacket* p) { in handle_new_connection()
399 void handle_packet(apacket *p, atransport *t) in handle_packet()
1019 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 | 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;
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 | 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 | 60 void reconnect_service(unique_fd fd, atransport* t) { in reconnect_service()
65 unique_fd reverse_service(std::string_view command, atransport* transport) { in reverse_service()
84 unique_fd ShellService(std::string_view args, const atransport* transport) { in ShellService()
262 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 | 761 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()
|