Searched refs:packet_queue_ (Results 1 – 7 of 7) sorted by relevance
| /external/cronet/tot/net/third_party/quiche/src/quiche/quic/qbone/ |
| D | qbone_packet_exchanger.cc | 42 if (packet_queue_.empty() && !write_blocked_) { in WritePacketToNetwork()
57 if (packet_queue_.size() >= max_pending_packets_) { in WritePacketToNetwork()
63 packet_queue_.push_back( in WritePacketToNetwork()
69 while (!packet_queue_.empty()) { in SetWritable()
72 if (WritePacket(packet_queue_.front()->data(), in SetWritable()
73 packet_queue_.front()->length(), &blocked, &error)) { in SetWritable()
74 packet_queue_.pop_front(); in SetWritable()
|
| D | qbone_packet_exchanger.h | 70 std::list<std::unique_ptr<QuicData>> packet_queue_; variable
|
| /external/cronet/stable/net/third_party/quiche/src/quiche/quic/qbone/ |
| D | qbone_packet_exchanger.cc | 42 if (packet_queue_.empty() && !write_blocked_) { in WritePacketToNetwork()
57 if (packet_queue_.size() >= max_pending_packets_) { in WritePacketToNetwork()
63 packet_queue_.push_back( in WritePacketToNetwork()
69 while (!packet_queue_.empty()) { in SetWritable()
72 if (WritePacket(packet_queue_.front()->data(), in SetWritable()
73 packet_queue_.front()->length(), &blocked, &error)) { in SetWritable()
74 packet_queue_.pop_front(); in SetWritable()
|
| D | qbone_packet_exchanger.h | 70 std::list<std::unique_ptr<QuicData>> packet_queue_; variable
|
| /external/webrtc/modules/pacing/ |
| D | pacing_controller.cc | 88 packet_queue_(/*creation_time=*/last_process_time_), in PacingController()
126 packet_queue_.SetPauseState(true, CurrentTime()); in Pause()
133 packet_queue_.SetPauseState(false, CurrentTime()); in Resume()
207 if (packet_queue_.Empty()) { in EnqueuePacket()
220 packet_queue_.Push(now, std::move(packet)); in EnqueuePacket()
251 return rtc::checked_cast<size_t>(packet_queue_.SizeInPackets()); in QueueSizePackets()
256 return packet_queue_.SizeInPacketsPerRtpPacketMediaType(); in SizeInPacketsPerRtpPacketMediaType()
260 DataSize size = packet_queue_.SizeInPayloadBytes(); in QueueSizeData()
262 size += static_cast<int64_t>(packet_queue_.SizeInPackets()) * in QueueSizeData()
277 return packet_queue_.OldestEnqueueTime(); in OldestPacketEnqueueTime()
[all …]
|
| D | pacing_controller.h | 238 PrioritizedPacketQueue packet_queue_; variable
|
| /external/pigweed/pw_rpc_transport/public/pw_rpc_transport/ |
| D | local_rpc_egress.h | 83 internal::PacketBufferQueue<kMaxPacketSize> packet_queue_{packet_storage_};
106 auto packet_buffer = packet_queue_.Pop(); in SendRpcPacket()
147 packet_queue_.Push(**packet_buffer); in Run()
|