| /packages/modules/adb/ |
| D | transport_benchmark.cpp | 66 client->SetReadCallback([](Connection*, std::unique_ptr<apacket>) -> bool { return true; }); in BM_Connection_Unidirectional() argument
67 … server->SetReadCallback([&received_bytes](Connection*, std::unique_ptr<apacket> packet) -> bool { in BM_Connection_Unidirectional()
82 std::unique_ptr<apacket> packet = std::make_unique<apacket>(); in BM_Connection_Unidirectional()
124 … client->SetReadCallback([&received_bytes](Connection*, std::unique_ptr<apacket> packet) -> bool { in BM_Connection_Echo()
129 static const auto handle_packet = [](Connection* connection, std::unique_ptr<apacket> packet) { in BM_Connection_Echo()
133 server->SetReadCallback([](Connection* connection, std::unique_ptr<apacket> packet) -> bool { in BM_Connection_Echo()
137 std::unique_ptr<apacket> packet(raw_packet); in BM_Connection_Echo()
156 std::unique_ptr<apacket> packet = std::make_unique<apacket>(); in BM_Connection_Echo()
|
| D | transport.h | 113 using ReadCallback = std::function<bool(Connection*, std::unique_ptr<apacket>)>;
126 virtual bool Write(std::unique_ptr<apacket> packet) = 0;
154 virtual bool Read(apacket* packet) = 0;
155 virtual bool Write(apacket* packet) = 0;
173 virtual bool Write(std::unique_ptr<apacket> packet) override final;
190 std::deque<std::unique_ptr<apacket>> write_queue_ GUARDED_BY(mutex_);
201 bool Read(apacket* packet) override final;
202 bool Write(apacket* packet) override final;
283 int Write(apacket* p);
482 bool check_header(apacket* p, atransport* t);
[all …]
|
| D | adb.h | 71 uint32_t calculate_apacket_checksum(const apacket* packet);
131 void print_packet(const char* label, apacket* p);
133 void handle_packet(apacket* p, atransport* t);
179 apacket* get_apacket(void);
180 void put_apacket(apacket* p);
|
| D | adb.cpp | 103 uint32_t calculate_apacket_checksum(const apacket* p) { in calculate_apacket_checksum()
111 apacket* get_apacket(void) in get_apacket()
113 apacket* p = new apacket(); in get_apacket()
122 void put_apacket(apacket *p) in put_apacket()
165 void print_packet(const char *label, apacket *p) in print_packet()
209 apacket *p = get_apacket(); in send_ready()
219 apacket *p = get_apacket(); in send_close()
252 apacket* p = get_apacket(); in send_tls_request()
261 apacket* cp = get_apacket(); in send_connect()
339 static void handle_new_connection(atransport* t, apacket* p) { in handle_new_connection()
[all …]
|
| D | transport.cpp | 311 std::unique_ptr<apacket> packet = std::move(this->write_queue_.front()); in Start()
329 auto packet = std::make_unique<apacket>(); in StartReadThread()
424 bool BlockingConnectionAdapter::Write(std::unique_ptr<apacket> packet) { in Write()
462 bool FdConnection::Read(apacket* packet) { in Read()
483 bool FdConnection::Write(apacket* packet) { in Write()
550 void send_packet(apacket* p, atransport* t) { in send_packet()
639 static int device_tracker_enqueue(asocket* socket, apacket::payload_type) { in device_tracker_enqueue()
648 apacket::payload_type data; in device_tracker_send()
798 t->connection()->SetReadCallback([t](Connection*, std::unique_ptr<apacket> p) { in transport_registration_func()
805 apacket* packet = p.release(); in transport_registration_func()
[all …]
|
| D | README.md | 62 …ket, apacket, and amessage constructs exist only to wrap data while it transits on a Transport. An…
64 …eatures a buffer where the elemental unit is an apacket. Is traffic is inbound, the buffer stores …
86 …. Note that unlike TCP which feature an "unacknowledged-send window", an apacket is sent only afte…
|
| D | sockets.cpp | 154 apacket::payload_type data; in local_socket_flush_outgoing()
221 static int local_socket_enqueue(asocket* s, apacket::payload_type data) { in local_socket_enqueue()
430 static int remote_socket_enqueue(asocket* s, apacket::payload_type data) { in remote_socket_enqueue()
432 apacket* p = get_apacket(); in remote_socket_enqueue()
452 apacket* p = get_apacket(); in remote_socket_ready()
462 apacket* p = get_apacket(); in remote_socket_shutdown()
505 apacket* p = get_apacket(); in connect_to_remote()
716 static int smart_socket_enqueue(asocket* s, apacket::payload_type data) { in smart_socket_enqueue()
|
| D | transport_fd.cpp | 120 auto packet = std::make_unique<apacket>(); in Run()
202 bool Write(std::unique_ptr<apacket> packet) final { in Write()
|
| D | socket.h | 76 int (*enqueue)(asocket* s, apacket::payload_type data) = nullptr;
|
| D | adb_utils.h | 49 std::string dump_packet(const char* name, const char* func, const apacket* p);
|
| D | types.h | 132 struct apacket { struct
|
| D | adb_utils.cpp | 221 std::string dump_packet(const char* name, const char* func, const apacket* p) { in dump_packet()
|
| D | socket_test.cpp | 124 apacket::payload_type data; in CreateCloser()
|
| /packages/modules/adb/client/ |
| D | transport_usb.cpp | 67 static int UsbReadPayload(usb_handle* h, apacket* p) { in UsbReadPayload()
100 static int remote_read(apacket* p, usb_handle* usb) { in remote_read()
129 static int remote_read(apacket* p, usb_handle* usb) { in remote_read()
157 bool UsbConnection::Read(apacket* packet) { in Read()
162 bool UsbConnection::Write(apacket* packet) { in Write()
|
| D | usb.h | 52 bool Read(apacket* packet) override final;
53 bool Write(apacket* packet) override final;
|
| D | auth.cpp | 449 apacket* p = get_apacket(); in send_auth_publickey()
470 apacket* p = get_apacket(); in send_auth_response()
|
| D | usb_libusb.cpp | 121 auto packet = std::make_unique<apacket>(); in HandlePacket()
300 bool Write(std::unique_ptr<apacket> packet) final { in Write()
|
| /packages/modules/adb/daemon/ |
| D | jdwp_service.cpp | 347 static int jdwp_socket_enqueue(asocket* s, apacket::payload_type) { in jdwp_socket_enqueue()
362 apacket::payload_type data; in jdwp_socket_ready()
413 apacket::payload_type payload(data.begin(), data.end()); in process_list_updated()
448 apacket::payload_type data; in jdwp_tracker_ready()
456 static int jdwp_tracker_enqueue(asocket* s, apacket::payload_type) { in jdwp_tracker_enqueue()
|
| D | services.cpp | 167 this->enqueue = [](asocket* self, apacket::payload_type data) { in ServiceSocket()
175 virtual int Enqueue(apacket::payload_type data) { return -1; } in Enqueue()
199 virtual int Enqueue(apacket::payload_type data) override final { in Enqueue()
234 int Enqueue(apacket::payload_type data) { return -1; } in Enqueue()
|
| D | usb.cpp | 181 virtual bool Write(std::unique_ptr<apacket> packet) override final { in Write()
580 auto packet = std::make_unique<apacket>(); in ProcessRead()
|
| D | auth.cpp | 264 apacket* p = get_apacket(); in send_auth_request()
|