| Index: net/quic/reliable_quic_stream.h
|
| diff --git a/net/quic/reliable_quic_stream.h b/net/quic/reliable_quic_stream.h
|
| deleted file mode 100644
|
| index 93ad0c695fc4fe01bf918c2a34581cbabed27b38..0000000000000000000000000000000000000000
|
| --- a/net/quic/reliable_quic_stream.h
|
| +++ /dev/null
|
| @@ -1,253 +0,0 @@
|
| -// Copyright (c) 2012 The Chromium Authors. All rights reserved.
|
| -// Use of this source code is governed by a BSD-style license that can be
|
| -// found in the LICENSE file.
|
| -//
|
| -// The base class for client/server reliable streams.
|
| -
|
| -#ifndef NET_QUIC_RELIABLE_QUIC_STREAM_H_
|
| -#define NET_QUIC_RELIABLE_QUIC_STREAM_H_
|
| -
|
| -#include <sys/types.h>
|
| -
|
| -#include <list>
|
| -#include <string>
|
| -
|
| -#include "base/basictypes.h"
|
| -#include "base/memory/ref_counted.h"
|
| -#include "base/strings/string_piece.h"
|
| -#include "net/base/iovec.h"
|
| -#include "net/base/net_export.h"
|
| -#include "net/quic/quic_ack_notifier.h"
|
| -#include "net/quic/quic_flow_controller.h"
|
| -#include "net/quic/quic_protocol.h"
|
| -#include "net/quic/quic_stream_sequencer.h"
|
| -#include "net/quic/quic_types.h"
|
| -
|
| -namespace net {
|
| -
|
| -namespace test {
|
| -class ReliableQuicStreamPeer;
|
| -} // namespace test
|
| -
|
| -class QuicSession;
|
| -
|
| -class NET_EXPORT_PRIVATE ReliableQuicStream {
|
| - public:
|
| - ReliableQuicStream(QuicStreamId id,
|
| - QuicSession* session);
|
| -
|
| - virtual ~ReliableQuicStream();
|
| -
|
| - // Called when a (potentially duplicate) stream frame has been received
|
| - // for this stream.
|
| - virtual void OnStreamFrame(const QuicStreamFrame& frame);
|
| -
|
| - // Called when the connection becomes writeable to allow the stream
|
| - // to write any pending data.
|
| - virtual void OnCanWrite();
|
| -
|
| - // Called by the session just before the stream is deleted.
|
| - virtual void OnClose();
|
| -
|
| - // Called when we get a stream reset from the peer.
|
| - virtual void OnStreamReset(const QuicRstStreamFrame& frame);
|
| -
|
| - // Called when we get or send a connection close, and should immediately
|
| - // close the stream. This is not passed through the sequencer,
|
| - // but is handled immediately.
|
| - virtual void OnConnectionClosed(QuicErrorCode error, bool from_peer);
|
| -
|
| - // Called when the final data has been read.
|
| - virtual void OnFinRead();
|
| -
|
| - virtual uint32 ProcessRawData(const char* data, uint32 data_len) = 0;
|
| -
|
| - // Called to reset the stream from this end.
|
| - virtual void Reset(QuicRstStreamErrorCode error);
|
| -
|
| - // Called to close the entire connection from this end.
|
| - virtual void CloseConnection(QuicErrorCode error);
|
| - virtual void CloseConnectionWithDetails(QuicErrorCode error,
|
| - const std::string& details);
|
| -
|
| - // Returns the effective priority for the stream. This value may change
|
| - // during the life of the stream.
|
| - virtual QuicPriority EffectivePriority() const = 0;
|
| -
|
| - QuicStreamId id() const { return id_; }
|
| -
|
| - QuicRstStreamErrorCode stream_error() const { return stream_error_; }
|
| - QuicErrorCode connection_error() const { return connection_error_; }
|
| -
|
| - bool read_side_closed() const { return read_side_closed_; }
|
| - bool write_side_closed() const { return write_side_closed_; }
|
| -
|
| - uint64 stream_bytes_read() const { return stream_bytes_read_; }
|
| - uint64 stream_bytes_written() const { return stream_bytes_written_; }
|
| -
|
| - QuicVersion version() const;
|
| -
|
| - void set_fin_sent(bool fin_sent) { fin_sent_ = fin_sent; }
|
| - void set_rst_sent(bool rst_sent) { rst_sent_ = rst_sent; }
|
| -
|
| - void set_fec_policy(FecPolicy fec_policy) { fec_policy_ = fec_policy; }
|
| - FecPolicy fec_policy() const { return fec_policy_; }
|
| -
|
| - // Adjust our flow control windows according to new offset in |frame|.
|
| - virtual void OnWindowUpdateFrame(const QuicWindowUpdateFrame& frame);
|
| -
|
| - int num_frames_received() const;
|
| -
|
| - int num_duplicate_frames_received() const;
|
| -
|
| - QuicFlowController* flow_controller() { return &flow_controller_; }
|
| -
|
| - // Called when we see a frame which could increase the highest offset.
|
| - // Returns true if the highest offset did increase.
|
| - bool MaybeIncreaseHighestReceivedOffset(QuicStreamOffset new_offset);
|
| - // Called when bytese are sent to the peer.
|
| - void AddBytesSent(QuicByteCount bytes);
|
| - // Called by the stream sequencer as bytes are consumed from the buffer.
|
| - // If our receive window has dropped below the threshold, then send a
|
| - // WINDOW_UPDATE frame.
|
| - void AddBytesConsumed(QuicByteCount bytes);
|
| -
|
| - // Updates the flow controller's send window offset and calls OnCanWrite if
|
| - // it was blocked before.
|
| - void UpdateSendWindowOffset(QuicStreamOffset new_offset);
|
| -
|
| - // Returns true if the stream is flow control blocked, by the stream flow
|
| - // control window or the connection flow control window.
|
| - bool IsFlowControlBlocked();
|
| -
|
| - // Returns true if we have received either a RST or a FIN - either of which
|
| - // gives a definitive number of bytes which the peer has sent. If this is not
|
| - // true on stream termination the session must keep track of the stream's byte
|
| - // offset until a definitive final value arrives.
|
| - bool HasFinalReceivedByteOffset() const {
|
| - return fin_received_ || rst_received_;
|
| - }
|
| -
|
| - // Returns true if the stream has queued data waiting to write.
|
| - bool HasBufferedData() const;
|
| -
|
| - protected:
|
| - // Sends as much of 'data' to the connection as the connection will consume,
|
| - // and then buffers any remaining data in queued_data_.
|
| - void WriteOrBufferData(
|
| - base::StringPiece data,
|
| - bool fin,
|
| - QuicAckNotifier::DelegateInterface* ack_notifier_delegate);
|
| -
|
| - // Sends as many bytes in the first |count| buffers of |iov| to the connection
|
| - // as the connection will consume.
|
| - // If |ack_notifier_delegate| is provided, then it will be notified once all
|
| - // the ACKs for this write have been received.
|
| - // Returns the number of bytes consumed by the connection.
|
| - QuicConsumedData WritevData(
|
| - const struct iovec* iov,
|
| - int iov_count,
|
| - bool fin,
|
| - QuicAckNotifier::DelegateInterface* ack_notifier_delegate);
|
| -
|
| - // Helper method that returns FecProtection to use for writes to the session.
|
| - FecProtection GetFecProtection();
|
| -
|
| - // Close the read side of the socket. Further frames will not be accepted.
|
| - virtual void CloseReadSide();
|
| -
|
| - // Close the write side of the socket. Further writes will fail.
|
| - void CloseWriteSide();
|
| -
|
| - bool fin_buffered() const { return fin_buffered_; }
|
| -
|
| - const QuicSession* session() const { return session_; }
|
| - QuicSession* session() { return session_; }
|
| -
|
| - const QuicStreamSequencer* sequencer() const { return &sequencer_; }
|
| - QuicStreamSequencer* sequencer() { return &sequencer_; }
|
| -
|
| - void DisableConnectionFlowControlForThisStream() {
|
| - stream_contributes_to_connection_flow_control_ = false;
|
| - }
|
| -
|
| - private:
|
| - friend class test::ReliableQuicStreamPeer;
|
| - friend class QuicStreamUtils;
|
| - class ProxyAckNotifierDelegate;
|
| -
|
| - struct PendingData {
|
| - PendingData(std::string data_in,
|
| - scoped_refptr<ProxyAckNotifierDelegate> delegate_in);
|
| - ~PendingData();
|
| -
|
| - std::string data;
|
| - // Delegate that should be notified when the pending data is acked.
|
| - // Can be nullptr.
|
| - scoped_refptr<ProxyAckNotifierDelegate> delegate;
|
| - };
|
| -
|
| - // Calls MaybeSendBlocked on our flow controller, and connection level flow
|
| - // controller. If we are flow control blocked, marks this stream as write
|
| - // blocked.
|
| - void MaybeSendBlocked();
|
| -
|
| - std::list<PendingData> queued_data_;
|
| -
|
| - QuicStreamSequencer sequencer_;
|
| - QuicStreamId id_;
|
| - QuicSession* session_;
|
| - // Bytes read and written refer to payload bytes only: they do not include
|
| - // framing, encryption overhead etc.
|
| - uint64 stream_bytes_read_;
|
| - uint64 stream_bytes_written_;
|
| -
|
| - // Stream error code received from a RstStreamFrame or error code sent by the
|
| - // visitor or sequencer in the RstStreamFrame.
|
| - QuicRstStreamErrorCode stream_error_;
|
| - // Connection error code due to which the stream was closed. |stream_error_|
|
| - // is set to |QUIC_STREAM_CONNECTION_ERROR| when this happens and consumers
|
| - // should check |connection_error_|.
|
| - QuicErrorCode connection_error_;
|
| -
|
| - // True if the read side is closed and further frames should be rejected.
|
| - bool read_side_closed_;
|
| - // True if the write side is closed, and further writes should fail.
|
| - bool write_side_closed_;
|
| -
|
| - bool fin_buffered_;
|
| - bool fin_sent_;
|
| -
|
| - // True if this stream has received (and the sequencer has accepted) a
|
| - // StreamFrame with the FIN set.
|
| - bool fin_received_;
|
| -
|
| - // In combination with fin_sent_, used to ensure that a FIN and/or a RST is
|
| - // always sent before stream termination.
|
| - bool rst_sent_;
|
| -
|
| - // True if this stream has received a RST stream frame.
|
| - bool rst_received_;
|
| -
|
| - // FEC policy to be used for this stream.
|
| - FecPolicy fec_policy_;
|
| -
|
| - // True if the session this stream is running under is a server session.
|
| - bool is_server_;
|
| -
|
| - QuicFlowController flow_controller_;
|
| -
|
| - // The connection level flow controller. Not owned.
|
| - QuicFlowController* connection_flow_controller_;
|
| -
|
| - // Special streams, such as the crypto and headers streams, do not respect
|
| - // connection level flow control limits (but are stream level flow control
|
| - // limited).
|
| - bool stream_contributes_to_connection_flow_control_;
|
| -
|
| - DISALLOW_COPY_AND_ASSIGN(ReliableQuicStream);
|
| -};
|
| -
|
| -} // namespace net
|
| -
|
| -#endif // NET_QUIC_RELIABLE_QUIC_STREAM_H_
|
|
|