Home
last modified time | relevance | path

Searched refs:missing_packets (Results 1 – 25 of 27) sorted by relevance

12

/external/chromium_org/net/quic/
Dquic_sent_entropy_manager_test.cc48 SequenceNumberSet missing_packets; in TEST_F() local
49 missing_packets.insert(1); in TEST_F()
50 missing_packets.insert(4); in TEST_F()
51 missing_packets.insert(7); in TEST_F()
52 missing_packets.insert(8); in TEST_F()
56 if (missing_packets.find(i + 1) == missing_packets.end()) { in TEST_F()
61 EXPECT_TRUE(entropy_manager_.IsValidEntropy(10, missing_packets, in TEST_F()
77 SequenceNumberSet missing_packets; in TEST_F() local
78 missing_packets.insert(7); in TEST_F()
79 missing_packets.insert(8); in TEST_F()
[all …]
Dquic_received_packet_manager.cc163 ack_frame_.missing_packets.erase(sequence_number); in RecordPacketReceived()
199 return ContainsKey(ack_frame_.missing_packets, sequence_number); in IsMissing()
263 size_t missing_packets_count = ack_frame_.missing_packets.size(); in DontWaitForPacketsBefore()
264 ack_frame_.missing_packets.erase( in DontWaitForPacketsBefore()
265 ack_frame_.missing_packets.begin(), in DontWaitForPacketsBefore()
266 ack_frame_.missing_packets.lower_bound(least_unacked)); in DontWaitForPacketsBefore()
267 return missing_packets_count != ack_frame_.missing_packets.size(); in DontWaitForPacketsBefore()
285 DCHECK(ack_frame_.missing_packets.empty() || in UpdatePacketInformationSentByPeer()
286 *ack_frame_.missing_packets.begin() >= in UpdatePacketInformationSentByPeer()
291 return !ack_frame_.missing_packets.empty() && in HasNewMissingPackets()
[all …]
Dquic_sent_entropy_manager.cc69 const SequenceNumberSet& missing_packets, in IsValidEntropy() argument
76 if (!missing_packets.empty() && in IsValidEntropy()
77 *missing_packets.begin() < GetSmallestPacketWithEntropy()) { in IsValidEntropy()
85 for (SequenceNumberSet::const_iterator it = missing_packets.begin(); in IsValidEntropy()
86 it != missing_packets.end(); ++it) { in IsValidEntropy()
Dquic_connection_logger.cc117 const SequenceNumberSet& missing_packets = frame->missing_packets; in NetLogQuicAckFrameCallback() local
118 for (SequenceNumberSet::const_iterator it = missing_packets.begin(); in NetLogQuicAckFrameCallback()
119 it != missing_packets.end(); ++it) { in NetLogQuicAckFrameCallback()
399 const SequenceNumberSet& missing_packets = in OnFrameAddedToPacket() local
400 frame.ack_frame->missing_packets; in OnFrameAddedToPacket()
404 if (missing_packets.size() < max_ranges || in OnFrameAddedToPacket()
405 (*missing_packets.rbegin() - *missing_packets.begin() - in OnFrameAddedToPacket()
406 missing_packets.size() + 1) < max_ranges) { in OnFrameAddedToPacket()
411 for (SequenceNumberSet::const_iterator it = missing_packets.begin(); in OnFrameAddedToPacket()
412 it != missing_packets.end(); ++it) { in OnFrameAddedToPacket()
[all …]
Dquic_protocol_test.cc43 ack_frame.missing_packets.insert(10); in TEST()
50 EXPECT_EQ(6u, ack_frame.missing_packets.size()); in TEST()
53 for (SequenceNumberSet::iterator it = ack_frame.missing_packets.begin(); in TEST()
54 it != ack_frame.missing_packets.end(); ++it, ++i) { in TEST()
Dquic_sent_packet_manager_test.cc314 ack_frame.missing_packets.insert(1); in TEST_F()
414 ack_frame.missing_packets.insert(2); in TEST_F()
495 ack_frame.missing_packets.insert(2); in TEST_F()
523 ack_frame.missing_packets.insert(1); in TEST_F()
555 ack_frame.missing_packets.insert(1); in TEST_F()
588 ack_frame.missing_packets.insert(1); in TEST_F()
589 ack_frame.missing_packets.insert(2); in TEST_F()
590 ack_frame.missing_packets.insert(3); in TEST_F()
591 ack_frame.missing_packets.insert(4); in TEST_F()
620 ack_frame.missing_packets.insert(1); in TEST_F()
[all …]
Dquic_connection_logger_unittest.cc34 frame.missing_packets.insert(i); in TEST_F()
43 frame.missing_packets.insert(i); in TEST_F()
Dquic_framer_test.cc1733 ASSERT_EQ(1u, frame.missing_packets.size()); in TEST_P()
1735 frame.missing_packets.begin(); in TEST_P()
1838 ASSERT_EQ(1u, frame.missing_packets.size()); in TEST_P()
1841 frame.missing_packets.begin(); in TEST_P()
1961 ASSERT_EQ(1u, frame.missing_packets.size()); in TEST_P()
1964 frame.missing_packets.begin(); in TEST_P()
2070 ASSERT_EQ(1u, frame.missing_packets.size()); in TEST_P()
2072 frame.missing_packets.begin(); in TEST_P()
2175 ASSERT_EQ(1u, frame.missing_packets.size()); in TEST_P()
2177 frame.missing_packets.begin(); in TEST_P()
[all …]
Dquic_received_packet_manager_test.cc344 EXPECT_EQ(1u, ack.missing_packets.size()); in TEST_F()
345 EXPECT_EQ(2u, *ack.missing_packets.begin()); in TEST_F()
347 EXPECT_EQ(2u, *ack.missing_packets.begin()); in TEST_F()
358 EXPECT_TRUE(ack.missing_packets.empty()); in TEST_F()
Dquic_sent_entropy_manager.h45 const SequenceNumberSet& missing_packets,
Dquic_connection.cc653 if (!incoming_ack.missing_packets.empty() && in ValidateAckFrame()
654 *incoming_ack.missing_packets.rbegin() > incoming_ack.largest_observed) { in ValidateAckFrame()
656 << *incoming_ack.missing_packets.rbegin() in ValidateAckFrame()
662 if (!incoming_ack.missing_packets.empty() && in ValidateAckFrame()
663 *incoming_ack.missing_packets.begin() < in ValidateAckFrame()
666 << *incoming_ack.missing_packets.begin() in ValidateAckFrame()
674 incoming_ack.missing_packets, in ValidateAckFrame()
683 if (!ContainsKey(incoming_ack.missing_packets, *iter)) { in ValidateAckFrame()
956 if (!last_ack_frames_.back().missing_packets.empty() && in UpdateStopWaitingCount()
957 GetLeastUnacked() > *last_ack_frames_.back().missing_packets.begin()) { in UpdateStopWaitingCount()
Dquic_protocol.cc247 ContainsKey(ack_frame.missing_packets, sequence_number); in IsAwaitingPacket()
254 ack_frame->missing_packets.insert(i); in InsertMissingPacketsBetween()
385 for (SequenceNumberSet::const_iterator it = ack_frame.missing_packets.begin(); in operator <<()
386 it != ack_frame.missing_packets.end(); ++it) { in operator <<()
Dquic_sent_packet_manager.cc240 if (ack_frame.missing_packets.empty()) { in UpdatePacketInformationReceivedByPeer()
243 least_packet_awaited_by_peer_ = *(ack_frame.missing_packets.begin()); in UpdatePacketInformationReceivedByPeer()
275 if (ContainsKey(ack_frame.missing_packets, sequence_number)) { in HandleAckForSentPackets()
Dquic_framer.cc985 if (!frame.missing_packets.empty()) { in GetAckFrameInfo()
986 DCHECK_GE(frame.largest_observed, *frame.missing_packets.rbegin()); in GetAckFrameInfo()
988 SequenceNumberSet::const_iterator iter = frame.missing_packets.begin(); in GetAckFrameInfo()
991 for (; iter != frame.missing_packets.end(); ++iter) { in GetAckFrameInfo()
1386 ack_frame->missing_packets.insert(last_sequence_number - i); in ProcessAckFrame()
2124 LOG_IF(DFATAL, !ContainsKey(frame.missing_packets, *iter)); in AppendAckFrameAndTypeByte()
Dquic_connection_test.cc959 frame->missing_packets.insert(missing); in NackPacket()
966 EXPECT_THAT(frame->missing_packets, Contains(arrived)); in AckPacket()
967 frame->missing_packets.erase(arrived); in AckPacket()
1038 EXPECT_EQ(0u, outgoing_ack()->missing_packets.size()); in TEST_P()
1042 EXPECT_EQ(0u, outgoing_ack()->missing_packets.size()); in TEST_P()
1046 EXPECT_EQ(0u, outgoing_ack()->missing_packets.size()); in TEST_P()
3147 EXPECT_TRUE(outgoing_ack()->missing_packets.empty()); in TEST_P()
/external/chromium_org/media/cast/net/rtcp/
Drtcp_builder_unittest.cc113 PacketIdSet missing_packets; in TEST_F() local
114 cast_message.missing_frames_and_packets[kLostFrameId] = missing_packets; in TEST_F()
116 missing_packets.insert(kLostPacketId1); in TEST_F()
117 missing_packets.insert(kLostPacketId2); in TEST_F()
118 missing_packets.insert(kLostPacketId3); in TEST_F()
120 missing_packets; in TEST_F()
147 PacketIdSet missing_packets; in TEST_F() local
148 cast_message.missing_frames_and_packets[kLostFrameId] = missing_packets; in TEST_F()
150 missing_packets.insert(kLostPacketId1); in TEST_F()
151 missing_packets.insert(kLostPacketId2); in TEST_F()
[all …]
/external/chromium_org/media/cast/net/
Dcast_transport_sender_impl_unittest.cc200 MissingFramesAndPacketsMap missing_packets; in TEST_F() local
201 missing_packets[1].insert(0); in TEST_F()
202 missing_packets[1].insert(1); in TEST_F()
203 missing_packets[1].insert(2); in TEST_F()
209 kVideoSsrc, missing_packets, true, dedup_info); in TEST_F()
245 MissingFramesAndPacketsMap missing_packets; in TEST_F() local
246 missing_packets[1].insert(kRtcpCastAllPacketsLost); in TEST_F()
252 kVideoSsrc, missing_packets, true, dedup_info); in TEST_F()
286 MissingFramesAndPacketsMap missing_packets; in TEST_F() local
287 missing_packets[1].insert(0); in TEST_F()
[all …]
Dcast_transport_sender_impl.cc276 const MissingFramesAndPacketsMap& missing_packets, in ResendPackets() argument
280 audio_sender_->ResendPackets(missing_packets, in ResendPackets()
284 video_sender_->ResendPackets(missing_packets, in ResendPackets()
Dcast_transport_sender_impl.h113 const MissingFramesAndPacketsMap& missing_packets,
/external/chromium_org/media/cast/net/rtp/
Dframe_buffer.cc93 PacketIdSet* missing_packets) const { in GetMissingPackets()
103 missing_packets->insert(packet); in GetMissingPackets()
109 missing_packets->insert(packet); in GetMissingPackets()
Dframe_buffer.h28 void GetMissingPackets(bool newest_frame, PacketIdSet* missing_packets) const;
Drtp_sender.h47 void ResendPackets(const MissingFramesAndPacketsMap& missing_packets,
Dframer.h77 PacketIdSet* missing_packets) const;
Dframer.cc254 PacketIdSet* missing_packets) const { in GetMissingPackets()
259 it->second->GetMissingPackets(last_frame, missing_packets); in GetMissingPackets()
/external/chromium_org/net/tools/quic/test_tools/
Dquic_test_utils.cc92 ack.missing_packets.insert(least_unacked + i); in MakeAckFrameWithNackRanges()

12