Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(618)

Unified Diff: net/quic/reliable_quic_stream.h

Issue 992733002: Remove //net (except for Android test stuff) and sdch (Closed) Base URL: git@github.com:domokit/mojo.git@master
Patch Set: Created 5 years, 9 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « net/quic/quic_write_blocked_list_test.cc ('k') | net/quic/reliable_quic_stream.cc » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
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_
« no previous file with comments | « net/quic/quic_write_blocked_list_test.cc ('k') | net/quic/reliable_quic_stream.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698