Lines Matching refs:apacket
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()
1099 int atransport::Write(apacket* p) { in Write()
1100 return this->connection()->Write(std::unique_ptr<apacket>(p)) ? 0 : -1; in Write()
1524 bool check_header(apacket* p, atransport* t) { in check_header()