| 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 91 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 102 | 102 |
| 103 void set_visitor(Visitor* visitor) { visitor_ = visitor; } | 103 void set_visitor(Visitor* visitor) { visitor_ = visitor; } |
| 104 | 104 |
| 105 bool headers_decompressed() const { return headers_decompressed_; } | 105 bool headers_decompressed() const { return headers_decompressed_; } |
| 106 | 106 |
| 107 const IPEndPoint& GetPeerAddress(); | 107 const IPEndPoint& GetPeerAddress(); |
| 108 | 108 |
| 109 // Gets the SSL connection information. | 109 // Gets the SSL connection information. |
| 110 bool GetSSLInfo(SSLInfo* ssl_info); | 110 bool GetSSLInfo(SSLInfo* ssl_info); |
| 111 | 111 |
| 112 // Override base class to enable flow control for data streams. | |
| 113 virtual bool IsFlowControlEnabled() const OVERRIDE; | |
| 114 | |
| 115 protected: | 112 protected: |
| 116 // Sets priority_ to priority. This should only be called before bytes are | 113 // Sets priority_ to priority. This should only be called before bytes are |
| 117 // written to the server. | 114 // written to the server. |
| 118 void set_priority(QuicPriority priority); | 115 void set_priority(QuicPriority priority); |
| 119 // This is protected because external classes should use EffectivePriority | 116 // This is protected because external classes should use EffectivePriority |
| 120 // instead. | 117 // instead. |
| 121 QuicPriority priority() const { return priority_; } | 118 QuicPriority priority() const { return priority_; } |
| 122 | 119 |
| 123 private: | 120 private: |
| 124 friend class test::QuicDataStreamPeer; | 121 friend class test::QuicDataStreamPeer; |
| (...skipping 16 matching lines...) Expand all Loading... |
| 141 bool decompression_failed_; | 138 bool decompression_failed_; |
| 142 // True if the priority has been read, false otherwise. | 139 // True if the priority has been read, false otherwise. |
| 143 bool priority_parsed_; | 140 bool priority_parsed_; |
| 144 | 141 |
| 145 DISALLOW_COPY_AND_ASSIGN(QuicDataStream); | 142 DISALLOW_COPY_AND_ASSIGN(QuicDataStream); |
| 146 }; | 143 }; |
| 147 | 144 |
| 148 } // namespace net | 145 } // namespace net |
| 149 | 146 |
| 150 #endif // NET_QUIC_QUIC_DATA_STREAM_H_ | 147 #endif // NET_QUIC_QUIC_DATA_STREAM_H_ |
| OLD | NEW |