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 |