Home
last modified time | relevance | path

Searched refs:apacket (Results 1 – 18 of 18) 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.h84 using ReadCallback = std::function<bool(Connection*, std::unique_ptr<apacket>)>;
97 virtual bool Write(std::unique_ptr<apacket> packet) = 0;
123 virtual bool Read(apacket* packet) = 0;
124 virtual bool Write(apacket* packet) = 0;
140 virtual bool Write(std::unique_ptr<apacket> packet) override final;
154 std::deque<std::unique_ptr<apacket>> write_queue_ GUARDED_BY(mutex_);
164 bool Read(apacket* packet) override final;
165 bool Write(apacket* packet) override final;
178 bool Read(apacket* packet) override final;
179 bool Write(apacket* packet) override final;
[all …]
Dadb.h68 uint32_t calculate_apacket_checksum(const apacket* packet);
128 void print_packet(const char* label, apacket* p);
130 void handle_packet(apacket* p, atransport* t);
176 apacket* get_apacket(void);
177 void put_apacket(apacket* p);
Dtransport_usb.cpp63 static int UsbReadPayload(usb_handle* h, apacket* p) { in UsbReadPayload()
96 static int remote_read(apacket* p, usb_handle* usb) { in remote_read()
125 static int remote_read(apacket* p, usb_handle* usb) { in remote_read()
153 bool UsbConnection::Read(apacket* packet) { in Read()
158 bool UsbConnection::Write(apacket* packet) { in Write()
Dtransport.cpp283 auto packet = std::make_unique<apacket>(); in Start()
306 std::unique_ptr<apacket> packet = std::move(this->write_queue_.front()); in Start()
379 bool BlockingConnectionAdapter::Write(std::unique_ptr<apacket> packet) { in Write()
389 bool FdConnection::Read(apacket* packet) { in Read()
410 bool FdConnection::Write(apacket* packet) { in Write()
431 void send_packet(apacket* p, atransport* t) { in send_packet()
520 static int device_tracker_enqueue(asocket* socket, apacket::payload_type) { in device_tracker_enqueue()
529 apacket::payload_type data; in device_tracker_send()
684 t->connection()->SetReadCallback([t](Connection*, std::unique_ptr<apacket> p) { in transport_registration_func()
691 apacket* packet = p.release(); in transport_registration_func()
[all …]
Dtransport_fd.cpp119 auto payload = data_chain.coalesce<apacket::payload_type>(); in Run()
120 auto packet = std::make_unique<apacket>(); in Run()
198 bool Write(std::unique_ptr<apacket> packet) final { in Write()
Dadb.cpp76 uint32_t calculate_apacket_checksum(const apacket* p) { in calculate_apacket_checksum()
84 apacket* get_apacket(void) in get_apacket()
86 apacket* p = new apacket(); in get_apacket()
95 void put_apacket(apacket *p) in put_apacket()
130 void print_packet(const char *label, apacket *p) in print_packet()
171 apacket *p = get_apacket(); in send_ready()
181 apacket *p = get_apacket(); in send_close()
214 apacket* cp = get_apacket(); in send_connect()
292 static void handle_new_connection(atransport* t, apacket* p) { in handle_new_connection()
313 void handle_packet(apacket *p, atransport *t) in handle_packet()
Dsockets.cpp153 apacket::payload_type data; in local_socket_flush_outgoing()
220 static int local_socket_enqueue(asocket* s, apacket::payload_type data) { in local_socket_enqueue()
429 static int remote_socket_enqueue(asocket* s, apacket::payload_type data) { in remote_socket_enqueue()
431 apacket* p = get_apacket(); in remote_socket_enqueue()
451 apacket* p = get_apacket(); in remote_socket_ready()
461 apacket* p = get_apacket(); in remote_socket_shutdown()
504 apacket* p = get_apacket(); in connect_to_remote()
717 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;
Dadb_utils.h47 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.h134 struct apacket { struct
Dsocket_test.cpp124 apacket::payload_type data; in CreateCloser()
/system/core/adb/daemon/
Dservices.cpp149 this->enqueue = [](asocket* self, apacket::payload_type data) { in ServiceSocket()
157 virtual int Enqueue(apacket::payload_type data) { return -1; } in Enqueue()
181 virtual int Enqueue(apacket::payload_type data) override final { in Enqueue()
216 int Enqueue(apacket::payload_type data) { return -1; } in Enqueue()
Djdwp_service.cpp401 static int jdwp_socket_enqueue(asocket* s, apacket::payload_type) { in jdwp_socket_enqueue()
416 apacket::payload_type data; in jdwp_socket_ready()
463 apacket::payload_type payload(data.begin(), data.end()); in jdwp_process_list_updated()
490 apacket::payload_type data; in jdwp_tracker_ready()
498 static int jdwp_tracker_enqueue(asocket* s, apacket::payload_type) { in jdwp_tracker_enqueue()
Dauth.cpp270 apacket* p = get_apacket(); in send_auth_request()
Dusb.cpp209 virtual bool Write(std::unique_ptr<apacket> packet) override final { in Write()
559 auto packet = std::make_unique<apacket>(); in ProcessRead()
/system/core/adb/client/
Dauth.cpp437 apacket* p = get_apacket(); in send_auth_publickey()
458 apacket* p = get_apacket(); in send_auth_response()