| // 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. |
| |
| #include "quiche/quic/tools/quic_simple_dispatcher.h" |
| |
| #include "absl/strings/string_view.h" |
| #include "quiche/quic/tools/quic_simple_server_session.h" |
| |
| namespace quic { |
| |
| QuicSimpleDispatcher::QuicSimpleDispatcher( |
| const QuicConfig* config, const QuicCryptoServerConfig* crypto_config, |
| QuicVersionManager* version_manager, |
| std::unique_ptr<QuicConnectionHelperInterface> helper, |
| std::unique_ptr<QuicCryptoServerStreamBase::Helper> session_helper, |
| std::unique_ptr<QuicAlarmFactory> alarm_factory, |
| QuicSimpleServerBackend* quic_simple_server_backend, |
| uint8_t expected_server_connection_id_length, |
| ConnectionIdGeneratorInterface& generator) |
| : QuicDispatcher(config, crypto_config, version_manager, std::move(helper), |
| std::move(session_helper), std::move(alarm_factory), |
| expected_server_connection_id_length, generator), |
| quic_simple_server_backend_(quic_simple_server_backend) {} |
| |
| QuicSimpleDispatcher::~QuicSimpleDispatcher() = default; |
| |
| int QuicSimpleDispatcher::GetRstErrorCount( |
| QuicRstStreamErrorCode error_code) const { |
| auto it = rst_error_map_.find(error_code); |
| if (it == rst_error_map_.end()) { |
| return 0; |
| } |
| return it->second; |
| } |
| |
| void QuicSimpleDispatcher::OnRstStreamReceived( |
| const QuicRstStreamFrame& frame) { |
| auto it = rst_error_map_.find(frame.error_code); |
| if (it == rst_error_map_.end()) { |
| rst_error_map_.insert(std::make_pair(frame.error_code, 1)); |
| } else { |
| it->second++; |
| } |
| } |
| |
| std::unique_ptr<QuicSession> QuicSimpleDispatcher::CreateQuicSession( |
| QuicConnectionId connection_id, const QuicSocketAddress& self_address, |
| const QuicSocketAddress& peer_address, absl::string_view /*alpn*/, |
| const ParsedQuicVersion& version, |
| const ParsedClientHello& /*parsed_chlo*/) { |
| // The QuicServerSessionBase takes ownership of |connection| below. |
| QuicConnection* connection = new QuicConnection( |
| connection_id, self_address, peer_address, helper(), alarm_factory(), |
| writer(), |
| /* owns_writer= */ false, Perspective::IS_SERVER, |
| ParsedQuicVersionVector{version}, connection_id_generator()); |
| |
| auto session = std::make_unique<QuicSimpleServerSession>( |
| config(), GetSupportedVersions(), connection, this, session_helper(), |
| crypto_config(), compressed_certs_cache(), quic_simple_server_backend_); |
| session->Initialize(); |
| return session; |
| } |
| |
| } // namespace quic |