Lines Matching refs:packet_queue

123     D("LS(%u) %s: %zu bytes in queue", s->id, __func__, s->packet_queue.size());  in local_socket_flush_incoming()
125     if (!s->packet_queue.empty()) {  in local_socket_flush_incoming()
126         std::vector<adb_iovec> iov = s->packet_queue.iovecs();  in local_socket_flush_incoming()
131             if (static_cast<size_t>(rc) == s->packet_queue.size()) {  in local_socket_flush_incoming()
132                 s->packet_queue.clear();  in local_socket_flush_incoming()
134                 s->packet_queue.drop_front(rc);  in local_socket_flush_incoming()
146     bool fd_full = !s->packet_queue.empty() && !s->has_write_error;  in local_socket_flush_incoming()
154             if (bytes_flushed != 0 && s->packet_queue.size() < MAX_PAYLOAD) {  in local_socket_flush_incoming()
255     s->packet_queue.append(std::move(data));  in local_socket_enqueue()
267     return !s->packet_queue.empty();  in local_socket_enqueue()
364     if (s->closing || s->has_write_error || s->packet_queue.empty()) {  in local_socket_close()