Lines Matching refs:seq_num
45 seq_num(rtp_packet.SequenceNumber()), in Packet()
83 uint16_t seq_num = packet->seq_num; in InsertPacket() local
84 size_t index = seq_num % buffer_.size(); in InsertPacket()
87 first_seq_num_ = seq_num; in InsertPacket()
89 } else if (AheadOf(first_seq_num_, seq_num)) { in InsertPacket()
96 first_seq_num_ = seq_num; in InsertPacket()
101 if (buffer_[index]->seq_num == packet->seq_num) { in InsertPacket()
106 while (ExpandBufferSize() && buffer_[seq_num % buffer_.size()] != nullptr) { in InsertPacket()
108 index = seq_num % buffer_.size(); in InsertPacket()
132 UpdateMissingPackets(seq_num); in InsertPacket()
134 result.packets = FindFrames(seq_num); in InsertPacket()
138 void PacketBuffer::ClearTo(uint16_t seq_num) { in ClearTo() argument
142 AheadOf<uint16_t>(first_seq_num_, seq_num)) { in ClearTo()
152 ++seq_num; in ClearTo()
153 size_t diff = ForwardDiff<uint16_t>(first_seq_num_, seq_num); in ClearTo()
157 if (stored != nullptr && AheadOf<uint16_t>(seq_num, stored->seq_num)) { in ClearTo()
165 first_seq_num_ = seq_num; in ClearTo()
168 auto clear_to_it = missing_packets_.upper_bound(seq_num); in ClearTo()
180 PacketBuffer::InsertResult PacketBuffer::InsertPadding(uint16_t seq_num) { in InsertPadding() argument
183 UpdateMissingPackets(seq_num); in InsertPadding()
184 result.packets = FindFrames(static_cast<uint16_t>(seq_num + 1)); in InsertPadding()
222 new_buffer[entry->seq_num % new_size] = std::move(entry); in ExpandBufferSize()
230 bool PacketBuffer::PotentialNewFrame(uint16_t seq_num) const { in PotentialNewFrame()
231 size_t index = seq_num % buffer_.size(); in PotentialNewFrame()
238 if (entry->seq_num != seq_num) in PotentialNewFrame()
244 if (prev_entry->seq_num != static_cast<uint16_t>(entry->seq_num - 1)) in PotentialNewFrame()
255 uint16_t seq_num) { in FindFrames() argument
257 for (size_t i = 0; i < buffer_.size() && PotentialNewFrame(seq_num); ++i) { in FindFrames()
258 size_t index = seq_num % buffer_.size(); in FindFrames()
264 uint16_t start_seq_num = seq_num; in FindFrames()
374 const uint16_t end_seq_num = seq_num + 1; in FindFrames()
381 RTC_DCHECK_EQ(i, packet->seq_num); in FindFrames()
384 packet->video_header.is_last_packet_in_frame = (i == seq_num); in FindFrames()
389 missing_packets_.upper_bound(seq_num)); in FindFrames()
391 ++seq_num; in FindFrames()
396 void PacketBuffer::UpdateMissingPackets(uint16_t seq_num) { in UpdateMissingPackets() argument
398 newest_inserted_seq_num_ = seq_num; in UpdateMissingPackets()
401 if (AheadOf(seq_num, *newest_inserted_seq_num_)) { in UpdateMissingPackets()
402 uint16_t old_seq_num = seq_num - kMaxPaddingAge; in UpdateMissingPackets()
412 while (AheadOf(seq_num, *newest_inserted_seq_num_)) { in UpdateMissingPackets()
417 missing_packets_.erase(seq_num); in UpdateMissingPackets()