| 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 // The base class for client/server reliable streams. | 5 // The base class for client/server reliable streams. |
| 6 | 6 |
| 7 #ifndef NET_QUIC_RELIABLE_QUIC_STREAM_H_ | 7 #ifndef NET_QUIC_RELIABLE_QUIC_STREAM_H_ |
| 8 #define NET_QUIC_RELIABLE_QUIC_STREAM_H_ | 8 #define NET_QUIC_RELIABLE_QUIC_STREAM_H_ |
| 9 | 9 |
| 10 #include <sys/types.h> | 10 #include <sys/types.h> |
| (...skipping 68 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 79 | 79 |
| 80 QuicRstStreamErrorCode stream_error() const { return stream_error_; } | 80 QuicRstStreamErrorCode stream_error() const { return stream_error_; } |
| 81 QuicErrorCode connection_error() const { return connection_error_; } | 81 QuicErrorCode connection_error() const { return connection_error_; } |
| 82 | 82 |
| 83 bool read_side_closed() const { return read_side_closed_; } | 83 bool read_side_closed() const { return read_side_closed_; } |
| 84 bool write_side_closed() const { return write_side_closed_; } | 84 bool write_side_closed() const { return write_side_closed_; } |
| 85 | 85 |
| 86 uint64 stream_bytes_read() { return stream_bytes_read_; } | 86 uint64 stream_bytes_read() { return stream_bytes_read_; } |
| 87 uint64 stream_bytes_written() { return stream_bytes_written_; } | 87 uint64 stream_bytes_written() { return stream_bytes_written_; } |
| 88 | 88 |
| 89 QuicVersion version(); |
| 90 |
| 89 protected: | 91 protected: |
| 90 // Sends as much of 'data' to the connection as the connection will consume, | 92 // Sends as much of 'data' to the connection as the connection will consume, |
| 91 // and then buffers any remaining data in queued_data_. | 93 // and then buffers any remaining data in queued_data_. |
| 92 void WriteOrBufferData(base::StringPiece data, bool fin); | 94 void WriteOrBufferData(base::StringPiece data, bool fin); |
| 93 | 95 |
| 94 // Sends as many bytes in the first |count| buffers of |iov| to the connection | 96 // Sends as many bytes in the first |count| buffers of |iov| to the connection |
| 95 // as the connection will consume. | 97 // as the connection will consume. |
| 96 // If |ack_notifier_delegate| is provided, then it will be notified once all | 98 // If |ack_notifier_delegate| is provided, then it will be notified once all |
| 97 // the ACKs for this write have been received. | 99 // the ACKs for this write have been received. |
| 98 // Returns the number of bytes consumed by the connection. | 100 // Returns the number of bytes consumed by the connection. |
| (...skipping 50 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 149 | 151 |
| 150 // True if the session this stream is running under is a server session. | 152 // True if the session this stream is running under is a server session. |
| 151 bool is_server_; | 153 bool is_server_; |
| 152 | 154 |
| 153 DISALLOW_COPY_AND_ASSIGN(ReliableQuicStream); | 155 DISALLOW_COPY_AND_ASSIGN(ReliableQuicStream); |
| 154 }; | 156 }; |
| 155 | 157 |
| 156 } // namespace net | 158 } // namespace net |
| 157 | 159 |
| 158 #endif // NET_QUIC_RELIABLE_QUIC_STREAM_H_ | 160 #endif // NET_QUIC_RELIABLE_QUIC_STREAM_H_ |
| OLD | NEW |