reliable_quic_stream.h revision f8ee788a64d60abd8f2d742a5fdedde054ecd910
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) 116f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) // Returns true if we have received either a RST or a FIN - either of which 117f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) // gives a definitive number of bytes which the peer has sent. If this is not 118f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) // true on stream termination the session must keep track of the stream's byte 119f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) // offset until a definitive final value arrives. 120f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) bool HasFinalReceivedByteOffset() const { 121f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) return fin_received_ || rst_received_; 122f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) } 123f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) 1245821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) protected: 1255d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) // Sends as much of 'data' to the connection as the connection will consume, 1265d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) // and then buffers any remaining data in queued_data_. 12723730a6e56a168d1879203e4b3819bb36e3d8f1fTorne (Richard Coles) void WriteOrBufferData( 12823730a6e56a168d1879203e4b3819bb36e3d8f1fTorne (Richard Coles) base::StringPiece data, 12923730a6e56a168d1879203e4b3819bb36e3d8f1fTorne (Richard Coles) bool fin, 13023730a6e56a168d1879203e4b3819bb36e3d8f1fTorne (Richard Coles) QuicAckNotifier::DelegateInterface* ack_notifier_delegate); 1315d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) 1325d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) // Sends as many bytes in the first |count| buffers of |iov| to the connection 1335d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) // as the connection will consume. 1345d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) // If |ack_notifier_delegate| is provided, then it will be notified once all 1355d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) // the ACKs for this write have been received. 1365d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) // Returns the number of bytes consumed by the connection. 1375d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) QuicConsumedData WritevData( 1385d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) const struct iovec* iov, 1395d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) int iov_count, 1405d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) bool fin, 1415d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) QuicAckNotifier::DelegateInterface* ack_notifier_delegate); 1422a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 143f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) // Helper method that returns FecProtection to use for writes to the session. 144f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) FecProtection GetFecProtection(); 145f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) 1465821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Close the read side of the socket. Further frames will not be accepted. 1475821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) virtual void CloseReadSide(); 1482a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 1495821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Close the write side of the socket. Further writes will fail. 1505821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) void CloseWriteSide(); 1515821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 152010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) bool HasBufferedData() const; 15358537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles) 154010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) bool fin_buffered() const { return fin_buffered_; } 155b2df76ea8fec9e32f6f3718986dba0d95315b29cTorne (Richard Coles) 156f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) void set_fec_policy(FecPolicy fec_policy) { fec_policy_ = fec_policy; } 157f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) 158a1401311d1ab56c4ed0a474bd38c108f75cb0cd9Torne (Richard Coles) const QuicSession* session() const { return session_; } 1595821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) QuicSession* session() { return session_; } 1605821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1615d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) const QuicStreamSequencer* sequencer() const { return &sequencer_; } 1625d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) QuicStreamSequencer* sequencer() { return &sequencer_; } 163d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 1640529e5d033099cbfc42635f6f6183833b09dff6eBen Murdoch void DisableFlowControl() { 1650529e5d033099cbfc42635f6f6183833b09dff6eBen Murdoch flow_controller_.Disable(); 1660529e5d033099cbfc42635f6f6183833b09dff6eBen Murdoch } 167e5d81f57cb97b3b6b7fccc9c5610d21eb81db09dBen Murdoch 1685821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) private: 1692a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) friend class test::ReliableQuicStreamPeer; 1702a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) friend class QuicStreamUtils; 17123730a6e56a168d1879203e4b3819bb36e3d8f1fTorne (Richard Coles) class ProxyAckNotifierDelegate; 17223730a6e56a168d1879203e4b3819bb36e3d8f1fTorne (Richard Coles) 17323730a6e56a168d1879203e4b3819bb36e3d8f1fTorne (Richard Coles) struct PendingData { 17423730a6e56a168d1879203e4b3819bb36e3d8f1fTorne (Richard Coles) PendingData(string data_in, 17523730a6e56a168d1879203e4b3819bb36e3d8f1fTorne (Richard Coles) scoped_refptr<ProxyAckNotifierDelegate> delegate_in); 17623730a6e56a168d1879203e4b3819bb36e3d8f1fTorne (Richard Coles) ~PendingData(); 17723730a6e56a168d1879203e4b3819bb36e3d8f1fTorne (Richard Coles) 17823730a6e56a168d1879203e4b3819bb36e3d8f1fTorne (Richard Coles) string data; 17923730a6e56a168d1879203e4b3819bb36e3d8f1fTorne (Richard Coles) // Delegate that should be notified when the pending data is acked. 18023730a6e56a168d1879203e4b3819bb36e3d8f1fTorne (Richard Coles) // Can be nullptr. 18123730a6e56a168d1879203e4b3819bb36e3d8f1fTorne (Richard Coles) scoped_refptr<ProxyAckNotifierDelegate> delegate; 18223730a6e56a168d1879203e4b3819bb36e3d8f1fTorne (Richard Coles) }; 1832a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 184010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) // Calls MaybeSendBlocked on our flow controller, and connection level flow 185010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) // controller. If we are flow control blocked, marks this stream as write 186010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) // blocked. 187010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) void MaybeSendBlocked(); 188010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) 18923730a6e56a168d1879203e4b3819bb36e3d8f1fTorne (Richard Coles) std::list<PendingData> queued_data_; 1905821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1915821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) QuicStreamSequencer sequencer_; 1925821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) QuicStreamId id_; 1935821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) QuicSession* session_; 1942a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) // Bytes read and written refer to payload bytes only: they do not include 1952a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) // framing, encryption overhead etc. 1962a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) uint64 stream_bytes_read_; 1972a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) uint64 stream_bytes_written_; 198c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) 199c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) // Stream error code received from a RstStreamFrame or error code sent by the 200c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) // visitor or sequencer in the RstStreamFrame. 201c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) QuicRstStreamErrorCode stream_error_; 202c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) // Connection error code due to which the stream was closed. |stream_error_| 203c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) // is set to |QUIC_STREAM_CONNECTION_ERROR| when this happens and consumers 204c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) // should check |connection_error_|. 205c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) QuicErrorCode connection_error_; 206c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) 2075821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // True if the read side is closed and further frames should be rejected. 2085821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) bool read_side_closed_; 2095821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // True if the write side is closed, and further writes should fail. 2105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) bool write_side_closed_; 2112a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 2122a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) bool fin_buffered_; 2132a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) bool fin_sent_; 2141e9bf3e0803691d0a228da41fc608347b6db4340Torne (Richard Coles) 215f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) // True if this stream has received (and the sequencer has accepted) a 216f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) // StreamFrame with the FIN set. 217f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) bool fin_received_; 218f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) 2195d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) // In combination with fin_sent_, used to ensure that a FIN and/or a RST is 2205d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) // always sent before stream termination. 2215d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) bool rst_sent_; 2225d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) 223f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) // True if this stream has received a RST stream frame. 224f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) bool rst_received_; 225f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) 226f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) // FEC policy to be used for this stream. 227f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) FecPolicy fec_policy_; 228f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) 2291e9bf3e0803691d0a228da41fc608347b6db4340Torne (Richard Coles) // True if the session this stream is running under is a server session. 2301e9bf3e0803691d0a228da41fc608347b6db4340Torne (Richard Coles) bool is_server_; 2315d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) 2320529e5d033099cbfc42635f6f6183833b09dff6eBen Murdoch QuicFlowController flow_controller_; 2330529e5d033099cbfc42635f6f6183833b09dff6eBen Murdoch 234010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) // The connection level flow controller. Not owned. 235010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) QuicFlowController* connection_flow_controller_; 236010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) 2375d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) DISALLOW_COPY_AND_ASSIGN(ReliableQuicStream); 2385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)}; 2395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2405821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} // namespace net 2415821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2425821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#endif // NET_QUIC_RELIABLE_QUIC_STREAM_H_ 243