1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
|
// 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 "net/tools/quic/quic_simple_dispatcher.h"
#include "net/tools/quic/quic_simple_server_session.h"
namespace net {
QuicSimpleDispatcher::QuicSimpleDispatcher(
const QuicConfig& config,
const QuicCryptoServerConfig* crypto_config,
QuicVersionManager* version_manager,
std::unique_ptr<QuicConnectionHelperInterface> helper,
std::unique_ptr<QuicCryptoServerStream::Helper> session_helper,
std::unique_ptr<QuicAlarmFactory> alarm_factory,
QuicHttpResponseCache* response_cache)
: QuicDispatcher(config,
crypto_config,
version_manager,
std::move(helper),
std::move(session_helper),
std::move(alarm_factory)),
response_cache_(response_cache) {}
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;
} else {
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++;
}
}
QuicServerSessionBase* QuicSimpleDispatcher::CreateQuicSession(
QuicConnectionId connection_id,
const QuicSocketAddress& client_address,
QuicStringPiece /*alpn*/) {
// The QuicServerSessionBase takes ownership of |connection| below.
QuicConnection* connection = new QuicConnection(
connection_id, client_address, helper(), alarm_factory(),
CreatePerConnectionWriter(),
/* owns_writer= */ true, Perspective::IS_SERVER, GetSupportedVersions());
QuicServerSessionBase* session = new QuicSimpleServerSession(
config(), connection, this, session_helper(), crypto_config(),
compressed_certs_cache(), response_cache_);
session->Initialize();
return session;
}
} // namespace net
|
