Index: net/quic/quic_stream_sequencer.h |
=================================================================== |
--- net/quic/quic_stream_sequencer.h (revision 165858) |
+++ net/quic/quic_stream_sequencer.h (working copy) |
@@ -1,90 +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 "base/basictypes.h" |
-#include "base/memory/scoped_ptr.h" |
-#include "net/quic/quic_protocol.h" |
- |
-using std::map; |
-using std::string; |
- |
-namespace net { |
- |
-class QuicSession; |
-class ReliableQuicStream; |
- |
-// Buffers frames until we have something which can be passed |
-// up to the next layer. |
-// TOOD(alyssar) add some checks for overflow attempts [1, 256,] [2, 256] |
-class NET_EXPORT_PRIVATE QuicStreamSequencer { |
- public: |
- static size_t kMaxUdpPacketSize; |
- |
- explicit QuicStreamSequencer(ReliableQuicStream* quic_stream); |
- QuicStreamSequencer(size_t max_frame_memory, |
- ReliableQuicStream* quic_stream); |
- |
- virtual ~QuicStreamSequencer(); |
- |
- // Returns the expected value of OnStreamFrame for this frame. |
- bool WillAcceptStreamFrame(const QuicStreamFrame& frame) const; |
- |
- // 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 either be buffered, and |
- // this will return true, or it will be rejected and this will return false. |
- bool OnStreamFrame(const QuicStreamFrame& frame); |
- |
- // Wait until we've seen 'offset' bytes, and then terminate the stream. |
- void CloseStreamAtOffset(QuicStreamOffset offset, bool half_close); |
- |
- // 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. |
- |
- // Advances the readable pointer num_bytes bytes, releasing any buffered data |
- // which is no longer in uses |
- void AdvanceReadablePtr(size_t num_bytes); |
- |
- // Returns true if the sequncer has bytes available for reading. |
- bool HasBytesToRead(); |
- |
- // Returns true if the sequencer has delivered a half close. |
- bool IsHalfClosed(); |
- |
- // Returns true if the sequencer has delivered a full close. |
- bool IsClosed(); |
- |
- private: |
- bool MaybeCloseStream(); |
- |
- friend class QuicStreamSequencerPeer; |
- // TODO(alyssar) use something better than strings. |
- typedef map<QuicStreamOffset, string> FrameMap; |
- |
- void FlushBufferedFrames(); |
- |
- ReliableQuicStream* stream_; // The stream which owns this sequencer. |
- QuicStreamOffset num_bytes_consumed_; // The last data consumed by the stream |
- FrameMap frames_; // sequence number -> frame |
- size_t max_frame_memory_; // the maximum memory the sequencer can buffer. |
- // The offset, if any, we got a stream cancelation for. When this many bytes |
- // have been processed, the stream will be half or full closed depending on |
- // the half_close_ bool. |
- QuicStreamOffset close_offset_; |
- // Only valid if close_offset_ is set. Indicates if it's a half or a full |
- // close. |
- bool half_close_; |
-}; |
- |
-} // namespace net |
- |
-#endif // NET_QUIC_QUIC_STREAM_SEQUENCER_H_ |