| Index: net/quic/quic_stream_sequencer.h
|
| diff --git a/net/quic/quic_stream_sequencer.h b/net/quic/quic_stream_sequencer.h
|
| deleted file mode 100644
|
| index 3570d3b86cc1a1fcc3aad61e10bd185c7a8f1163..0000000000000000000000000000000000000000
|
| --- a/net/quic/quic_stream_sequencer.h
|
| +++ /dev/null
|
| @@ -1,136 +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.
|
| -
|
| -#ifndef NET_QUIC_QUIC_STREAM_SEQUENCER_H_
|
| -#define NET_QUIC_QUIC_STREAM_SEQUENCER_H_
|
| -
|
| -#include <map>
|
| -#include <string>
|
| -
|
| -#include "base/basictypes.h"
|
| -#include "net/base/iovec.h"
|
| -#include "net/quic/quic_protocol.h"
|
| -
|
| -namespace net {
|
| -
|
| -namespace test {
|
| -class QuicStreamSequencerPeer;
|
| -} // namespace test
|
| -
|
| -class QuicSession;
|
| -class ReliableQuicStream;
|
| -
|
| -// Buffers frames until we have something which can be passed
|
| -// up to the next layer.
|
| -class NET_EXPORT_PRIVATE QuicStreamSequencer {
|
| - public:
|
| - explicit QuicStreamSequencer(ReliableQuicStream* quic_stream);
|
| - virtual ~QuicStreamSequencer();
|
| -
|
| - // If the frame is the next one we need in order to process in-order data,
|
| - // ProcessData will be immediately called on the stream until all buffered
|
| - // data is processed or the stream fails to consume data. Any unconsumed
|
| - // data will be buffered. If the frame is not the next in line, it will be
|
| - // buffered.
|
| - void OnStreamFrame(const QuicStreamFrame& frame);
|
| -
|
| - // Once data is buffered, it's up to the stream to read it when the stream
|
| - // can handle more data. The following three functions make that possible.
|
| -
|
| - // Fills in up to iov_len iovecs with the next readable regions. Returns the
|
| - // number of iovs used. Non-destructive of the underlying data.
|
| - int GetReadableRegions(iovec* iov, size_t iov_len);
|
| -
|
| - // Copies the data into the iov_len buffers provided. Returns the number of
|
| - // bytes read. Any buffered data no longer in use will be released.
|
| - int Readv(const struct iovec* iov, size_t iov_len);
|
| -
|
| - // Returns true if the sequncer has bytes available for reading.
|
| - bool HasBytesToRead() const;
|
| -
|
| - // Returns true if the sequencer has delivered the fin.
|
| - bool IsClosed() const;
|
| -
|
| - // Returns true if the sequencer has received this frame before.
|
| - bool IsDuplicate(const QuicStreamFrame& frame) const;
|
| -
|
| - // Returns true if |frame| contains data which overlaps buffered data
|
| - // (indicating an invalid stream frame has been received).
|
| - bool FrameOverlapsBufferedData(const QuicStreamFrame& frame) const;
|
| -
|
| - // Calls |ProcessRawData| on |stream_| for each buffered frame that may
|
| - // be processed.
|
| - void FlushBufferedFrames();
|
| -
|
| - // Blocks processing of frames until |FlushBufferedFrames| is called.
|
| - void SetBlockedUntilFlush();
|
| -
|
| - size_t num_bytes_buffered() const { return num_bytes_buffered_; }
|
| - QuicStreamOffset num_bytes_consumed() const { return num_bytes_consumed_; }
|
| -
|
| - int num_frames_received() const { return num_frames_received_; }
|
| -
|
| - int num_duplicate_frames_received() const {
|
| - return num_duplicate_frames_received_;
|
| - }
|
| -
|
| - int num_early_frames_received() const { return num_early_frames_received_; }
|
| -
|
| - private:
|
| - friend class test::QuicStreamSequencerPeer;
|
| -
|
| - // Wait until we've seen 'offset' bytes, and then terminate the stream.
|
| - void CloseStreamAtOffset(QuicStreamOffset offset);
|
| -
|
| - // If we've received a FIN and have processed all remaining data, then inform
|
| - // the stream of FIN, and clear buffers.
|
| - bool MaybeCloseStream();
|
| -
|
| - // Called whenever bytes are consumed by the stream. Updates
|
| - // num_bytes_consumed_ and num_bytes_buffered_.
|
| - void RecordBytesConsumed(size_t bytes_consumed);
|
| -
|
| - // The stream which owns this sequencer.
|
| - ReliableQuicStream* stream_;
|
| -
|
| - // The last data consumed by the stream.
|
| - QuicStreamOffset num_bytes_consumed_;
|
| -
|
| - // TODO(alyssar) use something better than strings.
|
| - // TODO(rjshade): In future we may support retransmission of partial stream
|
| - // frames, in which case we will have to allow receipt of overlapping frames.
|
| - // Maybe write new frames into a ring buffer, and keep track of consumed
|
| - // bytes, and gaps.
|
| - typedef std::map<QuicStreamOffset, std::string> FrameMap;
|
| -
|
| - // Stores buffered frames (maps from sequence number -> frame data as string).
|
| - FrameMap buffered_frames_;
|
| -
|
| - // The offset, if any, we got a stream termination for. When this many bytes
|
| - // have been processed, the sequencer will be closed.
|
| - QuicStreamOffset close_offset_;
|
| -
|
| - // If true, the sequencer is blocked from passing data to the stream and will
|
| - // buffer all new incoming data until FlushBufferedFrames is called.
|
| - bool blocked_;
|
| -
|
| - // Tracks how many bytes the sequencer has buffered.
|
| - size_t num_bytes_buffered_;
|
| -
|
| - // Count of the number of frames received.
|
| - int num_frames_received_;
|
| -
|
| - // Count of the number of duplicate frames received.
|
| - int num_duplicate_frames_received_;
|
| -
|
| - // Count of the number of frames received before all previous frames were
|
| - // received.
|
| - int num_early_frames_received_;
|
| -
|
| - DISALLOW_COPY_AND_ASSIGN(QuicStreamSequencer);
|
| -};
|
| -
|
| -} // namespace net
|
| -
|
| -#endif // NET_QUIC_QUIC_STREAM_SEQUENCER_H_
|
|
|