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 10 matching lines...) Expand all Loading... |
21 namespace net { | 21 namespace net { |
22 | 22 |
23 namespace test { | 23 namespace test { |
24 class ReliableQuicStreamPeer; | 24 class ReliableQuicStreamPeer; |
25 } // namespace test | 25 } // namespace test |
26 | 26 |
27 class IPEndPoint; | 27 class IPEndPoint; |
28 class QuicSession; | 28 class QuicSession; |
29 class SSLInfo; | 29 class SSLInfo; |
30 | 30 |
| 31 #define ENDPOINT (is_server_ ? "Server: " : " Client: ") |
| 32 |
31 // All this does right now is send data to subclasses via the sequencer. | 33 // All this does right now is send data to subclasses via the sequencer. |
32 class NET_EXPORT_PRIVATE ReliableQuicStream : public | 34 class NET_EXPORT_PRIVATE ReliableQuicStream : public |
33 QuicSpdyDecompressor::Visitor { | 35 QuicSpdyDecompressor::Visitor { |
34 public: | 36 public: |
35 // Visitor receives callbacks from the stream. | 37 // Visitor receives callbacks from the stream. |
36 class Visitor { | 38 class Visitor { |
37 public: | 39 public: |
38 Visitor() {} | 40 Visitor() {} |
39 | 41 |
40 // Called when the stream is closed. | 42 // Called when the stream is closed. |
(...skipping 176 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
217 | 219 |
218 // True if the read side is closed and further frames should be rejected. | 220 // True if the read side is closed and further frames should be rejected. |
219 bool read_side_closed_; | 221 bool read_side_closed_; |
220 // True if the write side is closed, and further writes should fail. | 222 // True if the write side is closed, and further writes should fail. |
221 bool write_side_closed_; | 223 bool write_side_closed_; |
222 | 224 |
223 // True if the priority has been read, false otherwise. | 225 // True if the priority has been read, false otherwise. |
224 bool priority_parsed_; | 226 bool priority_parsed_; |
225 bool fin_buffered_; | 227 bool fin_buffered_; |
226 bool fin_sent_; | 228 bool fin_sent_; |
| 229 |
| 230 // True if the session this stream is running under is a server session. |
| 231 bool is_server_; |
227 }; | 232 }; |
228 | 233 |
229 } // namespace net | 234 } // namespace net |
230 | 235 |
231 #endif // NET_QUIC_RELIABLE_QUIC_STREAM_H_ | 236 #endif // NET_QUIC_RELIABLE_QUIC_STREAM_H_ |
OLD | NEW |