Lines Matching refs:packet_queue_
129 packet_queue_(last_process_time_, field_trials_), in PacingController()
157 packet_queue_.SetPauseState(true, CurrentTime()); in Pause()
164 packet_queue_.SetPauseState(false, CurrentTime()); in Resume()
247 packet_queue_.SetIncludeOverhead(); in SetIncludeOverhead()
254 packet_queue_.SetTransportOverhead(overhead_per_packet); in SetTransportOverhead()
265 return packet_queue_.SizeInPackets(); in QueueSizePackets()
269 return packet_queue_.Size(); in QueueSizeData()
281 Timestamp oldest_packet = packet_queue_.OldestEnqueueTime(); in OldestPacketWaitTime()
300 if (mode_ == ProcessMode::kDynamic && packet_queue_.Empty() && in EnqueuePacketInternal()
305 packet_queue_.Push(priority, now, packet_counter_++, std::move(packet)); in EnqueuePacketInternal()
365 packet_queue_.LeadingAudioPacketEnqueueTime(); in NextSendTime()
377 if (media_rate_ > DataRate::Zero() && !packet_queue_.Empty()) { in NextSendTime()
385 if (padding_rate_ > DataRate::Zero() && packet_queue_.Empty()) { in NextSendTime()
458 DataSize queue_size_data = packet_queue_.Size(); in ProcessPackets()
463 packet_queue_.UpdateQueueTime(now); in ProcessPackets()
467 queue_time_limit - packet_queue_.AverageQueueTime()); in ProcessPackets()
613 if (!packet_queue_.Empty()) { in PaddingToAdd()
649 if (packet_queue_.Empty()) { in GetPendingPacket()
657 !pace_audio_ && packet_queue_.LeadingAudioPacketEnqueueTime().has_value(); in GetPendingPacket()
684 return packet_queue_.Pop(); in GetPendingPacket()