Home | History | Annotate | Download | only in quic 
      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 
     15 QuicServerSession::QuicServerSession(
     16     const QuicConfig& config,
     17     QuicConnection* connection,
     18     QuicSessionOwner* owner)
     19     : QuicSession(connection, config),
     20       owner_(owner) {
     21 }
     22 
     23 QuicServerSession::~QuicServerSession() {
     24 }
     25 
     26 void QuicServerSession::InitializeSession(
     27     const QuicCryptoServerConfig& crypto_config) {
     28   crypto_stream_.reset(CreateQuicCryptoServerStream(crypto_config));
     29 }
     30 
     31 QuicCryptoServerStream* QuicServerSession::CreateQuicCryptoServerStream(
     32     const QuicCryptoServerConfig& crypto_config) {
     33   return new QuicCryptoServerStream(crypto_config, this);
     34 }
     35 
     36 void QuicServerSession::OnConnectionClosed(QuicErrorCode error,
     37                                            bool from_peer) {
     38   QuicSession::OnConnectionClosed(error, from_peer);
     39   owner_->OnConnectionClosed(connection()->guid(), error);
     40 }
     41 
     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 
     57 QuicDataStream* QuicServerSession::CreateIncomingDataStream(
     58     QuicStreamId id) {
     59   if (!ShouldCreateIncomingDataStream(id)) {
     60     return NULL;
     61   }
     62 
     63   return new QuicSpdyServerStream(id, this);
     64 }
     65 
     66 QuicDataStream* QuicServerSession::CreateOutgoingDataStream() {
     67   DLOG(ERROR) << "Server push not yet supported";
     68   return NULL;
     69 }
     70 
     71 QuicCryptoServerStream* QuicServerSession::GetCryptoStream() {
     72   return crypto_stream_.get();
     73 }
     74 
     75 }  // namespace tools
     76 }  // namespace net
     77