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.h165 asocket* host_service_to_socket(std::string_view name, std::string_view serial,
170 asocket* daemon_service_to_socket(std::string_view name, atransport* transport);
234 asocket* s);
Dadb_listeners.cpp88 asocket* s = create_local_socket(std::move(fd)); in ss_listener_event_func()
107 asocket* s = create_local_socket(std::move(fd)); in listener_event_func()
Dtransport.cpp608 asocket socket;
632 static void device_tracker_close(asocket* socket) { in device_tracker_close()
634 asocket* peer = socket->peer; in device_tracker_close()
645 static int device_tracker_enqueue(asocket* socket, apacket::payload_type) { in device_tracker_enqueue()
652 asocket* peer = tracker->socket.peer; in device_tracker_send()
663 static void device_tracker_ready(asocket* socket) { in device_tracker_ready()
674 asocket* create_device_tracker(TrackerOutputType output_type) { in create_device_tracker()
Dadb.cpp502 asocket* s = create_local_service_socket(address, t); in handle_packet()
528 asocket* s = find_local_socket(p->msg.arg1, 0); in handle_packet()
569 asocket* s = find_local_socket(p->msg.arg1, p->msg.arg0); in handle_packet()
593 asocket* s = find_local_socket(p->msg.arg1, p->msg.arg0); in handle_packet()
1250 asocket* s) { in handle_host_request()
Dservices.cpp250 asocket* host_service_to_socket(std::string_view name, std::string_view serial, in host_service_to_socket()
Dtransport.h528 asocket* create_device_tracker(TrackerOutputType type);
/packages/modules/adb/daemon/
Djdwp_service.cpp336 struct JdwpSocket : public asocket {
340 static void jdwp_socket_close(asocket* s) { in jdwp_socket_close()
354 static int jdwp_socket_enqueue(asocket* s, apacket::payload_type) { in jdwp_socket_enqueue()
361 static void jdwp_socket_ready(asocket* s) { in jdwp_socket_ready()
363 asocket* peer = jdwp->peer; in jdwp_socket_ready()
380 asocket* create_jdwp_service_socket(void) { in create_jdwp_service_socket()
402 struct JdwpTracker : public asocket {
440 static void jdwp_tracker_close(asocket* s) { in jdwp_tracker_close()
457 static void jdwp_tracker_ready(asocket* s) { in jdwp_tracker_ready()
469 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.cpp166 struct ServiceSocket : public asocket {
172 this->enqueue = [](asocket* self, apacket::payload_type data) { in ServiceSocket()
177 this->ready = [](asocket* self) { return static_cast<ServiceSocket*>(self)->Ready(); }; in ServiceSocket()
178 this->close = [](asocket* self) { return static_cast<ServiceSocket*>(self)->Close(); }; in ServiceSocket()
251 asocket* daemon_service_to_socket(std::string_view name, atransport* transport) { in daemon_service_to_socket()