Lines Matching refs:hist_
39 hist_(&fake_clock_, /*enable_padding_prio=*/GetParam()) {} in RtpPacketHistoryTest()
42 RtpPacketHistory hist_; member in webrtc::RtpPacketHistoryTest
55 EXPECT_EQ(StorageMode::kDisabled, hist_.GetStorageMode()); in TEST_P()
56 hist_.SetStorePacketsStatus(StorageMode::kStoreAndCull, 10); in TEST_P()
57 EXPECT_EQ(StorageMode::kStoreAndCull, hist_.GetStorageMode()); in TEST_P()
58 hist_.SetStorePacketsStatus(StorageMode::kStoreAndCull, 10); in TEST_P()
59 EXPECT_EQ(StorageMode::kStoreAndCull, hist_.GetStorageMode()); in TEST_P()
60 hist_.SetStorePacketsStatus(StorageMode::kDisabled, 0); in TEST_P()
61 EXPECT_EQ(StorageMode::kDisabled, hist_.GetStorageMode()); in TEST_P()
65 hist_.SetStorePacketsStatus(StorageMode::kStoreAndCull, 10); in TEST_P()
67 hist_.PutRtpPacket(CreateRtpPacket(kStartSeqNum), absl::nullopt); in TEST_P()
68 EXPECT_TRUE(hist_.GetPacketState(kStartSeqNum)); in TEST_P()
71 hist_.SetStorePacketsStatus(StorageMode::kStoreAndCull, 10); in TEST_P()
72 EXPECT_FALSE(hist_.GetPacketState(kStartSeqNum)); in TEST_P()
76 hist_.SetStorePacketsStatus(StorageMode::kStoreAndCull, 10); in TEST_P()
78 hist_.PutRtpPacket(CreateRtpPacket(kStartSeqNum), absl::nullopt); in TEST_P()
79 EXPECT_TRUE(hist_.GetPacketState(kStartSeqNum)); in TEST_P()
82 hist_.SetStorePacketsStatus(StorageMode::kStoreAndCull, 10); in TEST_P()
83 EXPECT_FALSE(hist_.GetPacketState(kStartSeqNum)); in TEST_P()
86 hist_.PutRtpPacket(CreateRtpPacket(To16u(kStartSeqNum + 1)), absl::nullopt); in TEST_P()
87 EXPECT_TRUE(hist_.GetPacketState(To16u(kStartSeqNum + 1))); in TEST_P()
95 hist_.PutRtpPacket(CreateRtpPacket(To16u(kStartSeqNum + 2)), absl::nullopt); in TEST_P()
96 EXPECT_FALSE(hist_.GetPacketState(kStartSeqNum)); in TEST_P()
97 EXPECT_TRUE(hist_.GetPacketState(To16u(kStartSeqNum + 1))); in TEST_P()
98 EXPECT_TRUE(hist_.GetPacketState(To16u(kStartSeqNum + 2))); in TEST_P()
102 EXPECT_EQ(StorageMode::kDisabled, hist_.GetStorageMode()); in TEST_P()
104 hist_.PutRtpPacket(std::move(packet), absl::nullopt); in TEST_P()
106 EXPECT_FALSE(hist_.GetPacketState(kStartSeqNum)); in TEST_P()
110 hist_.SetStorePacketsStatus(StorageMode::kStoreAndCull, 10); in TEST_P()
111 EXPECT_FALSE(hist_.GetPacketState(0)); in TEST_P()
115 hist_.SetStorePacketsStatus(StorageMode::kStoreAndCull, 10); in TEST_P()
118 EXPECT_FALSE(hist_.GetPacketState(kStartSeqNum)); in TEST_P()
119 hist_.PutRtpPacket(std::move(packet), absl::nullopt); in TEST_P()
120 EXPECT_TRUE(hist_.GetPacketState(kStartSeqNum)); in TEST_P()
124 hist_.SetStorePacketsStatus(StorageMode::kStoreAndCull, 10); in TEST_P()
129 hist_.PutRtpPacket(std::move(packet), absl::nullopt); in TEST_P()
132 hist_.GetPacketAndSetSendTime(kStartSeqNum); in TEST_P()
141 hist_.SetStorePacketsStatus(StorageMode::kStoreAndCull, 10); in TEST_P()
142 hist_.SetRtt(kRttMs); in TEST_P()
148 hist_.PutRtpPacket(std::move(packet), fake_clock_.TimeInMilliseconds()); in TEST_P()
151 hist_.GetPacketState(kStartSeqNum); in TEST_P()
161 EXPECT_TRUE(hist_.GetPacketAndSetSendTime(kStartSeqNum)); in TEST_P()
164 state = hist_.GetPacketState(kStartSeqNum); in TEST_P()
172 hist_.SetStorePacketsStatus(StorageMode::kStoreAndCull, 10); in TEST_P()
173 hist_.SetRtt(kMinRetransmitIntervalMs); in TEST_P()
177 hist_.PutRtpPacket(std::move(packet), absl::nullopt); in TEST_P()
180 EXPECT_TRUE(hist_.GetPacketAndSetSendTime(kStartSeqNum)); in TEST_P()
192 hist_.GetPacketState(kStartSeqNum); in TEST_P()
198 EXPECT_TRUE(hist_.GetPacketAndSetSendTime(kStartSeqNum)); in TEST_P()
202 EXPECT_FALSE(hist_.GetPacketState(kStartSeqNum)); in TEST_P()
206 EXPECT_TRUE(hist_.GetPacketState(kStartSeqNum)); in TEST_P()
207 EXPECT_TRUE(hist_.GetPacketAndSetSendTime(kStartSeqNum)); in TEST_P()
213 hist_.SetStorePacketsStatus(StorageMode::kStoreAndCull, 10); in TEST_P()
214 hist_.SetRtt(kMinRetransmitIntervalMs); in TEST_P()
218 hist_.PutRtpPacket(std::move(packet), fake_clock_.TimeInMilliseconds()); in TEST_P()
222 packet = hist_.GetPacketAndSetSendTime(kStartSeqNum); in TEST_P()
229 EXPECT_FALSE(hist_.GetPacketAndSetSendTime(kStartSeqNum)); in TEST_P()
233 EXPECT_TRUE(hist_.GetPacketAndSetSendTime(kStartSeqNum)); in TEST_P()
238 hist_.SetStorePacketsStatus(StorageMode::kStoreAndCull, kMaxNumPackets); in TEST_P()
250 hist_.PutRtpPacket(std::move(packet), fake_clock_.TimeInMilliseconds()); in TEST_P()
255 EXPECT_TRUE(hist_.GetPacketState(kStartSeqNum)); in TEST_P()
260 hist_.PutRtpPacket(std::move(packet), fake_clock_.TimeInMilliseconds()); in TEST_P()
263 EXPECT_FALSE(hist_.GetPacketState(kStartSeqNum)); in TEST_P()
264 EXPECT_TRUE(hist_.GetPacketState(To16u(kStartSeqNum + 1))); in TEST_P()
271 hist_.SetStorePacketsStatus(StorageMode::kStoreAndCull, in TEST_P()
279 hist_.PutRtpPacket(std::move(packet), absl::nullopt); in TEST_P()
283 EXPECT_TRUE(hist_.GetPacketState(kStartSeqNum)); in TEST_P()
288 hist_.PutRtpPacket(std::move(packet), fake_clock_.TimeInMilliseconds()); in TEST_P()
291 EXPECT_FALSE(hist_.GetPacketState(kStartSeqNum)); in TEST_P()
292 EXPECT_TRUE(hist_.GetPacketState(To16u(kStartSeqNum + 1))); in TEST_P()
304 hist_.SetStorePacketsStatus(StorageMode::kStoreAndCull, kMaxNumPackets * 2); in TEST_P()
305 hist_.SetRtt(1); in TEST_P()
312 hist_.PutRtpPacket(std::move(packet), fake_clock_.TimeInMilliseconds()); in TEST_P()
321 auto packet = hist_.GetPayloadPaddingPacket(); in TEST_P()
327 auto packet = hist_.GetPayloadPaddingPacket(); in TEST_P()
334 hist_.SetStorePacketsStatus(StorageMode::kStoreAndCull, kMaxNumPackets); in TEST_P()
339 hist_.PutRtpPacket(CreateRtpPacket(To16u(kStartSeqNum + i)), absl::nullopt); in TEST_P()
344 EXPECT_TRUE(hist_.GetPacketState(kStartSeqNum)); in TEST_P()
347 hist_.PutRtpPacket(CreateRtpPacket(To16u(kStartSeqNum + kMaxNumPackets)), in TEST_P()
349 EXPECT_TRUE(hist_.GetPacketState(kStartSeqNum)); in TEST_P()
354 EXPECT_TRUE(hist_.GetPacketAndSetSendTime(To16u(kStartSeqNum + i))); in TEST_P()
358 hist_.PutRtpPacket(CreateRtpPacket(To16u(kStartSeqNum + kMaxNumPackets + 1)), in TEST_P()
360 EXPECT_FALSE(hist_.GetPacketState(kStartSeqNum)); in TEST_P()
361 EXPECT_FALSE(hist_.GetPacketState(To16u(kStartSeqNum + 1))); in TEST_P()
362 EXPECT_TRUE(hist_.GetPacketState(To16u(kStartSeqNum + 2))); in TEST_P()
367 hist_.SetStorePacketsStatus(StorageMode::kStoreAndCull, 1); in TEST_P()
370 hist_.PutRtpPacket(CreateRtpPacket(kStartSeqNum), in TEST_P()
376 hist_.PutRtpPacket(CreateRtpPacket(To16u(kStartSeqNum + 1)), in TEST_P()
379 EXPECT_TRUE(hist_.GetPacketState(kStartSeqNum)); in TEST_P()
383 hist_.PutRtpPacket(CreateRtpPacket(To16u(kStartSeqNum + 2)), in TEST_P()
386 EXPECT_FALSE(hist_.GetPacketState(kStartSeqNum)); in TEST_P()
387 EXPECT_TRUE(hist_.GetPacketState(To16u(kStartSeqNum + 1))); in TEST_P()
396 hist_.SetStorePacketsStatus(StorageMode::kStoreAndCull, 1); in TEST_P()
397 hist_.SetRtt(kRttMs); in TEST_P()
400 hist_.PutRtpPacket(CreateRtpPacket(kStartSeqNum), in TEST_P()
405 hist_.PutRtpPacket(CreateRtpPacket(To16u(kStartSeqNum + 1)), in TEST_P()
408 EXPECT_TRUE(hist_.GetPacketState(kStartSeqNum)); in TEST_P()
412 hist_.PutRtpPacket(CreateRtpPacket(To16u(kStartSeqNum + 2)), in TEST_P()
415 EXPECT_FALSE(hist_.GetPacketState(kStartSeqNum)); in TEST_P()
416 EXPECT_TRUE(hist_.GetPacketState(To16u(kStartSeqNum + 1))); in TEST_P()
422 hist_.SetStorePacketsStatus(StorageMode::kStoreAndCull, kMaxNumPackets); in TEST_P()
424 hist_.PutRtpPacket(CreateRtpPacket(kStartSeqNum), in TEST_P()
432 EXPECT_TRUE(hist_.GetPacketState(kStartSeqNum)); in TEST_P()
436 hist_.PutRtpPacket(CreateRtpPacket(To16u(kStartSeqNum + 1)), in TEST_P()
439 EXPECT_FALSE(hist_.GetPacketState(kStartSeqNum)); in TEST_P()
446 hist_.SetStorePacketsStatus(StorageMode::kStoreAndCull, kMaxNumPackets); in TEST_P()
447 hist_.SetRtt(kRttMs); in TEST_P()
449 hist_.PutRtpPacket(CreateRtpPacket(kStartSeqNum), in TEST_P()
458 EXPECT_TRUE(hist_.GetPacketState(kStartSeqNum)); in TEST_P()
462 hist_.PutRtpPacket(CreateRtpPacket(To16u(kStartSeqNum + 1)), in TEST_P()
465 EXPECT_FALSE(hist_.GetPacketState(kStartSeqNum)); in TEST_P()
473 hist_.SetStorePacketsStatus(StorageMode::kStoreAndCull, 10); in TEST_P()
478 hist_.PutRtpPacket(std::move(packet), fake_clock_.TimeInMilliseconds()); in TEST_P()
479 hist_.GetPacketAndSetSendTime(kStartSeqNum); in TEST_P()
483 hist_.PutRtpPacket(std::move(packet), fake_clock_.TimeInMilliseconds()); in TEST_P()
484 hist_.GetPacketAndSetSendTime(To16u(kStartSeqNum + 1)); in TEST_P()
488 hist_.PutRtpPacket(std::move(packet), fake_clock_.TimeInMilliseconds()); in TEST_P()
489 hist_.GetPacketAndSetSendTime(To16u(kStartSeqNum + 2)); in TEST_P()
491 EXPECT_TRUE(hist_.GetPacketState(kStartSeqNum).has_value()); in TEST_P()
492 EXPECT_TRUE(hist_.GetPacketState(To16u(kStartSeqNum + 1)).has_value()); in TEST_P()
493 EXPECT_TRUE(hist_.GetPacketState(To16u(kStartSeqNum + 2)).has_value()); in TEST_P()
497 hist_.CullAcknowledgedPackets(acked_sequence_numbers); in TEST_P()
499 EXPECT_TRUE(hist_.GetPacketState(kStartSeqNum).has_value()); in TEST_P()
500 EXPECT_FALSE(hist_.GetPacketState(To16u(kStartSeqNum + 1)).has_value()); in TEST_P()
501 EXPECT_TRUE(hist_.GetPacketState(To16u(kStartSeqNum + 2)).has_value()); in TEST_P()
508 hist_.SetRtt(1); // Trigger culling of old packets. in TEST_P()
509 EXPECT_FALSE(hist_.GetPacketState(kStartSeqNum).has_value()); in TEST_P()
510 EXPECT_FALSE(hist_.GetPacketState(To16u(kStartSeqNum + 1)).has_value()); in TEST_P()
511 EXPECT_TRUE(hist_.GetPacketState(To16u(kStartSeqNum + 2)).has_value()); in TEST_P()
515 hist_.SetRtt(1); // Trigger culling of old packets. in TEST_P()
516 EXPECT_FALSE(hist_.GetPacketState(kStartSeqNum).has_value()); in TEST_P()
517 EXPECT_FALSE(hist_.GetPacketState(To16u(kStartSeqNum + 1)).has_value()); in TEST_P()
518 EXPECT_FALSE(hist_.GetPacketState(To16u(kStartSeqNum + 2)).has_value()); in TEST_P()
523 hist_.SetRtt(kRttMs); in TEST_P()
526 hist_.SetStorePacketsStatus(StorageMode::kStoreAndCull, 1); in TEST_P()
529 hist_.PutRtpPacket(CreateRtpPacket(kStartSeqNum), in TEST_P()
534 hist_.GetPacketState(kStartSeqNum); in TEST_P()
539 EXPECT_TRUE(hist_.GetPacketAndSetSendTime(kStartSeqNum)); in TEST_P()
540 packet_state = hist_.GetPacketState(kStartSeqNum); in TEST_P()
546 EXPECT_TRUE(hist_.SetPendingTransmission(kStartSeqNum)); in TEST_P()
547 packet_state = hist_.GetPacketState(kStartSeqNum); in TEST_P()
552 EXPECT_TRUE(hist_.GetPacketAndSetSendTime(kStartSeqNum)); in TEST_P()
554 ASSERT_FALSE(hist_.GetPacketState(kStartSeqNum).has_value()); in TEST_P()
558 packet_state = hist_.GetPacketState(kStartSeqNum); in TEST_P()
565 hist_.SetRtt(kRttMs); in TEST_P()
568 hist_.SetStorePacketsStatus(StorageMode::kStoreAndCull, 1); in TEST_P()
571 hist_.PutRtpPacket(CreateRtpPacket(kStartSeqNum), in TEST_P()
575 EXPECT_TRUE(hist_.GetPacketAndMarkAsPending(kStartSeqNum)); in TEST_P()
579 EXPECT_FALSE(hist_.GetPacketAndMarkAsPending(kStartSeqNum)); in TEST_P()
582 hist_.MarkPacketAsSent(kStartSeqNum); in TEST_P()
583 EXPECT_FALSE(hist_.GetPacketAndMarkAsPending(kStartSeqNum)); in TEST_P()
587 EXPECT_TRUE(hist_.GetPacketAndMarkAsPending(kStartSeqNum)); in TEST_P()
593 hist_.SetRtt(kRttMs); in TEST_P()
596 hist_.SetStorePacketsStatus(StorageMode::kStoreAndCull, 1); in TEST_P()
601 hist_.PutRtpPacket(std::move(packet), fake_clock_.TimeInMicroseconds()); in TEST_P()
606 hist_.GetPacketAndMarkAsPending( in TEST_P()
618 hist_.SetStorePacketsStatus(StorageMode::kStoreAndCull, 1); in TEST_P()
620 hist_.PutRtpPacket(CreateRtpPacket(kStartSeqNum), in TEST_P()
626 EXPECT_FALSE(hist_.GetPacketAndMarkAsPending( in TEST_P()
631 EXPECT_TRUE(hist_.GetPacketAndMarkAsPending(kStartSeqNum)); in TEST_P()
640 hist_.SetStorePacketsStatus(StorageMode::kStoreAndCull, 1); in TEST_P()
641 hist_.SetRtt(kRttMs); in TEST_P()
644 hist_.PutRtpPacket(CreateRtpPacket(kStartSeqNum), in TEST_P()
650 EXPECT_TRUE(hist_.SetPendingTransmission(kStartSeqNum)); in TEST_P()
656 hist_.GetPacketState(kStartSeqNum); in TEST_P()
661 EXPECT_TRUE(hist_.GetPacketAndSetSendTime(kStartSeqNum)); in TEST_P()
662 hist_.SetRtt(kRttMs); // Force culling of old packets. in TEST_P()
663 packet_state = hist_.GetPacketState(kStartSeqNum); in TEST_P()
673 hist_.SetStorePacketsStatus(StorageMode::kStoreAndCull, 1); in TEST_P()
676 hist_.PutRtpPacket(CreateRtpPacket(kStartSeqNum), in TEST_P()
680 hist_.PutRtpPacket(CreateRtpPacket(kStartSeqNum + 1), in TEST_P()
685 EXPECT_EQ(hist_.GetPayloadPaddingPacket()->SequenceNumber(), in TEST_P()
689 EXPECT_EQ(hist_.GetPayloadPaddingPacket()->SequenceNumber(), kStartSeqNum); in TEST_P()
692 EXPECT_EQ(hist_.GetPayloadPaddingPacket()->SequenceNumber(), in TEST_P()
696 EXPECT_EQ(hist_.GetPayloadPaddingPacket()->SequenceNumber(), kStartSeqNum); in TEST_P()
699 hist_.CullAcknowledgedPackets(std::vector<uint16_t>{kStartSeqNum + 1}); in TEST_P()
702 EXPECT_EQ(hist_.GetPayloadPaddingPacket()->SequenceNumber(), kStartSeqNum); in TEST_P()
704 hist_.CullAcknowledgedPackets(std::vector<uint16_t>{kStartSeqNum}); in TEST_P()
706 EXPECT_EQ(hist_.GetPayloadPaddingPacket(), nullptr); in TEST_P()
710 hist_.SetStorePacketsStatus(StorageMode::kStoreAndCull, 1); in TEST_P()
712 hist_.PutRtpPacket(CreateRtpPacket(kStartSeqNum), in TEST_P()
716 EXPECT_EQ(hist_.GetPayloadPaddingPacket()->SequenceNumber(), kStartSeqNum); in TEST_P()
719 hist_.SetPendingTransmission(kStartSeqNum); in TEST_P()
720 EXPECT_EQ(nullptr, hist_.GetPayloadPaddingPacket()); in TEST_P()
723 hist_.GetPacketAndSetSendTime(kStartSeqNum); in TEST_P()
724 EXPECT_EQ(hist_.GetPayloadPaddingPacket()->SequenceNumber(), kStartSeqNum); in TEST_P()
728 hist_.SetStorePacketsStatus(StorageMode::kStoreAndCull, 1); in TEST_P()
730 hist_.PutRtpPacket(CreateRtpPacket(kStartSeqNum), in TEST_P()
735 EXPECT_EQ(nullptr, hist_.GetPayloadPaddingPacket( in TEST_P()
740 hist_.GetPayloadPaddingPacket([&](const RtpPacketToSend& packet) { in TEST_P()
750 hist_.SetStorePacketsStatus(StorageMode::kStoreAndCull, 2); in TEST_P()
752 hist_.PutRtpPacket(CreateRtpPacket(kStartSeqNum), in TEST_P()
754 hist_.PutRtpPacket(CreateRtpPacket(kStartSeqNum + 1), in TEST_P()
757 hist_.CullAcknowledgedPackets(std::vector<uint16_t>{kStartSeqNum + 1}); in TEST_P()
759 auto packet = hist_.GetPacketAndMarkAsPending(kStartSeqNum + 1); in TEST_P()
764 hist_.SetStorePacketsStatus(StorageMode::kStoreAndCull, 10); in TEST_P()
775 hist_.PutRtpPacket(std::move(packet), fake_clock_.TimeInMilliseconds()); in TEST_P()
776 hist_.GetPacketAndSetSendTime(seq_no); in TEST_P()
785 hist_.GetPacketState(seq_no); in TEST_P()
790 hist_.CullAcknowledgedPackets(acked_sequence_numbers); in TEST_P()
802 hist_.SetStorePacketsStatus(StorageMode::kStoreAndCull, kHistorySize); in TEST_P()
804 EXPECT_EQ(hist_.GetPayloadPaddingPacket(), nullptr); in TEST_P()
807 hist_.PutRtpPacket(CreateRtpPacket(To16u(kStartSeqNum + i)), in TEST_P()
809 hist_.MarkPacketAsSent(To16u(kStartSeqNum + i)); in TEST_P()
813 EXPECT_EQ(hist_.GetPayloadPaddingPacket()->SequenceNumber(), in TEST_P()
815 EXPECT_EQ(hist_.GetPayloadPaddingPacket()->SequenceNumber(), in TEST_P()
817 EXPECT_EQ(hist_.GetPayloadPaddingPacket()->SequenceNumber(), in TEST_P()
823 hist_.CullAcknowledgedPackets( in TEST_P()
826 EXPECT_EQ(hist_.GetPayloadPaddingPacket()->SequenceNumber(), in TEST_P()
828 EXPECT_EQ(hist_.GetPayloadPaddingPacket()->SequenceNumber(), in TEST_P()
830 EXPECT_EQ(hist_.GetPayloadPaddingPacket()->SequenceNumber(), in TEST_P()
834 hist_.CullAcknowledgedPackets(std::vector<uint16_t>{kStartSeqNum}); in TEST_P()
835 EXPECT_EQ(hist_.GetPayloadPaddingPacket(), nullptr); in TEST_P()