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_SPDY_STREAM_H_ | 9 #ifndef NET_QUIC_QUIC_SPDY_STREAM_H_ |
10 #define NET_QUIC_QUIC_SPDY_STREAM_H_ | 10 #define NET_QUIC_QUIC_SPDY_STREAM_H_ |
(...skipping 192 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
203 const QuicHeaderList& header_list); | 203 const QuicHeaderList& header_list); |
204 virtual void OnTrailingHeadersComplete(bool fin, | 204 virtual void OnTrailingHeadersComplete(bool fin, |
205 size_t frame_len, | 205 size_t frame_len, |
206 const QuicHeaderList& header_list); | 206 const QuicHeaderList& header_list); |
207 QuicSpdySession* spdy_session() const { return spdy_session_; } | 207 QuicSpdySession* spdy_session() const { return spdy_session_; } |
208 Visitor* visitor() { return visitor_; } | 208 Visitor* visitor() { return visitor_; } |
209 | 209 |
210 // Returns true if headers have been fully read and consumed. | 210 // Returns true if headers have been fully read and consumed. |
211 bool FinishedReadingHeaders() const; | 211 bool FinishedReadingHeaders() const; |
212 | 212 |
| 213 // Redirects to the headers stream if force HOL blocking enabled, |
| 214 // otherwise just pass through. |
| 215 QuicConsumedData WritevDataInner( |
| 216 QuicIOVector iov, |
| 217 QuicStreamOffset offset, |
| 218 bool fin, |
| 219 QuicAckListenerInterface* ack_notifier_delegate) override; |
| 220 |
213 private: | 221 private: |
214 friend class test::QuicSpdyStreamPeer; | 222 friend class test::QuicSpdyStreamPeer; |
215 friend class test::ReliableQuicStreamPeer; | 223 friend class test::ReliableQuicStreamPeer; |
216 friend class QuicStreamUtils; | 224 friend class QuicStreamUtils; |
217 | 225 |
218 // Returns true if trailers have been fully read and consumed. | 226 // Returns true if trailers have been fully read and consumed. |
219 bool FinishedReadingTrailers() const; | 227 bool FinishedReadingTrailers() const; |
220 | 228 |
221 QuicSpdySession* spdy_session_; | 229 QuicSpdySession* spdy_session_; |
222 | 230 |
(...skipping 18 matching lines...) Expand all Loading... |
241 std::string decompressed_trailers_; | 249 std::string decompressed_trailers_; |
242 // The parsed trailers received from the peer. | 250 // The parsed trailers received from the peer. |
243 SpdyHeaderBlock received_trailers_; | 251 SpdyHeaderBlock received_trailers_; |
244 | 252 |
245 DISALLOW_COPY_AND_ASSIGN(QuicSpdyStream); | 253 DISALLOW_COPY_AND_ASSIGN(QuicSpdyStream); |
246 }; | 254 }; |
247 | 255 |
248 } // namespace net | 256 } // namespace net |
249 | 257 |
250 #endif // NET_QUIC_QUIC_SPDY_STREAM_H_ | 258 #endif // NET_QUIC_QUIC_SPDY_STREAM_H_ |
OLD | NEW |