| 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/quic_stream_sequencer_buffer.h" | 5 #include "net/quic/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/quic_bug_tracker.h" | 9 #include "net/quic/quic_bug_tracker.h" |
| 10 | 10 |
| (...skipping 88 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 99 offset + size <= current_gap->begin_offset) { | 99 offset + size <= current_gap->begin_offset) { |
| 100 DVLOG(1) << "Duplicated data at offset: " << offset << " length: " << size; | 100 DVLOG(1) << "Duplicated data at offset: " << offset << " length: " << size; |
| 101 return QUIC_NO_ERROR; | 101 return QUIC_NO_ERROR; |
| 102 } | 102 } |
| 103 if (offset < current_gap->begin_offset && | 103 if (offset < current_gap->begin_offset && |
| 104 offset + size > current_gap->begin_offset) { | 104 offset + size > current_gap->begin_offset) { |
| 105 // Beginning of new data overlaps data before current gap. | 105 // Beginning of new data overlaps data before current gap. |
| 106 *error_details = | 106 *error_details = |
| 107 string("Beginning of received data overlaps with buffered data.\n") + | 107 string("Beginning of received data overlaps with buffered data.\n") + |
| 108 "New frame range " + RangeDebugString(offset, offset + size) + | 108 "New frame range " + RangeDebugString(offset, offset + size) + |
| 109 "\n" | 109 " with first 128 bytes: " + |
| 110 "Currently received frames: " + | 110 string(data.data(), data.length() < 128 ? data.length() : 128) + |
| 111 ReceivedFramesDebugString() + | 111 "\nCurrently received frames: " + ReceivedFramesDebugString() + |
| 112 "\n" | 112 "\nCurrent gaps: " + GapsDebugString(); |
| 113 "Current gaps: " + | |
| 114 GapsDebugString() + "\n"; | |
| 115 return QUIC_OVERLAPPING_STREAM_DATA; | 113 return QUIC_OVERLAPPING_STREAM_DATA; |
| 116 } | 114 } |
| 117 if (offset + size > current_gap->end_offset) { | 115 if (offset + size > current_gap->end_offset) { |
| 118 // End of new data overlaps with data after current gap. | 116 // End of new data overlaps with data after current gap. |
| 119 *error_details = | 117 *error_details = |
| 120 "End of received data overlaps with buffered data.\n" | 118 string("End of received data overlaps with buffered data.\n") + |
| 121 "New frame range " + | 119 "New frame range " + RangeDebugString(offset, offset + size) + |
| 122 RangeDebugString(offset, offset + size) + | 120 " with first 128 bytes: " + |
| 123 "\n" | 121 string(data.data(), data.length() < 128 ? data.length() : 128) + |
| 124 "Currently received frames: " + | 122 "\nCurrently received frames: " + ReceivedFramesDebugString() + |
| 125 ReceivedFramesDebugString() + | 123 "\nCurrent gaps: " + GapsDebugString(); |
| 126 "\n" | |
| 127 "Current gaps: " + | |
| 128 GapsDebugString() + "\n"; | |
| 129 return QUIC_OVERLAPPING_STREAM_DATA; | 124 return QUIC_OVERLAPPING_STREAM_DATA; |
| 130 } | 125 } |
| 131 | 126 |
| 132 // Write beyond the current range this buffer is covering. | 127 // Write beyond the current range this buffer is covering. |
| 133 if (offset + size > total_bytes_read_ + max_buffer_capacity_bytes_) { | 128 if (offset + size > total_bytes_read_ + max_buffer_capacity_bytes_) { |
| 134 *error_details = "Received data beyond available range."; | 129 *error_details = "Received data beyond available range."; |
| 135 return QUIC_INTERNAL_ERROR; | 130 return QUIC_INTERNAL_ERROR; |
| 136 } | 131 } |
| 137 | 132 |
| 138 size_t total_written = 0; | 133 size_t total_written = 0; |
| (...skipping 362 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 501 QuicStreamOffset current_frame_begin_offset = it.first; | 496 QuicStreamOffset current_frame_begin_offset = it.first; |
| 502 QuicStreamOffset current_frame_end_offset = | 497 QuicStreamOffset current_frame_end_offset = |
| 503 it.second.length + current_frame_begin_offset; | 498 it.second.length + current_frame_begin_offset; |
| 504 current_frames_string += | 499 current_frames_string += |
| 505 RangeDebugString(current_frame_begin_offset, current_frame_end_offset); | 500 RangeDebugString(current_frame_begin_offset, current_frame_end_offset); |
| 506 } | 501 } |
| 507 return current_frames_string; | 502 return current_frames_string; |
| 508 } | 503 } |
| 509 | 504 |
| 510 } // namespace net | 505 } // namespace net |
| OLD | NEW |