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

Unified Diff: net/quic/quic_session.h

Issue 11300020: Add QuicStream and friends to QUIC code. (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: smaller char constant Created 8 years, 1 month 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_crypto_stream_test.cc ('k') | net/quic/quic_session.cc » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: net/quic/quic_session.h
diff --git a/net/quic/quic_session.h b/net/quic/quic_session.h
new file mode 100644
index 0000000000000000000000000000000000000000..cc4edc660aef3e89fdd5d515a94cb7b784665641
--- /dev/null
+++ b/net/quic/quic_session.h
@@ -0,0 +1,117 @@
+// 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.
+//
+// A QuicSession, which demuxes a single connection to individual streams.
+
+#ifndef NET_QUIC_QUIC_SESSION_H_
+#define NET_QUIC_QUIC_SESSION_H_
+
+#include <vector>
+
+#include "base/compiler_specific.h"
+#include "base/hash_tables.h"
+#include "net/base/ip_endpoint.h"
+#include "net/quic/quic_connection.h"
+#include "net/quic/quic_crypto_stream.h"
+#include "net/quic/quic_packet_creator.h"
+#include "net/quic/quic_protocol.h"
+#include "net/quic/reliable_quic_stream.h"
+
+namespace net {
+
+class NET_EXPORT_PRIVATE QuicSession : public QuicConnectionVisitorInterface {
+ public:
+ QuicSession(QuicConnection* connection, bool is_server);
+
+ virtual ~QuicSession();
+
+ // QuicConnectionVisitorInterface methods:
+ virtual bool OnPacket(const IPEndPoint& self_address,
+ const IPEndPoint& peer_address,
+ const QuicPacketHeader& header,
+ const std::vector<QuicStreamFrame>& frame) OVERRIDE;
+ virtual void OnRstStream(const QuicRstStreamFrame& frame) OVERRIDE;
+ virtual void ConnectionClose(QuicErrorCode error, bool from_peer) OVERRIDE;
+ // Not needed for HTTP.
+ virtual void OnAck(AckedPackets acked_packets) OVERRIDE {}
+
+ // Called by streams when they want to write data to the peer.
+ virtual int WriteData(QuicStreamId id, base::StringPiece data,
+ QuicStreamOffset offset, bool fin);
+ // Called by streams when they want to close the stream in both directions.
+ void SendRstStream(QuicStreamId id,
+ QuicErrorCode error,
+ QuicStreamOffset offset);
+
+ // Removes the stream associated with 'stream_id' from the active stream map.
+ virtual void CloseStream(QuicStreamId stream_id);
+
+ // Returns true once the crypto handshake is complete.
+ virtual bool IsHandshakeComplete();
+
+ QuicConnection* connection() { return connection_.get(); }
+ size_t num_active_requests() const { return stream_map_.size(); }
+ const IPEndPoint& peer_address() const {
+ return connection_->peer_address();
+ }
+
+ QuicPacketCreator::Options* options() { return connection()->options(); }
+
+ // Returns the number of currently open streams, including those which have
+ // been implicitly created.
+ virtual size_t GetNumOpenStreams();
+
+ protected:
+ // Creates a new stream, owned by the caller, to handle a peer-initiated
+ // stream. Returns NULL if max streams have already been opened.
+ virtual ReliableQuicStream* CreateIncomingReliableStream(QuicStreamId id) = 0;
+
+ // Create a new stream, owned by the caller, to handle a locally-initiated
+ // stream. Returns NULL if max streams have already been opened.
+ virtual ReliableQuicStream* CreateOutgoingReliableStream() = 0;
+
+ // Return the reserved crypto stream.
+ virtual QuicCryptoStream* GetCryptoStream() = 0;
+
+ // Adds 'stream' to the active stream map.
+ void ActivateStream(ReliableQuicStream* stream);
+
+ // Returns the stream id for a new stream.
+ QuicStreamId GetNextStreamId();
+
+ // Returns true if the stream existed previously and has been closed.
+ bool IsClosedStream(QuicStreamId id);
+
+ ReliableQuicStream* GetIncomingReliableStream(QuicStreamId stream_id);
+
+ size_t get_max_open_streams() const {
+ return max_open_streams_;
+ }
+
+ private:
+ friend class QuicSessionPeer;
+
+ typedef base::hash_map<QuicStreamId, ReliableQuicStream*> ReliableStreamMap;
+
+ ReliableQuicStream* GetStream(const QuicStreamId stream_id);
+
+ scoped_ptr<QuicConnection> connection_;
+
+ // Returns the maximum number of streams this connection can open.
+ const size_t max_open_streams_;
+
+ // Map from StreamId to pointers to streams that are owned by the caller.
+ ReliableStreamMap stream_map_;
+ QuicStreamId next_stream_id_;
+ bool is_server_;
+
+ // Set of stream ids that have been "implicitly created" by receipt
+ // of a stream id larger than the next expected stream id.
+ base::hash_set<QuicStreamId> implicitly_created_streams_;
+ QuicStreamId largest_peer_created_stream_id_;
+};
+
+} // namespace net
+
+#endif // NET_QUIC_QUIC_SESSION_H_
« no previous file with comments | « net/quic/quic_crypto_stream_test.cc ('k') | net/quic/quic_session.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698