| OLD | NEW |
| 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 #ifndef NET_QUIC_QUIC_STREAM_SEQUENCER_H_ | 5 #ifndef NET_QUIC_QUIC_STREAM_SEQUENCER_H_ |
| 6 #define NET_QUIC_QUIC_STREAM_SEQUENCER_H_ | 6 #define NET_QUIC_QUIC_STREAM_SEQUENCER_H_ |
| 7 | 7 |
| 8 #include <stddef.h> | 8 #include <stddef.h> |
| 9 | 9 |
| 10 #include <map> | 10 #include <map> |
| (...skipping 76 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 87 | 87 |
| 88 // Number of bytes has been consumed. | 88 // Number of bytes has been consumed. |
| 89 QuicStreamOffset NumBytesConsumed() const; | 89 QuicStreamOffset NumBytesConsumed() const; |
| 90 | 90 |
| 91 int num_frames_received() const { return num_frames_received_; } | 91 int num_frames_received() const { return num_frames_received_; } |
| 92 | 92 |
| 93 int num_duplicate_frames_received() const { | 93 int num_duplicate_frames_received() const { |
| 94 return num_duplicate_frames_received_; | 94 return num_duplicate_frames_received_; |
| 95 } | 95 } |
| 96 | 96 |
| 97 int num_early_frames_received() const { return num_early_frames_received_; } | |
| 98 | |
| 99 bool ignore_read_data() const { return ignore_read_data_; } | 97 bool ignore_read_data() const { return ignore_read_data_; } |
| 100 | 98 |
| 101 // Returns std::string describing internal state. | 99 // Returns std::string describing internal state. |
| 102 const std::string DebugString() const; | 100 const std::string DebugString() const; |
| 103 | 101 |
| 104 private: | 102 private: |
| 105 friend class test::QuicStreamSequencerPeer; | 103 friend class test::QuicStreamSequencerPeer; |
| 106 | 104 |
| 107 // Deletes and records as consumed any buffered data that is now in-sequence. | 105 // Deletes and records as consumed any buffered data that is now in-sequence. |
| 108 // (To be called only after StopReading has been called.) | 106 // (To be called only after StopReading has been called.) |
| (...skipping 19 matching lines...) Expand all Loading... |
| 128 // If true, the sequencer is blocked from passing data to the stream and will | 126 // If true, the sequencer is blocked from passing data to the stream and will |
| 129 // buffer all new incoming data until FlushBufferedFrames is called. | 127 // buffer all new incoming data until FlushBufferedFrames is called. |
| 130 bool blocked_; | 128 bool blocked_; |
| 131 | 129 |
| 132 // Count of the number of frames received. | 130 // Count of the number of frames received. |
| 133 int num_frames_received_; | 131 int num_frames_received_; |
| 134 | 132 |
| 135 // Count of the number of duplicate frames received. | 133 // Count of the number of duplicate frames received. |
| 136 int num_duplicate_frames_received_; | 134 int num_duplicate_frames_received_; |
| 137 | 135 |
| 138 // Count of the number of frames received before all previous frames were | |
| 139 // received. | |
| 140 int num_early_frames_received_; | |
| 141 | |
| 142 // Not owned. | 136 // Not owned. |
| 143 const QuicClock* clock_; | 137 const QuicClock* clock_; |
| 144 | 138 |
| 145 // If true, all incoming data will be discarded. | 139 // If true, all incoming data will be discarded. |
| 146 bool ignore_read_data_; | 140 bool ignore_read_data_; |
| 147 | 141 |
| 148 DISALLOW_COPY_AND_ASSIGN(QuicStreamSequencer); | 142 DISALLOW_COPY_AND_ASSIGN(QuicStreamSequencer); |
| 149 }; | 143 }; |
| 150 | 144 |
| 151 } // namespace net | 145 } // namespace net |
| 152 | 146 |
| 153 #endif // NET_QUIC_QUIC_STREAM_SEQUENCER_H_ | 147 #endif // NET_QUIC_QUIC_STREAM_SEQUENCER_H_ |
| OLD | NEW |