Searched refs:packet_queue (Results 1 – 2 of 2) sorted by relevance
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()[all …]
124 IOVector packet_queue; member