| /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 | 116 virtual bool Write(std::unique_ptr<apacket> packet) = 0;
157 virtual bool Read(apacket* packet) = 0;
158 virtual bool Write(apacket* packet) = 0;
176 virtual bool Write(std::unique_ptr<apacket> packet) override final;
193 std::deque<std::unique_ptr<apacket>> write_queue_ GUARDED_BY(mutex_);
204 bool Read(apacket* packet) override final;
205 bool Write(apacket* packet) override final;
286 int Write(apacket* p);
301 bool HandleRead(std::unique_ptr<apacket> p);
519 bool check_header(apacket* p, atransport* t);
[all …]
|
| D | adb.h | 76 uint32_t calculate_apacket_checksum(const apacket* packet);
141 void print_packet(const char* label, apacket* p);
143 void handle_packet(apacket* p, atransport* t);
183 apacket* get_apacket(void);
184 void put_apacket(apacket* p);
|
| D | README.md | 62 …ket, apacket, and amessage constructs exist only to wrap data while it transits on a Transport. An…
64 …tures a buffer where the elemental unit is an apacket. If traffic is inbound, the buffer stores th…
86 …. Note that unlike TCP which feature an "unacknowledged-send window", an apacket is sent only afte…
|
| D | adb.cpp | 110 uint32_t calculate_apacket_checksum(const apacket* p) { in calculate_apacket_checksum()
147 apacket* get_apacket(void) { in get_apacket()
148 apacket* p = new apacket(); in get_apacket()
157 void put_apacket(apacket *p) in put_apacket()
200 void print_packet(const char *label, apacket *p) in print_packet()
243 apacket *p = get_apacket(); in send_ready()
259 apacket *p = get_apacket(); in send_close()
292 apacket* p = get_apacket(); in send_tls_request()
301 apacket* cp = get_apacket(); in send_connect()
379 static void handle_new_connection(atransport* t, apacket* p) { in handle_new_connection()
[all …]
|
| D | transport.cpp | 324 std::unique_ptr<apacket> packet = std::move(this->write_queue_.front()); in Start()
342 auto packet = std::make_unique<apacket>(); in StartReadThread()
434 bool BlockingConnectionAdapter::Write(std::unique_ptr<apacket> packet) { in Write()
472 bool FdConnection::Read(apacket* packet) { in Read()
493 bool FdConnection::Write(apacket* packet) { in Write()
560 void send_packet(apacket* p, atransport* t) { in send_packet()
645 static int device_tracker_enqueue(asocket* socket, apacket::payload_type) { in device_tracker_enqueue()
654 apacket::payload_type data; in device_tracker_send()
1046 int atransport::Write(apacket* p) { in Write()
1047 return this->connection()->Write(std::unique_ptr<apacket>(p)) ? 0 : -1; in Write()
[all …]
|
| D | sockets.cpp | 178 apacket::payload_type data; in local_socket_flush_outgoing()
252 static int local_socket_enqueue(asocket* s, apacket::payload_type data) { in local_socket_enqueue()
487 static int remote_socket_enqueue(asocket* s, apacket::payload_type data) { in remote_socket_enqueue()
489 apacket* p = get_apacket(); in remote_socket_enqueue()
509 apacket* p = get_apacket(); in remote_socket_ready()
519 apacket* p = get_apacket(); in remote_socket_shutdown()
568 apacket* p = get_apacket(); in connect_to_remote()
784 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 | 92 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 | 134 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 | 125 apacket::payload_type data; in CreateCloser()
|
| /packages/modules/adb/client/ |
| D | transport_usb.cpp | 65 static int UsbReadPayload(usb_handle* h, apacket* p) { in UsbReadPayload()
98 static int remote_read(apacket* p, usb_handle* usb) { in remote_read()
127 bool UsbConnection::Read(apacket* packet) { in Read()
132 bool UsbConnection::Write(apacket* packet) { in Write()
|
| D | usb.h | 50 bool Read(apacket* packet) override final;
51 bool Write(apacket* packet) override final;
|
| D | auth.cpp | 448 apacket* p = get_apacket(); in send_auth_publickey()
469 apacket* p = get_apacket(); in send_auth_response()
|
| D | usb_libusb.cpp | 136 auto packet = std::make_unique<apacket>(); in HandlePacket()
323 bool Write(std::unique_ptr<apacket> packet) final { in Write()
|
| /packages/modules/adb/daemon/ |
| D | jdwp_service.cpp | 354 static int jdwp_socket_enqueue(asocket* s, apacket::payload_type) { in jdwp_socket_enqueue()
369 apacket::payload_type data; in jdwp_socket_ready()
426 apacket::payload_type payload(data.begin(), data.end()); in process_list_updated()
461 apacket::payload_type data; in jdwp_tracker_ready()
469 static int jdwp_tracker_enqueue(asocket* s, apacket::payload_type) { in jdwp_tracker_enqueue()
|
| D | services.cpp | 172 this->enqueue = [](asocket* self, apacket::payload_type data) { in ServiceSocket()
187 virtual int Enqueue(apacket::payload_type data) { return -1; } in Enqueue()
211 virtual int Enqueue(apacket::payload_type data) override final { in Enqueue()
246 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()
584 auto packet = std::make_unique<apacket>(); in ProcessRead()
|
| D | auth.cpp | 265 apacket* p = get_apacket(); in send_auth_request()
|