reliable_quic_stream.h revision 46d4c2bc3267f3f028f39e7e311b0f89aba2e4fd
15821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// Copyright (c) 2012 The Chromium Authors. All rights reserved. 25821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// Use of this source code is governed by a BSD-style license that can be 35821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// found in the LICENSE file. 45821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// 55821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// The base class for client/server reliable streams. 65821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 75821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#ifndef NET_QUIC_RELIABLE_QUIC_STREAM_H_ 85821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#define NET_QUIC_RELIABLE_QUIC_STREAM_H_ 95821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 102a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)#include <sys/types.h> 112a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 122a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)#include <list> 132a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 145d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles)#include "base/basictypes.h" 1523730a6e56a168d1879203e4b3819bb36e3d8f1fTorne (Richard Coles)#include "base/memory/ref_counted.h" 16b2df76ea8fec9e32f6f3718986dba0d95315b29cTorne (Richard Coles)#include "base/strings/string_piece.h" 17b2df76ea8fec9e32f6f3718986dba0d95315b29cTorne (Richard Coles)#include "net/base/iovec.h" 18b2df76ea8fec9e32f6f3718986dba0d95315b29cTorne (Richard Coles)#include "net/base/net_export.h" 19f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles)#include "net/quic/quic_ack_notifier.h" 200529e5d033099cbfc42635f6f6183833b09dff6eBen Murdoch#include "net/quic/quic_flow_controller.h" 215d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles)#include "net/quic/quic_protocol.h" 225821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/quic/quic_stream_sequencer.h" 2346d4c2bc3267f3f028f39e7e311b0f89aba2e4fdTorne (Richard Coles)#include "net/quic/quic_types.h" 245821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 255821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)namespace net { 265821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 272a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)namespace test { 282a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)class ReliableQuicStreamPeer; 292a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)} // namespace test 302a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 315821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)class QuicSession; 325821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 335d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles)class NET_EXPORT_PRIVATE ReliableQuicStream { 345821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) public: 355821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ReliableQuicStream(QuicStreamId id, 365821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) QuicSession* session); 375821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) virtual ~ReliableQuicStream(); 395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 40a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) // Called when a (potentially duplicate) stream frame has been received 41a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) // for this stream. Returns false if this frame can not be accepted 42a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) // because there is too much data already buffered. 432a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) virtual bool OnStreamFrame(const QuicStreamFrame& frame); 442a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 45a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) // Called when the connection becomes writeable to allow the stream 46a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) // to write any pending data. 472a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) virtual void OnCanWrite(); 482a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 492a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) // Called by the session just before the stream is deleted. 502a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) virtual void OnClose(); 515821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 52a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) // Called when we get a stream reset from the peer. 535d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) virtual void OnStreamReset(const QuicRstStreamFrame& frame); 545821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 555821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Called when we get or send a connection close, and should immediately 565821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // close the stream. This is not passed through the sequencer, 575821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // but is handled immediately. 581e9bf3e0803691d0a228da41fc608347b6db4340Torne (Richard Coles) virtual void OnConnectionClosed(QuicErrorCode error, bool from_peer); 595821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 60a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) // Called when the final data has been read. 61a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) virtual void OnFinRead(); 625821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 635d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) virtual uint32 ProcessRawData(const char* data, uint32 data_len) = 0; 64b2df76ea8fec9e32f6f3718986dba0d95315b29cTorne (Richard Coles) 65a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) // Called to reset the stream from this end. 66a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) virtual void Reset(QuicRstStreamErrorCode error); 675821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 681e9bf3e0803691d0a228da41fc608347b6db4340Torne (Richard Coles) // Called to close the entire connection from this end. 691e9bf3e0803691d0a228da41fc608347b6db4340Torne (Richard Coles) virtual void CloseConnection(QuicErrorCode error); 701e9bf3e0803691d0a228da41fc608347b6db4340Torne (Richard Coles) virtual void CloseConnectionWithDetails(QuicErrorCode error, 711e9bf3e0803691d0a228da41fc608347b6db4340Torne (Richard Coles) const string& details); 721e9bf3e0803691d0a228da41fc608347b6db4340Torne (Richard Coles) 735d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) // Returns the effective priority for the stream. This value may change 745d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) // during the life of the stream. 755d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) virtual QuicPriority EffectivePriority() const = 0; 76d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 775821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) QuicStreamId id() const { return id_; } 785821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 79c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) QuicRstStreamErrorCode stream_error() const { return stream_error_; } 80c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) QuicErrorCode connection_error() const { return connection_error_; } 815821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 822a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) bool read_side_closed() const { return read_side_closed_; } 832a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) bool write_side_closed() const { return write_side_closed_; } 842a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 85a1401311d1ab56c4ed0a474bd38c108f75cb0cd9Torne (Richard Coles) uint64 stream_bytes_read() const { return stream_bytes_read_; } 86a1401311d1ab56c4ed0a474bd38c108f75cb0cd9Torne (Richard Coles) uint64 stream_bytes_written() const { return stream_bytes_written_; } 87b2df76ea8fec9e32f6f3718986dba0d95315b29cTorne (Richard Coles) 88a1401311d1ab56c4ed0a474bd38c108f75cb0cd9Torne (Richard Coles) QuicVersion version() const; 8990dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles) 905d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) void set_fin_sent(bool fin_sent) { fin_sent_ = fin_sent; } 915d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) void set_rst_sent(bool rst_sent) { rst_sent_ = rst_sent; } 922385ea399aae016c0806a4f9ef3c9cfe3d2a39dfBen Murdoch 93e5d81f57cb97b3b6b7fccc9c5610d21eb81db09dBen Murdoch // Adjust our flow control windows according to new offset in |frame|. 94e5d81f57cb97b3b6b7fccc9c5610d21eb81db09dBen Murdoch virtual void OnWindowUpdateFrame(const QuicWindowUpdateFrame& frame); 95e5d81f57cb97b3b6b7fccc9c5610d21eb81db09dBen Murdoch 96010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) int num_frames_received() const; 97c5cede9ae108bb15f6b7a8aea21c7e1fefa2834cBen Murdoch 98010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) int num_duplicate_frames_received() const; 99c5cede9ae108bb15f6b7a8aea21c7e1fefa2834cBen Murdoch 1000529e5d033099cbfc42635f6f6183833b09dff6eBen Murdoch QuicFlowController* flow_controller() { return &flow_controller_; } 1010529e5d033099cbfc42635f6f6183833b09dff6eBen Murdoch 10246d4c2bc3267f3f028f39e7e311b0f89aba2e4fdTorne (Richard Coles) // Called when we see a frame which could increase the highest offset. 10346d4c2bc3267f3f028f39e7e311b0f89aba2e4fdTorne (Richard Coles) // Returns true if the highest offset did increase. 10446d4c2bc3267f3f028f39e7e311b0f89aba2e4fdTorne (Richard Coles) bool MaybeIncreaseHighestReceivedOffset(uint64 new_offset); 105010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) // Called when bytese are sent to the peer. 106010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) void AddBytesSent(uint64 bytes); 10746d4c2bc3267f3f028f39e7e311b0f89aba2e4fdTorne (Richard Coles) // Called by the stream sequencer as bytes are consumed from the buffer. 10846d4c2bc3267f3f028f39e7e311b0f89aba2e4fdTorne (Richard Coles) // If our receive window has dropped below the threshold, then send a 10946d4c2bc3267f3f028f39e7e311b0f89aba2e4fdTorne (Richard Coles) // WINDOW_UPDATE frame. 110010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) void AddBytesConsumed(uint64 bytes); 111010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) 112010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) // Returns true if the stream is flow control blocked, by the stream flow 113010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) // control window or the connection flow control window. 114010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) bool IsFlowControlBlocked(); 115010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) 1165821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) protected: 1175d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) // Sends as much of 'data' to the connection as the connection will consume, 1185d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) // and then buffers any remaining data in queued_data_. 11923730a6e56a168d1879203e4b3819bb36e3d8f1fTorne (Richard Coles) void WriteOrBufferData( 12023730a6e56a168d1879203e4b3819bb36e3d8f1fTorne (Richard Coles) base::StringPiece data, 12123730a6e56a168d1879203e4b3819bb36e3d8f1fTorne (Richard Coles) bool fin, 12223730a6e56a168d1879203e4b3819bb36e3d8f1fTorne (Richard Coles) QuicAckNotifier::DelegateInterface* ack_notifier_delegate); 1235d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) 1245d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) // Sends as many bytes in the first |count| buffers of |iov| to the connection 1255d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) // as the connection will consume. 1265d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) // If |ack_notifier_delegate| is provided, then it will be notified once all 1275d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) // the ACKs for this write have been received. 1285d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) // Returns the number of bytes consumed by the connection. 1295d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) QuicConsumedData WritevData( 1305d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) const struct iovec* iov, 1315d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) int iov_count, 1325d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) bool fin, 1335d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) QuicAckNotifier::DelegateInterface* ack_notifier_delegate); 1342a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 1355821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Close the read side of the socket. Further frames will not be accepted. 1365821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) virtual void CloseReadSide(); 1372a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 1385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Close the write side of the socket. Further writes will fail. 1395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) void CloseWriteSide(); 1405821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 141010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) bool HasBufferedData() const; 14258537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles) 143010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) bool fin_buffered() const { return fin_buffered_; } 144b2df76ea8fec9e32f6f3718986dba0d95315b29cTorne (Richard Coles) 145a1401311d1ab56c4ed0a474bd38c108f75cb0cd9Torne (Richard Coles) const QuicSession* session() const { return session_; } 1465821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) QuicSession* session() { return session_; } 1475821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1485d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) const QuicStreamSequencer* sequencer() const { return &sequencer_; } 1495d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) QuicStreamSequencer* sequencer() { return &sequencer_; } 150d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 1510529e5d033099cbfc42635f6f6183833b09dff6eBen Murdoch void DisableFlowControl() { 1520529e5d033099cbfc42635f6f6183833b09dff6eBen Murdoch flow_controller_.Disable(); 1530529e5d033099cbfc42635f6f6183833b09dff6eBen Murdoch } 154e5d81f57cb97b3b6b7fccc9c5610d21eb81db09dBen Murdoch 1555821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) private: 1562a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) friend class test::ReliableQuicStreamPeer; 1572a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) friend class QuicStreamUtils; 15823730a6e56a168d1879203e4b3819bb36e3d8f1fTorne (Richard Coles) class ProxyAckNotifierDelegate; 15923730a6e56a168d1879203e4b3819bb36e3d8f1fTorne (Richard Coles) 16023730a6e56a168d1879203e4b3819bb36e3d8f1fTorne (Richard Coles) struct PendingData { 16123730a6e56a168d1879203e4b3819bb36e3d8f1fTorne (Richard Coles) PendingData(string data_in, 16223730a6e56a168d1879203e4b3819bb36e3d8f1fTorne (Richard Coles) scoped_refptr<ProxyAckNotifierDelegate> delegate_in); 16323730a6e56a168d1879203e4b3819bb36e3d8f1fTorne (Richard Coles) ~PendingData(); 16423730a6e56a168d1879203e4b3819bb36e3d8f1fTorne (Richard Coles) 16523730a6e56a168d1879203e4b3819bb36e3d8f1fTorne (Richard Coles) string data; 16623730a6e56a168d1879203e4b3819bb36e3d8f1fTorne (Richard Coles) // Delegate that should be notified when the pending data is acked. 16723730a6e56a168d1879203e4b3819bb36e3d8f1fTorne (Richard Coles) // Can be nullptr. 16823730a6e56a168d1879203e4b3819bb36e3d8f1fTorne (Richard Coles) scoped_refptr<ProxyAckNotifierDelegate> delegate; 16923730a6e56a168d1879203e4b3819bb36e3d8f1fTorne (Richard Coles) }; 1702a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 171010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) // Calls MaybeSendBlocked on our flow controller, and connection level flow 172010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) // controller. If we are flow control blocked, marks this stream as write 173010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) // blocked. 174010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) void MaybeSendBlocked(); 175010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) 17623730a6e56a168d1879203e4b3819bb36e3d8f1fTorne (Richard Coles) std::list<PendingData> queued_data_; 1775821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1785821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) QuicStreamSequencer sequencer_; 1795821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) QuicStreamId id_; 1805821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) QuicSession* session_; 1812a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) // Bytes read and written refer to payload bytes only: they do not include 1822a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) // framing, encryption overhead etc. 1832a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) uint64 stream_bytes_read_; 1842a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) uint64 stream_bytes_written_; 185c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) 186c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) // Stream error code received from a RstStreamFrame or error code sent by the 187c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) // visitor or sequencer in the RstStreamFrame. 188c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) QuicRstStreamErrorCode stream_error_; 189c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) // Connection error code due to which the stream was closed. |stream_error_| 190c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) // is set to |QUIC_STREAM_CONNECTION_ERROR| when this happens and consumers 191c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) // should check |connection_error_|. 192c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) QuicErrorCode connection_error_; 193c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) 1945821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // True if the read side is closed and further frames should be rejected. 1955821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) bool read_side_closed_; 1965821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // True if the write side is closed, and further writes should fail. 1975821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) bool write_side_closed_; 1982a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 1992a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) bool fin_buffered_; 2002a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) bool fin_sent_; 2011e9bf3e0803691d0a228da41fc608347b6db4340Torne (Richard Coles) 2025d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) // In combination with fin_sent_, used to ensure that a FIN and/or a RST is 2035d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) // always sent before stream termination. 2045d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) bool rst_sent_; 2055d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) 2061e9bf3e0803691d0a228da41fc608347b6db4340Torne (Richard Coles) // True if the session this stream is running under is a server session. 2071e9bf3e0803691d0a228da41fc608347b6db4340Torne (Richard Coles) bool is_server_; 2085d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) 2090529e5d033099cbfc42635f6f6183833b09dff6eBen Murdoch QuicFlowController flow_controller_; 2100529e5d033099cbfc42635f6f6183833b09dff6eBen Murdoch 211010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) // The connection level flow controller. Not owned. 212010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) QuicFlowController* connection_flow_controller_; 213010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) 2145d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) DISALLOW_COPY_AND_ASSIGN(ReliableQuicStream); 2155821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)}; 2165821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2175821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} // namespace net 2185821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2195821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#endif // NET_QUIC_RELIABLE_QUIC_STREAM_H_ 220