Searched refs:asocket (Results 1 – 12 of 12) sorted by relevance
| /system/core/adb/ |
| D | socket.h | 36 struct asocket { struct
56 asocket* peer = nullptr; argument
76 int (*enqueue)(asocket* s, apacket::payload_type data) = nullptr; argument
81 void (*ready)(asocket* s) = nullptr; argument
87 void (*shutdown)(asocket* s) = nullptr; argument
93 void (*close)(asocket* s) = nullptr; argument
101 asocket *find_local_socket(unsigned local_id, unsigned remote_id); argument
102 void install_local_socket(asocket *s);
103 void remove_socket(asocket *s);
106 asocket* create_local_socket(unique_fd fd);
[all …]
|
| D | sockets.cpp | 50 static auto& local_socket_list = *new std::vector<asocket*>();
56 static auto& local_socket_closing_list = *new std::vector<asocket*>();
61 asocket* find_local_socket(unsigned local_id, unsigned peer_id) { in find_local_socket()
62 asocket* result = nullptr; in find_local_socket()
65 for (asocket* s : local_socket_list) { in find_local_socket()
78 void install_local_socket(asocket* s) { in install_local_socket()
91 void remove_socket(asocket* s) { in remove_socket()
94 list->erase(std::remove_if(list->begin(), list->end(), [s](asocket* x) { return x == s; }), in remove_socket()
105 for (asocket* s : local_socket_list) { in close_all_sockets()
119 static SocketFlushResult local_socket_flush_incoming(asocket* s) { in local_socket_flush_incoming()
[all …]
|
| D | socket_test.cpp | 61 asocket* prev_tail = create_local_socket(unique_fd(first[1])); in TEST_F()
64 auto connect = [](asocket* tail, asocket* head) { in TEST_F()
73 asocket* head = create_local_socket(unique_fd(intermediate[0])); in TEST_F()
76 asocket* tail = create_local_socket(unique_fd(intermediate[1])); in TEST_F()
83 asocket* end = create_local_socket(unique_fd(last[0])); in TEST_F()
114 asocket* s = create_local_socket(std::move(arg->socket_fd)); in CreateCloser()
138 asocket* cause_close_s = create_local_socket(std::move(arg->cause_close_fd)); in CreateCloser()
238 asocket* head = create_local_socket(unique_fd(head_fd[1])); in TEST_F()
239 asocket* tail = create_local_socket(unique_fd(tail_fd[1])); in TEST_F()
292 asocket* s = create_local_socket(unique_fd(accept_fd)); in TEST_F()
|
| D | adb.h | 151 asocket* host_service_to_socket(std::string_view name, std::string_view serial,
156 asocket* daemon_service_to_socket(std::string_view name);
165 asocket* create_jdwp_service_socket();
166 asocket* create_jdwp_tracker_service_socket();
233 asocket* s);
|
| D | fdevent_test.h | 69 asocket* dummy_socket = create_local_socket(unique_fd(dummy_fds[1])); in PrepareThread()
|
| D | adb_listeners.cpp | 84 asocket* s = create_local_socket(std::move(fd)); in ss_listener_event_func()
102 asocket* s = create_local_socket(std::move(fd)); in listener_event_func()
|
| D | transport.cpp | 483 asocket socket;
507 static void device_tracker_close(asocket* socket) { in device_tracker_close()
509 asocket* peer = socket->peer; in device_tracker_close()
520 static int device_tracker_enqueue(asocket* socket, apacket::payload_type) { in device_tracker_enqueue()
527 asocket* peer = tracker->socket.peer; in device_tracker_send()
538 static void device_tracker_ready(asocket* socket) { in device_tracker_ready()
551 asocket* create_device_tracker(bool long_output) { in create_device_tracker()
|
| D | adb.cpp | 374 asocket* s = create_local_service_socket(address, t); in handle_packet()
388 asocket* s = find_local_socket(p->msg.arg1, 0); in handle_packet()
413 asocket* s = find_local_socket(p->msg.arg1, p->msg.arg0); in handle_packet()
437 asocket* s = find_local_socket(p->msg.arg1, p->msg.arg0); in handle_packet()
1030 asocket* s) { in handle_host_request()
|
| D | services.cpp | 200 asocket* host_service_to_socket(std::string_view name, std::string_view serial, in host_service_to_socket()
|
| D | transport.h | 417 asocket* create_device_tracker(bool long_output);
|
| /system/core/adb/daemon/ |
| D | jdwp_service.cpp | 383 struct JdwpSocket : public asocket {
387 static void jdwp_socket_close(asocket* s) { in jdwp_socket_close()
401 static int jdwp_socket_enqueue(asocket* s, apacket::payload_type) { in jdwp_socket_enqueue()
408 static void jdwp_socket_ready(asocket* s) { in jdwp_socket_ready()
410 asocket* peer = jdwp->peer; in jdwp_socket_ready()
427 asocket* create_jdwp_service_socket(void) { in create_jdwp_service_socket()
449 struct JdwpTracker : public asocket {
469 static void jdwp_tracker_close(asocket* s) { in jdwp_tracker_close()
486 static void jdwp_tracker_ready(asocket* s) { in jdwp_tracker_ready()
498 static int jdwp_tracker_enqueue(asocket* s, apacket::payload_type) { in jdwp_tracker_enqueue()
[all …]
|
| D | services.cpp | 146 struct ServiceSocket : public asocket {
149 this->enqueue = [](asocket* self, apacket::payload_type data) { in ServiceSocket()
152 this->ready = [](asocket* self) { return static_cast<ServiceSocket*>(self)->Ready(); }; in ServiceSocket()
153 this->close = [](asocket* self) { return static_cast<ServiceSocket*>(self)->Close(); }; in ServiceSocket()
221 asocket* daemon_service_to_socket(std::string_view name) { in daemon_service_to_socket()
|