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 415f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) // for this stream. 425f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) virtual void OnStreamFrame(const QuicStreamFrame& frame); 432a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 44a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) // Called when the connection becomes writeable to allow the stream 45a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) // to write any pending data. 462a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) virtual void OnCanWrite(); 472a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 482a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) // Called by the session just before the stream is deleted. 492a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) virtual void OnClose(); 505821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 51a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) // Called when we get a stream reset from the peer. 525d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) virtual void OnStreamReset(const QuicRstStreamFrame& frame); 535821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 545821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Called when we get or send a connection close, and should immediately 555821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // close the stream. This is not passed through the sequencer, 565821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // but is handled immediately. 571e9bf3e0803691d0a228da41fc608347b6db4340Torne (Richard Coles) virtual void OnConnectionClosed(QuicErrorCode error, bool from_peer); 585821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 59a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) // Called when the final data has been read. 60a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) virtual void OnFinRead(); 615821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 625d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) virtual uint32 ProcessRawData(const char* data, uint32 data_len) = 0; 63b2df76ea8fec9e32f6f3718986dba0d95315b29cTorne (Richard Coles) 64a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) // Called to reset the stream from this end. 65a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) virtual void Reset(QuicRstStreamErrorCode error); 665821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 671e9bf3e0803691d0a228da41fc608347b6db4340Torne (Richard Coles) // Called to close the entire connection from this end. 681e9bf3e0803691d0a228da41fc608347b6db4340Torne (Richard Coles) virtual void CloseConnection(QuicErrorCode error); 691e9bf3e0803691d0a228da41fc608347b6db4340Torne (Richard Coles) virtual void CloseConnectionWithDetails(QuicErrorCode error, 701e9bf3e0803691d0a228da41fc608347b6db4340Torne (Richard Coles) const string& details); 711e9bf3e0803691d0a228da41fc608347b6db4340Torne (Richard Coles) 725d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) // Returns the effective priority for the stream. This value may change 735d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) // during the life of the stream. 745d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) virtual QuicPriority EffectivePriority() const = 0; 75d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 765821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) QuicStreamId id() const { return id_; } 775821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 78c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) QuicRstStreamErrorCode stream_error() const { return stream_error_; } 79c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) QuicErrorCode connection_error() const { return connection_error_; } 805821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 812a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) bool read_side_closed() const { return read_side_closed_; } 822a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) bool write_side_closed() const { return write_side_closed_; } 832a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 84a1401311d1ab56c4ed0a474bd38c108f75cb0cd9Torne (Richard Coles) uint64 stream_bytes_read() const { return stream_bytes_read_; } 85a1401311d1ab56c4ed0a474bd38c108f75cb0cd9Torne (Richard Coles) uint64 stream_bytes_written() const { return stream_bytes_written_; } 86b2df76ea8fec9e32f6f3718986dba0d95315b29cTorne (Richard Coles) 87a1401311d1ab56c4ed0a474bd38c108f75cb0cd9Torne (Richard Coles) QuicVersion version() const; 8890dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles) 895d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) void set_fin_sent(bool fin_sent) { fin_sent_ = fin_sent; } 905d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) void set_rst_sent(bool rst_sent) { rst_sent_ = rst_sent; } 912385ea399aae016c0806a4f9ef3c9cfe3d2a39dfBen Murdoch 92116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch void set_fec_policy(FecPolicy fec_policy) { fec_policy_ = fec_policy; } 93116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch FecPolicy fec_policy() const { return fec_policy_; } 94116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch 95e5d81f57cb97b3b6b7fccc9c5610d21eb81db09dBen Murdoch // Adjust our flow control windows according to new offset in |frame|. 96e5d81f57cb97b3b6b7fccc9c5610d21eb81db09dBen Murdoch virtual void OnWindowUpdateFrame(const QuicWindowUpdateFrame& frame); 97e5d81f57cb97b3b6b7fccc9c5610d21eb81db09dBen Murdoch 98010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) int num_frames_received() const; 99c5cede9ae108bb15f6b7a8aea21c7e1fefa2834cBen Murdoch 100010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) int num_duplicate_frames_received() const; 101c5cede9ae108bb15f6b7a8aea21c7e1fefa2834cBen Murdoch 1020529e5d033099cbfc42635f6f6183833b09dff6eBen Murdoch QuicFlowController* flow_controller() { return &flow_controller_; } 1030529e5d033099cbfc42635f6f6183833b09dff6eBen Murdoch 10446d4c2bc3267f3f028f39e7e311b0f89aba2e4fdTorne (Richard Coles) // Called when we see a frame which could increase the highest offset. 10546d4c2bc3267f3f028f39e7e311b0f89aba2e4fdTorne (Richard Coles) // Returns true if the highest offset did increase. 10646d4c2bc3267f3f028f39e7e311b0f89aba2e4fdTorne (Richard Coles) bool MaybeIncreaseHighestReceivedOffset(uint64 new_offset); 107010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) // Called when bytese are sent to the peer. 108010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) void AddBytesSent(uint64 bytes); 10946d4c2bc3267f3f028f39e7e311b0f89aba2e4fdTorne (Richard Coles) // Called by the stream sequencer as bytes are consumed from the buffer. 11046d4c2bc3267f3f028f39e7e311b0f89aba2e4fdTorne (Richard Coles) // If our receive window has dropped below the threshold, then send a 11146d4c2bc3267f3f028f39e7e311b0f89aba2e4fdTorne (Richard Coles) // WINDOW_UPDATE frame. 112010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) void AddBytesConsumed(uint64 bytes); 113010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) 1141675a649fd7a8b3cb80ffddae2dc181f122353c5Ben Murdoch // Updates the flow controller's send window offset and calls OnCanWrite if 1151675a649fd7a8b3cb80ffddae2dc181f122353c5Ben Murdoch // it was blocked before. 1161675a649fd7a8b3cb80ffddae2dc181f122353c5Ben Murdoch void UpdateSendWindowOffset(uint64 new_offset); 1171675a649fd7a8b3cb80ffddae2dc181f122353c5Ben Murdoch 118010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) // Returns true if the stream is flow control blocked, by the stream flow 119010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) // control window or the connection flow control window. 120010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) bool IsFlowControlBlocked(); 121010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) 122f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) // Returns true if we have received either a RST or a FIN - either of which 123f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) // gives a definitive number of bytes which the peer has sent. If this is not 124f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) // true on stream termination the session must keep track of the stream's byte 125f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) // offset until a definitive final value arrives. 126f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) bool HasFinalReceivedByteOffset() const { 127f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) return fin_received_ || rst_received_; 128f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) } 129f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) 1301675a649fd7a8b3cb80ffddae2dc181f122353c5Ben Murdoch // Returns true if the stream has queued data waiting to write. 1311675a649fd7a8b3cb80ffddae2dc181f122353c5Ben Murdoch bool HasBufferedData() const; 1321675a649fd7a8b3cb80ffddae2dc181f122353c5Ben Murdoch 1335821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) protected: 1345d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) // Sends as much of 'data' to the connection as the connection will consume, 1355d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) // and then buffers any remaining data in queued_data_. 13623730a6e56a168d1879203e4b3819bb36e3d8f1fTorne (Richard Coles) void WriteOrBufferData( 13723730a6e56a168d1879203e4b3819bb36e3d8f1fTorne (Richard Coles) base::StringPiece data, 13823730a6e56a168d1879203e4b3819bb36e3d8f1fTorne (Richard Coles) bool fin, 13923730a6e56a168d1879203e4b3819bb36e3d8f1fTorne (Richard Coles) QuicAckNotifier::DelegateInterface* ack_notifier_delegate); 1405d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) 1415d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) // Sends as many bytes in the first |count| buffers of |iov| to the connection 1425d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) // as the connection will consume. 1435d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) // If |ack_notifier_delegate| is provided, then it will be notified once all 1445d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) // the ACKs for this write have been received. 1455d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) // Returns the number of bytes consumed by the connection. 1465d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) QuicConsumedData WritevData( 1475d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) const struct iovec* iov, 1485d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) int iov_count, 1495d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) bool fin, 1505d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) QuicAckNotifier::DelegateInterface* ack_notifier_delegate); 1512a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 152f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) // Helper method that returns FecProtection to use for writes to the session. 153f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) FecProtection GetFecProtection(); 154f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) 1555821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Close the read side of the socket. Further frames will not be accepted. 1565821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) virtual void CloseReadSide(); 1572a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 1585821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Close the write side of the socket. Further writes will fail. 1595821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) void CloseWriteSide(); 1605821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 161010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) bool fin_buffered() const { return fin_buffered_; } 162b2df76ea8fec9e32f6f3718986dba0d95315b29cTorne (Richard Coles) 163a1401311d1ab56c4ed0a474bd38c108f75cb0cd9Torne (Richard Coles) const QuicSession* session() const { return session_; } 1645821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) QuicSession* session() { return session_; } 1655821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1665d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) const QuicStreamSequencer* sequencer() const { return &sequencer_; } 1675d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) QuicStreamSequencer* sequencer() { return &sequencer_; } 168d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 1691320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci // TODO(rjshade): Remove this method when removing QUIC_VERSION_19. 1700529e5d033099cbfc42635f6f6183833b09dff6eBen Murdoch void DisableFlowControl() { 1710529e5d033099cbfc42635f6f6183833b09dff6eBen Murdoch flow_controller_.Disable(); 1720529e5d033099cbfc42635f6f6183833b09dff6eBen Murdoch } 173e5d81f57cb97b3b6b7fccc9c5610d21eb81db09dBen Murdoch 174116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch void DisableConnectionFlowControlForThisStream() { 175116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch stream_contributes_to_connection_flow_control_ = false; 176116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch } 177116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch 1785821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) private: 1792a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) friend class test::ReliableQuicStreamPeer; 1802a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) friend class QuicStreamUtils; 18123730a6e56a168d1879203e4b3819bb36e3d8f1fTorne (Richard Coles) class ProxyAckNotifierDelegate; 18223730a6e56a168d1879203e4b3819bb36e3d8f1fTorne (Richard Coles) 18323730a6e56a168d1879203e4b3819bb36e3d8f1fTorne (Richard Coles) struct PendingData { 18423730a6e56a168d1879203e4b3819bb36e3d8f1fTorne (Richard Coles) PendingData(string data_in, 18523730a6e56a168d1879203e4b3819bb36e3d8f1fTorne (Richard Coles) scoped_refptr<ProxyAckNotifierDelegate> delegate_in); 18623730a6e56a168d1879203e4b3819bb36e3d8f1fTorne (Richard Coles) ~PendingData(); 18723730a6e56a168d1879203e4b3819bb36e3d8f1fTorne (Richard Coles) 18823730a6e56a168d1879203e4b3819bb36e3d8f1fTorne (Richard Coles) string data; 18923730a6e56a168d1879203e4b3819bb36e3d8f1fTorne (Richard Coles) // Delegate that should be notified when the pending data is acked. 19023730a6e56a168d1879203e4b3819bb36e3d8f1fTorne (Richard Coles) // Can be nullptr. 19123730a6e56a168d1879203e4b3819bb36e3d8f1fTorne (Richard Coles) scoped_refptr<ProxyAckNotifierDelegate> delegate; 19223730a6e56a168d1879203e4b3819bb36e3d8f1fTorne (Richard Coles) }; 1932a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 194010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) // Calls MaybeSendBlocked on our flow controller, and connection level flow 195010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) // controller. If we are flow control blocked, marks this stream as write 196010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) // blocked. 197010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) void MaybeSendBlocked(); 198010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) 19923730a6e56a168d1879203e4b3819bb36e3d8f1fTorne (Richard Coles) std::list<PendingData> queued_data_; 2005821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2015821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) QuicStreamSequencer sequencer_; 2025821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) QuicStreamId id_; 2035821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) QuicSession* session_; 2042a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) // Bytes read and written refer to payload bytes only: they do not include 2052a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) // framing, encryption overhead etc. 2062a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) uint64 stream_bytes_read_; 2072a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) uint64 stream_bytes_written_; 208c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) 209c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) // Stream error code received from a RstStreamFrame or error code sent by the 210c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) // visitor or sequencer in the RstStreamFrame. 211c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) QuicRstStreamErrorCode stream_error_; 212c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) // Connection error code due to which the stream was closed. |stream_error_| 213c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) // is set to |QUIC_STREAM_CONNECTION_ERROR| when this happens and consumers 214c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) // should check |connection_error_|. 215c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) QuicErrorCode connection_error_; 216c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) 2175821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // True if the read side is closed and further frames should be rejected. 2185821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) bool read_side_closed_; 2195821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // True if the write side is closed, and further writes should fail. 2205821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) bool write_side_closed_; 2212a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 2222a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) bool fin_buffered_; 2232a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) bool fin_sent_; 2241e9bf3e0803691d0a228da41fc608347b6db4340Torne (Richard Coles) 225f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) // True if this stream has received (and the sequencer has accepted) a 226f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) // StreamFrame with the FIN set. 227f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) bool fin_received_; 228f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) 2295d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) // In combination with fin_sent_, used to ensure that a FIN and/or a RST is 2305d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) // always sent before stream termination. 2315d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) bool rst_sent_; 2325d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) 233f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) // True if this stream has received a RST stream frame. 234f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) bool rst_received_; 235f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) 236f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) // FEC policy to be used for this stream. 237f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) FecPolicy fec_policy_; 238f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) 2391e9bf3e0803691d0a228da41fc608347b6db4340Torne (Richard Coles) // True if the session this stream is running under is a server session. 2401e9bf3e0803691d0a228da41fc608347b6db4340Torne (Richard Coles) bool is_server_; 2415d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) 2420529e5d033099cbfc42635f6f6183833b09dff6eBen Murdoch QuicFlowController flow_controller_; 2430529e5d033099cbfc42635f6f6183833b09dff6eBen Murdoch 244010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) // The connection level flow controller. Not owned. 245010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) QuicFlowController* connection_flow_controller_; 246010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) 247116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch // Special streams, such as the crypto and headers streams, do not respect 248116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch // connection level flow control limits (but are stream level flow control 249116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch // limited). 250116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch bool stream_contributes_to_connection_flow_control_; 251116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch 2525d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) DISALLOW_COPY_AND_ASSIGN(ReliableQuicStream); 2535821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)}; 2545821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2555821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} // namespace net 2565821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2575821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#endif // NET_QUIC_RELIABLE_QUIC_STREAM_H_ 258