1 // Copyright 2014 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file.
5 // A server specific QuicSession subclass.
7 #ifndef NET_QUIC_QUIC_SERVER_SESSION_H_
8 #define NET_QUIC_QUIC_SERVER_SESSION_H_
13 #include "base/basictypes.h"
14 #include "base/containers/hash_tables.h"
15 #include "base/memory/scoped_ptr.h"
16 #include "net/quic/quic_crypto_server_stream.h"
17 #include "net/quic/quic_per_connection_packet_writer.h"
18 #include "net/quic/quic_protocol.h"
19 #include "net/quic/quic_session.h"
24 class QuicServerSessionPeer;
27 class QuicBlockedWriterInterface;
30 class QuicCryptoServerConfig;
31 class ReliableQuicStream;
33 // An interface from the session to the entity owning the session.
34 // This lets the session notify its owner (the Dispatcher) when the connection
35 // is closed or blocked.
36 class QuicServerSessionVisitor {
38 virtual ~QuicServerSessionVisitor() {}
40 virtual void OnConnectionClosed(QuicConnectionId connection_id,
41 QuicErrorCode error) = 0;
42 virtual void OnWriteBlocked(QuicBlockedWriterInterface* blocked_writer) = 0;
45 class QuicServerSession : public QuicSession {
47 QuicServerSession(const QuicConfig& config,
48 QuicConnection* connection,
49 QuicServerSessionVisitor* visitor,
52 // Override the base class to notify the owner of the connection close.
53 void OnConnectionClosed(QuicErrorCode error, bool from_peer) override;
54 void OnWriteBlocked() override;
56 // Sends a server config update to the client, containing new bandwidth
58 void OnCongestionWindowChange(QuicTime now) override;
60 ~QuicServerSession() override;
62 virtual void InitializeSession(const QuicCryptoServerConfig& crypto_config);
64 const QuicCryptoServerStream* crypto_stream() const {
65 return crypto_stream_.get();
68 // Override base class to process FEC config received from client.
69 void OnConfigNegotiated() override;
71 void set_serving_region(string serving_region) {
72 serving_region_ = serving_region;
76 // QuicSession methods:
77 QuicDataStream* CreateIncomingDataStream(QuicStreamId id) override;
78 QuicDataStream* CreateOutgoingDataStream() override;
79 QuicCryptoServerStream* GetCryptoStream() override;
81 // If we should create an incoming stream, returns true. Otherwise
82 // does error handling, including communicating the error to the client and
83 // possibly closing the connection, and returns false.
84 virtual bool ShouldCreateIncomingDataStream(QuicStreamId id);
86 virtual QuicCryptoServerStream* CreateQuicCryptoServerStream(
87 const QuicCryptoServerConfig& crypto_config);
90 friend class test::QuicServerSessionPeer;
92 scoped_ptr<QuicCryptoServerStream> crypto_stream_;
93 QuicServerSessionVisitor* visitor_;
95 // The most recent bandwidth estimate sent to the client.
96 QuicBandwidth bandwidth_estimate_sent_to_client_;
98 // Text describing server location. Sent to the client as part of the bandwith
99 // estimate in the source-address token. Optional, can be left empty.
100 string serving_region_;
102 // Time at which we send the last SCUP to the client.
103 QuicTime last_scup_time_;
105 // Number of packets sent to the peer, at the time we last sent a SCUP.
106 int64 last_scup_sequence_number_;
108 DISALLOW_COPY_AND_ASSIGN(QuicServerSession);
113 #endif // NET_QUIC_QUIC_SERVER_SESSION_H_