Home
last modified time | relevance | path

Searched refs:apacket (Results 1 – 19 of 19) sorted by relevance

/system/core/adb/
Dtransport_benchmark.cpp66 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()
Dtransport.h112 using ReadCallback = std::function<bool(Connection*, std::unique_ptr<apacket>)>;
125 virtual bool Write(std::unique_ptr<apacket> packet) = 0;
153 virtual bool Read(apacket* packet) = 0;
154 virtual bool Write(apacket* packet) = 0;
172 virtual bool Write(std::unique_ptr<apacket> packet) override final;
189 std::deque<std::unique_ptr<apacket>> write_queue_ GUARDED_BY(mutex_);
200 bool Read(apacket* packet) override final;
201 bool Write(apacket* packet) override final;
282 int Write(apacket* p);
480 bool check_header(apacket* p, atransport* t);
[all …]
Dadb.h71 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);
Dtransport.cpp309 std::unique_ptr<apacket> packet = std::move(this->write_queue_.front()); in Start()
327 auto packet = std::make_unique<apacket>(); in StartReadThread()
422 bool BlockingConnectionAdapter::Write(std::unique_ptr<apacket> packet) { in Write()
460 bool FdConnection::Read(apacket* packet) { in Read()
481 bool FdConnection::Write(apacket* packet) { in Write()
548 void send_packet(apacket* p, atransport* t) { in send_packet()
637 static int device_tracker_enqueue(asocket* socket, apacket::payload_type) { in device_tracker_enqueue()
646 apacket::payload_type data; in device_tracker_send()
796 t->connection()->SetReadCallback([t](Connection*, std::unique_ptr<apacket> p) { in transport_registration_func()
803 apacket* packet = p.release(); in transport_registration_func()
[all …]
Dadb.cpp84 uint32_t calculate_apacket_checksum(const apacket* p) { in calculate_apacket_checksum()
92 apacket* get_apacket(void) in get_apacket()
94 apacket* p = new apacket(); in get_apacket()
103 void put_apacket(apacket *p) in put_apacket()
140 void print_packet(const char *label, apacket *p) in print_packet()
184 apacket *p = get_apacket(); in send_ready()
194 apacket *p = get_apacket(); in send_close()
227 apacket* p = get_apacket(); in send_tls_request()
236 apacket* cp = get_apacket(); in send_connect()
314 static void handle_new_connection(atransport* t, apacket* p) { in handle_new_connection()
[all …]
Dsockets.cpp154 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()
Dsocket.h76 int (*enqueue)(asocket* s, apacket::payload_type data) = nullptr;
Dtransport_fd.cpp120 auto packet = std::make_unique<apacket>(); in Run()
202 bool Write(std::unique_ptr<apacket> packet) final { in Write()
Dadb_utils.h49 std::string dump_packet(const char* name, const char* func, const apacket* p);
Dadb_utils.cpp221 std::string dump_packet(const char* name, const char* func, const apacket* p) { in dump_packet()
Dtypes.h132 struct apacket { struct
Dsocket_test.cpp124 apacket::payload_type data; in CreateCloser()
/system/core/adb/client/
Dtransport_usb.cpp67 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()
Dusb.h62 bool Read(apacket* packet) override final;
63 bool Write(apacket* packet) override final;
Dauth.cpp449 apacket* p = get_apacket(); in send_auth_publickey()
470 apacket* p = get_apacket(); in send_auth_response()
/system/core/adb/daemon/
Dservices.cpp167 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()
Djdwp_service.cpp347 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()
Dusb.cpp210 virtual bool Write(std::unique_ptr<apacket> packet) override final { in Write()
596 auto packet = std::make_unique<apacket>(); in ProcessRead()
Dauth.cpp252 apacket* p = get_apacket(); in send_auth_request()