Searched refs:packet_queue (Results 1 – 2 of 2) sorted by relevance
120 if (!s->packet_queue.empty()) { in local_socket_flush_incoming()121 std::vector<adb_iovec> iov = s->packet_queue.iovecs(); in local_socket_flush_incoming()123 if (rc > 0 && static_cast<size_t>(rc) == s->packet_queue.size()) { in local_socket_flush_incoming()124 s->packet_queue.clear(); in local_socket_flush_incoming()127 s->packet_queue.take_front(rc); in local_socket_flush_incoming()223 s->packet_queue.append(std::move(data)); in local_socket_enqueue()235 return !s->packet_queue.empty(); in local_socket_enqueue()332 if (s->closing || s->has_write_error || s->packet_queue.empty()) { in local_socket_close()
66 IOVector packet_queue; member