Home
last modified time | relevance | path

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

/packages/modules/adb/
Dsocket.h58 struct asocket { struct
84 asocket* peer = nullptr; argument
92 int (*enqueue)(asocket* s, apacket::payload_type data) = nullptr; argument
97 void (*ready)(asocket* s) = nullptr; argument
103 void (*shutdown)(asocket* s) = nullptr; argument
109 void (*close)(asocket* s) = nullptr; argument
138 asocket *find_local_socket(unsigned local_id, unsigned remote_id); argument
139 void install_local_socket(asocket *s);
140 void remove_socket(asocket *s);
143 void local_socket_ack(asocket* s, std::optional<int32_t> acked_bytes);
[all …]
Dsockets.cpp53 static auto& local_socket_list = *new std::vector<asocket*>();
59 static auto& local_socket_closing_list = *new std::vector<asocket*>();
64 asocket* find_local_socket(unsigned local_id, unsigned peer_id) { in find_local_socket()
65 asocket* result = nullptr; in find_local_socket()
68 for (asocket* s : local_socket_list) { in find_local_socket()
81 void install_local_socket(asocket* s) { in install_local_socket()
94 void remove_socket(asocket* s) { in remove_socket()
97 list->erase(std::remove_if(list->begin(), list->end(), [s](asocket* x) { return x == s; }), in remove_socket()
108 for (asocket* s : local_socket_list) { in close_all_sockets()
122 static SocketFlushResult local_socket_flush_incoming(asocket* s) { in local_socket_flush_incoming()
[all …]
Dsocket_test.cpp62 asocket* prev_tail = create_local_socket(unique_fd(first[1])); in TEST_F()
65 auto connect = [](asocket* tail, asocket* head) { in TEST_F()
74 asocket* head = create_local_socket(unique_fd(intermediate[0])); in TEST_F()
77 asocket* tail = create_local_socket(unique_fd(intermediate[1])); in TEST_F()
84 asocket* end = create_local_socket(unique_fd(last[0])); in TEST_F()
115 asocket* s = create_local_socket(std::move(arg->socket_fd)); in CreateCloser()
141 asocket* cause_close_s = create_local_socket(std::move(arg->cause_close_fd)); in CreateCloser()
243 asocket* head = create_local_socket(unique_fd(head_fd[1])); in TEST_F()
244 asocket* tail = create_local_socket(unique_fd(tail_fd[1])); in TEST_F()
298 asocket* s = create_local_socket(unique_fd(accept_fd)); in TEST_F()
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. If traffic is inbound, the buf…
88 The two types of asocket (Remote and Local) differentiate between outbound and inbound traffic.
Dadb.h163 asocket* host_service_to_socket(std::string_view name, std::string_view serial,
168 asocket* daemon_service_to_socket(std::string_view name, atransport* transport);
229 asocket* s);
Dtransport.cpp607 asocket socket;
631 static void device_tracker_close(asocket* socket) { in device_tracker_close()
633 asocket* peer = socket->peer; in device_tracker_close()
644 static int device_tracker_enqueue(asocket* socket, apacket::payload_type) { in device_tracker_enqueue()
651 asocket* peer = tracker->socket.peer; in device_tracker_send()
662 static void device_tracker_ready(asocket* socket) { in device_tracker_ready()
673 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.cpp499 asocket* s = create_local_service_socket(address, t); in handle_packet()
525 asocket* s = find_local_socket(p->msg.arg1, 0); in handle_packet()
566 asocket* s = find_local_socket(p->msg.arg1, p->msg.arg0); in handle_packet()
590 asocket* s = find_local_socket(p->msg.arg1, p->msg.arg0); in handle_packet()
1224 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.h523 asocket* create_device_tracker(bool long_output);
/packages/modules/adb/daemon/
Djdwp_service.cpp327 struct JdwpSocket : public asocket {
331 static void jdwp_socket_close(asocket* s) { in jdwp_socket_close()
345 static int jdwp_socket_enqueue(asocket* s, apacket::payload_type) { in jdwp_socket_enqueue()
352 static void jdwp_socket_ready(asocket* s) { in jdwp_socket_ready()
354 asocket* peer = jdwp->peer; in jdwp_socket_ready()
371 asocket* create_jdwp_service_socket(void) { in create_jdwp_service_socket()
393 struct JdwpTracker : public asocket {
425 static void jdwp_tracker_close(asocket* s) { in jdwp_tracker_close()
442 static void jdwp_tracker_ready(asocket* s) { in jdwp_tracker_ready()
454 static int jdwp_tracker_enqueue(asocket* s, apacket::payload_type) { in jdwp_tracker_enqueue()
[all …]
Djdwp_service.h21 asocket* create_jdwp_service_socket();
22 asocket* create_jdwp_tracker_service_socket();
23 asocket* create_app_tracker_service_socket();
Dservices.cpp165 struct ServiceSocket : public asocket {
171 this->enqueue = [](asocket* self, apacket::payload_type data) { in ServiceSocket()
176 this->ready = [](asocket* self) { return static_cast<ServiceSocket*>(self)->Ready(); }; in ServiceSocket()
177 this->close = [](asocket* self) { return static_cast<ServiceSocket*>(self)->Close(); }; in ServiceSocket()
250 asocket* daemon_service_to_socket(std::string_view name, atransport* transport) { in daemon_service_to_socket()