| OLD | NEW |
| 1 // Copyright (c) 2015 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2015 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/core/quic_stream_sequencer_buffer.h" | 5 #include "net/quic/core/quic_stream_sequencer_buffer.h" |
| 6 | 6 |
| 7 #include "base/logging.h" | 7 #include "base/logging.h" |
| 8 #include "base/strings/string_number_conversions.h" | 8 #include "base/strings/string_number_conversions.h" |
| 9 #include "net/quic/core/quic_bug_tracker.h" | 9 #include "net/quic/core/quic_bug_tracker.h" |
| 10 #include "net/quic/core/quic_flags.h" | 10 #include "net/quic/core/quic_flags.h" |
| (...skipping 127 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 138 "\nCurrent gaps: " + GapsDebugString(); | 138 "\nCurrent gaps: " + GapsDebugString(); |
| 139 return QUIC_OVERLAPPING_STREAM_DATA; | 139 return QUIC_OVERLAPPING_STREAM_DATA; |
| 140 } | 140 } |
| 141 | 141 |
| 142 // Write beyond the current range this buffer is covering. | 142 // Write beyond the current range this buffer is covering. |
| 143 if (offset + size > total_bytes_read_ + max_buffer_capacity_bytes_) { | 143 if (offset + size > total_bytes_read_ + max_buffer_capacity_bytes_) { |
| 144 *error_details = "Received data beyond available range."; | 144 *error_details = "Received data beyond available range."; |
| 145 return QUIC_INTERNAL_ERROR; | 145 return QUIC_INTERNAL_ERROR; |
| 146 } | 146 } |
| 147 | 147 |
| 148 if (FLAGS_quic_limit_frame_gaps_in_buffer && | 148 if (current_gap->begin_offset != starting_offset && |
| 149 current_gap->begin_offset != starting_offset && | |
| 150 current_gap->end_offset != starting_offset + data.length() && | 149 current_gap->end_offset != starting_offset + data.length() && |
| 151 gaps_.size() >= kMaxNumGapsAllowed) { | 150 gaps_.size() >= kMaxNumGapsAllowed) { |
| 152 // This frame is going to create one more gap which exceeds max number of | 151 // This frame is going to create one more gap which exceeds max number of |
| 153 // gaps allowed. Stop processing. | 152 // gaps allowed. Stop processing. |
| 154 *error_details = "Too many gaps created for this stream."; | 153 *error_details = "Too many gaps created for this stream."; |
| 155 return QUIC_TOO_MANY_FRAME_GAPS; | 154 return QUIC_TOO_MANY_FRAME_GAPS; |
| 156 } | 155 } |
| 157 | 156 |
| 158 size_t total_written = 0; | 157 size_t total_written = 0; |
| 159 size_t source_remaining = size; | 158 size_t source_remaining = size; |
| (...skipping 375 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 535 QuicStreamOffset current_frame_begin_offset = it.first; | 534 QuicStreamOffset current_frame_begin_offset = it.first; |
| 536 QuicStreamOffset current_frame_end_offset = | 535 QuicStreamOffset current_frame_end_offset = |
| 537 it.second.length + current_frame_begin_offset; | 536 it.second.length + current_frame_begin_offset; |
| 538 current_frames_string += | 537 current_frames_string += |
| 539 RangeDebugString(current_frame_begin_offset, current_frame_end_offset); | 538 RangeDebugString(current_frame_begin_offset, current_frame_end_offset); |
| 540 } | 539 } |
| 541 return current_frames_string; | 540 return current_frames_string; |
| 542 } | 541 } |
| 543 | 542 |
| 544 } // namespace net | 543 } // namespace net |
| OLD | NEW |