Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(285)

Side by Side Diff: net/quic/quic_fec_group.cc

Issue 15937012: Land Recent QUIC changes. (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Small bug fixes Created 7 years, 6 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
OLDNEW
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be 2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file. 3 // found in the LICENSE file.
4 4
5 #include "net/quic/quic_fec_group.h" 5 #include "net/quic/quic_fec_group.h"
6 6
7 #include <limits> 7 #include <limits>
8 8
9 #include "base/logging.h" 9 #include "base/logging.h"
10 10
(...skipping 31 matching lines...) Expand 10 before | Expand all | Expand 10 after
42 } 42 }
43 if (!UpdateParity(decrypted_payload, header.entropy_flag)) { 43 if (!UpdateParity(decrypted_payload, header.entropy_flag)) {
44 return false; 44 return false;
45 } 45 }
46 received_packets_.insert(header.packet_sequence_number); 46 received_packets_.insert(header.packet_sequence_number);
47 return true; 47 return true;
48 } 48 }
49 49
50 bool QuicFecGroup::UpdateFec( 50 bool QuicFecGroup::UpdateFec(
51 QuicPacketSequenceNumber fec_packet_sequence_number, 51 QuicPacketSequenceNumber fec_packet_sequence_number,
52 bool fec_entropy_flag, 52 bool fec_packet_entropy,
53 const QuicFecData& fec) { 53 const QuicFecData& fec) {
54 if (min_protected_packet_ != kNoSequenceNumber) { 54 if (min_protected_packet_ != kNoSequenceNumber) {
55 return false; 55 return false;
56 } 56 }
57 SequenceNumberSet::const_iterator it = received_packets_.begin(); 57 SequenceNumberSet::const_iterator it = received_packets_.begin();
58 while (it != received_packets_.end()) { 58 while (it != received_packets_.end()) {
59 if ((*it < fec.fec_group) || 59 if ((*it < fec.fec_group) ||
60 (*it >= fec_packet_sequence_number)) { 60 (*it >= fec_packet_sequence_number)) {
61 DLOG(ERROR) << "FEC group does not cover received packet: " << *it; 61 DLOG(ERROR) << "FEC group does not cover received packet: " << *it;
62 return false; 62 return false;
63 } 63 }
64 ++it; 64 ++it;
65 } 65 }
66 if (!UpdateParity(fec.redundancy, fec_entropy_flag)) { 66 if (!UpdateParity(fec.redundancy, fec_packet_entropy)) {
67 return false; 67 return false;
68 } 68 }
69 min_protected_packet_ = fec.fec_group; 69 min_protected_packet_ = fec.fec_group;
70 max_protected_packet_ = fec_packet_sequence_number - 1; 70 max_protected_packet_ = fec_packet_sequence_number - 1;
71 return true; 71 return true;
72 } 72 }
73 73
74 bool QuicFecGroup::CanRevive() const { 74 bool QuicFecGroup::CanRevive() const {
75 // We can revive if we're missing exactly 1 packet. 75 // We can revive if we're missing exactly 1 packet.
76 return NumMissingPackets() == 1; 76 return NumMissingPackets() == 1;
(...skipping 80 matching lines...) Expand 10 before | Expand all | Expand 10 after
157 } 157 }
158 158
159 size_t QuicFecGroup::NumMissingPackets() const { 159 size_t QuicFecGroup::NumMissingPackets() const {
160 if (min_protected_packet_ == kNoSequenceNumber) 160 if (min_protected_packet_ == kNoSequenceNumber)
161 return numeric_limits<size_t>::max(); 161 return numeric_limits<size_t>::max();
162 return (max_protected_packet_ - min_protected_packet_ + 1) - 162 return (max_protected_packet_ - min_protected_packet_ + 1) -
163 received_packets_.size(); 163 received_packets_.size();
164 } 164 }
165 165
166 } // namespace net 166 } // namespace net
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698