| OLD | NEW |
| 1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 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 // The base class for streams which deliver data to/from an application. | 5 // The base class for streams which deliver data to/from an application. |
| 6 // In each direction, the data on such a stream first contains compressed | 6 // In each direction, the data on such a stream first contains compressed |
| 7 // headers then body data. | 7 // headers then body data. |
| 8 | 8 |
| 9 #ifndef NET_QUIC_QUIC_DATA_STREAM_H_ | 9 #ifndef NET_QUIC_QUIC_DATA_STREAM_H_ |
| 10 #define NET_QUIC_QUIC_DATA_STREAM_H_ | 10 #define NET_QUIC_QUIC_DATA_STREAM_H_ |
| (...skipping 41 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 52 DISALLOW_COPY_AND_ASSIGN(Visitor); | 52 DISALLOW_COPY_AND_ASSIGN(Visitor); |
| 53 }; | 53 }; |
| 54 | 54 |
| 55 QuicDataStream(QuicStreamId id, QuicSession* session); | 55 QuicDataStream(QuicStreamId id, QuicSession* session); |
| 56 | 56 |
| 57 ~QuicDataStream() override; | 57 ~QuicDataStream() override; |
| 58 | 58 |
| 59 // ReliableQuicStream implementation | 59 // ReliableQuicStream implementation |
| 60 void OnClose() override; | 60 void OnClose() override; |
| 61 uint32 ProcessRawData(const char* data, uint32 data_len) override; | 61 uint32 ProcessRawData(const char* data, uint32 data_len) override; |
| 62 |
| 62 // By default, this is the same as priority(), however it allows streams | 63 // By default, this is the same as priority(), however it allows streams |
| 63 // to temporarily alter effective priority. For example if a SPDY stream has | 64 // to temporarily alter effective priority. For example if a SPDY stream has |
| 64 // compressed but not written headers it can write the headers with a higher | 65 // compressed but not written headers it can write the headers with a higher |
| 65 // priority. | 66 // priority. |
| 66 QuicPriority EffectivePriority() const override; | 67 QuicPriority EffectivePriority() const override; |
| 67 | 68 |
| 68 // Overridden by subclasses to process data. The headers will be delivered | 69 // Overridden by subclasses to process data. The headers will be delivered |
| 69 // via OnStreamHeaders, so only data will be delivered through this method. | 70 // via OnStreamHeaders, so only data will be delivered through this method. |
| 70 virtual uint32 ProcessData(const char* data, uint32 data_len) = 0; | 71 virtual uint32 ProcessData(const char* data, uint32 data_len) = 0; |
| 71 | 72 |
| (...skipping 57 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 129 // Contains a copy of the decompressed headers until they are consumed | 130 // Contains a copy of the decompressed headers until they are consumed |
| 130 // via ProcessData or Readv. | 131 // via ProcessData or Readv. |
| 131 std::string decompressed_headers_; | 132 std::string decompressed_headers_; |
| 132 | 133 |
| 133 DISALLOW_COPY_AND_ASSIGN(QuicDataStream); | 134 DISALLOW_COPY_AND_ASSIGN(QuicDataStream); |
| 134 }; | 135 }; |
| 135 | 136 |
| 136 } // namespace net | 137 } // namespace net |
| 137 | 138 |
| 138 #endif // NET_QUIC_QUIC_DATA_STREAM_H_ | 139 #endif // NET_QUIC_QUIC_DATA_STREAM_H_ |
| OLD | NEW |