Test interaction between DevToolsWindow and BrowserView.
[chromium-blink-merge.git] / net / quic / quic_server_session.cc
blob399b772e578bc18508713e26bc6298ec6de94a3c
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 #include "net/quic/quic_server_session.h"
7 #include "base/logging.h"
8 #include "net/quic/quic_connection.h"
9 #include "net/quic/quic_flags.h"
10 #include "net/quic/quic_spdy_server_stream.h"
11 #include "net/quic/reliable_quic_stream.h"
13 namespace net {
15 QuicServerSession::QuicServerSession(
16 const QuicConfig& config,
17 QuicConnection* connection,
18 QuicPerConnectionPacketWriter* connection_packet_writer,
19 QuicServerSessionVisitor* visitor)
20 : QuicSession(connection, config),
21 connection_packet_writer_(connection_packet_writer),
22 visitor_(visitor) {}
24 QuicServerSession::~QuicServerSession() {}
26 void QuicServerSession::InitializeSession(
27 const QuicCryptoServerConfig& crypto_config) {
28 QuicSession::InitializeSession();
29 crypto_stream_.reset(CreateQuicCryptoServerStream(crypto_config));
32 QuicCryptoServerStream* QuicServerSession::CreateQuicCryptoServerStream(
33 const QuicCryptoServerConfig& crypto_config) {
34 return new QuicCryptoServerStream(crypto_config, this);
37 void QuicServerSession::OnConfigNegotiated() {
38 QuicSession::OnConfigNegotiated();
39 if (!FLAGS_enable_quic_fec ||
40 !config()->HasReceivedConnectionOptions() ||
41 !ContainsQuicTag(config()->ReceivedConnectionOptions(), kFHDR)) {
42 return;
44 // kFHDR config maps to FEC protection always for headers stream.
45 // TODO(jri): Add crypto stream in addition to headers for kHDR.
46 headers_stream_->set_fec_policy(FEC_PROTECT_ALWAYS);
49 void QuicServerSession::OnConnectionClosed(QuicErrorCode error,
50 bool from_peer) {
51 QuicSession::OnConnectionClosed(error, from_peer);
52 // In the unlikely event we get a connection close while doing an asynchronous
53 // crypto event, make sure we cancel the callback.
54 if (crypto_stream_.get() != NULL) {
55 crypto_stream_->CancelOutstandingCallbacks();
57 visitor_->OnConnectionClosed(connection()->connection_id(), error);
60 void QuicServerSession::OnWriteBlocked() {
61 QuicSession::OnWriteBlocked();
62 visitor_->OnWriteBlocked(connection());
65 bool QuicServerSession::ShouldCreateIncomingDataStream(QuicStreamId id) {
66 if (id % 2 == 0) {
67 DVLOG(1) << "Invalid incoming even stream_id:" << id;
68 connection()->SendConnectionClose(QUIC_INVALID_STREAM_ID);
69 return false;
71 if (GetNumOpenStreams() >= get_max_open_streams()) {
72 DVLOG(1) << "Failed to create a new incoming stream with id:" << id
73 << " Already " << GetNumOpenStreams() << " open.";
74 connection()->SendConnectionClose(QUIC_TOO_MANY_OPEN_STREAMS);
75 return false;
77 return true;
80 QuicDataStream* QuicServerSession::CreateIncomingDataStream(
81 QuicStreamId id) {
82 if (!ShouldCreateIncomingDataStream(id)) {
83 return NULL;
86 return new QuicSpdyServerStream(id, this);
89 QuicDataStream* QuicServerSession::CreateOutgoingDataStream() {
90 DLOG(ERROR) << "Server push not yet supported";
91 return NULL;
94 QuicCryptoServerStream* QuicServerSession::GetCryptoStream() {
95 return crypto_stream_.get();
98 } // namespace net