blob: aa9a9c1e6162561756909e3a18c7bc49e9921285 [file] [log] [blame]
// 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 "quic/tools/quic_simple_dispatcher.h"
#include "absl/strings/string_view.h"
#include "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)
: QuicDispatcher(config,
crypto_config,
version_manager,
std::move(helper),
std::move(session_helper),
std::move(alarm_factory),
expected_server_connection_id_length),
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,
absl::string_view /*sni*/) {
// 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});
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