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