Home
last modified time | relevance | path

Searched refs:asocket (Results 1 – 13 of 13) sorted by relevance

/packages/modules/adb/
Dsocket.h36 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 …]
Dsockets.cpp52 static auto& local_socket_list = *new std::vector<asocket*>();
58 static auto& local_socket_closing_list = *new std::vector<asocket*>();
63 asocket* find_local_socket(unsigned local_id, unsigned peer_id) { in find_local_socket()
64 asocket* result = nullptr; in find_local_socket()
67 for (asocket* s : local_socket_list) { in find_local_socket()
80 void install_local_socket(asocket* s) { in install_local_socket()
93 void remove_socket(asocket* s) { in remove_socket()
96 list->erase(std::remove_if(list->begin(), list->end(), [s](asocket* x) { return x == s; }), in remove_socket()
107 for (asocket* s : local_socket_list) { in close_all_sockets()
121 static SocketFlushResult local_socket_flush_incoming(asocket* s) { in local_socket_flush_incoming()
[all …]
Dsocket_test.cpp61 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()
Dadb.h153 asocket* host_service_to_socket(std::string_view name, std::string_view serial,
158 asocket* daemon_service_to_socket(std::string_view name);
167 asocket* create_jdwp_service_socket();
168 asocket* create_jdwp_tracker_service_socket();
169 asocket* create_app_tracker_service_socket();
229 asocket* s);
DREADME.md62 …asocket, apacket, and amessage constructs exist only to wrap data while it transits on a Transport…
64 An asocket features a buffer where the elemental unit is an apacket. Is traffic is inbound, the buf…
88 The two types of asocket (Remote and Local) differentiate between outbound and inbound traffic.
Dtransport.cpp602 asocket socket;
626 static void device_tracker_close(asocket* socket) { in device_tracker_close()
628 asocket* peer = socket->peer; in device_tracker_close()
639 static int device_tracker_enqueue(asocket* socket, apacket::payload_type) { in device_tracker_enqueue()
646 asocket* peer = tracker->socket.peer; in device_tracker_send()
657 static void device_tracker_ready(asocket* socket) { in device_tracker_ready()
668 asocket* create_device_tracker(bool long_output) { in create_device_tracker()
Dadb_listeners.cpp85 asocket* s = create_local_socket(std::move(fd)); in ss_listener_event_func()
104 asocket* s = create_local_socket(std::move(fd)); in listener_event_func()
Dadb.cpp443 asocket* s = create_local_service_socket(address, t); in handle_packet()
457 asocket* s = find_local_socket(p->msg.arg1, 0); in handle_packet()
482 asocket* s = find_local_socket(p->msg.arg1, p->msg.arg0); in handle_packet()
506 asocket* s = find_local_socket(p->msg.arg1, p->msg.arg0); in handle_packet()
1127 asocket* s) { in handle_host_request()
Dservices.cpp242 asocket* host_service_to_socket(std::string_view name, std::string_view serial, in host_service_to_socket()
Dtransport.h489 asocket* create_device_tracker(bool long_output);
/packages/modules/adb/daemon/
Djdwp_service.cpp329 struct JdwpSocket : public asocket {
333 static void jdwp_socket_close(asocket* s) { in jdwp_socket_close()
347 static int jdwp_socket_enqueue(asocket* s, apacket::payload_type) { in jdwp_socket_enqueue()
354 static void jdwp_socket_ready(asocket* s) { in jdwp_socket_ready()
356 asocket* peer = jdwp->peer; in jdwp_socket_ready()
373 asocket* create_jdwp_service_socket(void) { in create_jdwp_service_socket()
395 struct JdwpTracker : public asocket {
427 static void jdwp_tracker_close(asocket* s) { in jdwp_tracker_close()
444 static void jdwp_tracker_ready(asocket* s) { in jdwp_tracker_ready()
456 static int jdwp_tracker_enqueue(asocket* s, apacket::payload_type) { in jdwp_tracker_enqueue()
[all …]
Dservices.cpp164 struct ServiceSocket : public asocket {
167 this->enqueue = [](asocket* self, apacket::payload_type data) { in ServiceSocket()
170 this->ready = [](asocket* self) { return static_cast<ServiceSocket*>(self)->Ready(); }; in ServiceSocket()
171 this->close = [](asocket* self) { return static_cast<ServiceSocket*>(self)->Close(); }; in ServiceSocket()
239 asocket* daemon_service_to_socket(std::string_view name) { in daemon_service_to_socket()
/packages/modules/adb/fdevent/
Dfdevent_test.h75 asocket* dummy_socket = create_local_socket(unique_fd(dummy_fds[1])); in PrepareThread()