1 // Copyright (c) 2012 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.
4
5 #include "net/tools/quic/quic_server_session.h"
6
7 #include "base/logging.h"
8 #include "net/quic/quic_connection.h"
9 #include "net/quic/reliable_quic_stream.h"
10 #include "net/tools/quic/quic_spdy_server_stream.h"
11
12 namespace net {
13 namespace tools {
14
QuicServerSession(const QuicConfig & config,QuicConnection * connection,QuicSessionOwner * owner)15 QuicServerSession::QuicServerSession(
16 const QuicConfig& config,
17 QuicConnection* connection,
18 QuicSessionOwner* owner)
19 : QuicSession(connection, config),
20 owner_(owner) {
21 }
22
~QuicServerSession()23 QuicServerSession::~QuicServerSession() {
24 }
25
InitializeSession(const QuicCryptoServerConfig & crypto_config)26 void QuicServerSession::InitializeSession(
27 const QuicCryptoServerConfig& crypto_config) {
28 crypto_stream_.reset(CreateQuicCryptoServerStream(crypto_config));
29 }
30
CreateQuicCryptoServerStream(const QuicCryptoServerConfig & crypto_config)31 QuicCryptoServerStream* QuicServerSession::CreateQuicCryptoServerStream(
32 const QuicCryptoServerConfig& crypto_config) {
33 return new QuicCryptoServerStream(crypto_config, this);
34 }
35
OnConnectionClosed(QuicErrorCode error,bool from_peer)36 void QuicServerSession::OnConnectionClosed(QuicErrorCode error,
37 bool from_peer) {
38 QuicSession::OnConnectionClosed(error, from_peer);
39 owner_->OnConnectionClosed(connection()->guid(), error);
40 }
41
ShouldCreateIncomingDataStream(QuicStreamId id)42 bool QuicServerSession::ShouldCreateIncomingDataStream(QuicStreamId id) {
43 if (id % 2 == 0) {
44 DLOG(INFO) << "Invalid incoming even stream_id:" << id;
45 connection()->SendConnectionClose(QUIC_INVALID_STREAM_ID);
46 return false;
47 }
48 if (GetNumOpenStreams() >= get_max_open_streams()) {
49 DLOG(INFO) << "Failed to create a new incoming stream with id:" << id
50 << " Already " << GetNumOpenStreams() << " open.";
51 connection()->SendConnectionClose(QUIC_TOO_MANY_OPEN_STREAMS);
52 return false;
53 }
54 return true;
55 }
56
CreateIncomingDataStream(QuicStreamId id)57 QuicDataStream* QuicServerSession::CreateIncomingDataStream(
58 QuicStreamId id) {
59 if (!ShouldCreateIncomingDataStream(id)) {
60 return NULL;
61 }
62
63 return new QuicSpdyServerStream(id, this);
64 }
65
CreateOutgoingDataStream()66 QuicDataStream* QuicServerSession::CreateOutgoingDataStream() {
67 DLOG(ERROR) << "Server push not yet supported";
68 return NULL;
69 }
70
GetCryptoStream()71 QuicCryptoServerStream* QuicServerSession::GetCryptoStream() {
72 return crypto_stream_.get();
73 }
74
75 } // namespace tools
76 } // namespace net
77