blob: 79142c4681ec5a4d32b9ab7defc9baa6949d9e29 (
plain)
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
|
// 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/core/quic_crypto_handshaker.h"
#include "quic/core/quic_session.h"
namespace quic {
#define ENDPOINT \
(session()->perspective() == Perspective::IS_SERVER ? "Server: " : "Client: ")
QuicCryptoHandshaker::QuicCryptoHandshaker(QuicCryptoStream* stream,
QuicSession* session)
: stream_(stream), session_(session), last_sent_handshake_message_tag_(0) {
crypto_framer_.set_visitor(this);
}
QuicCryptoHandshaker::~QuicCryptoHandshaker() {}
void QuicCryptoHandshaker::SendHandshakeMessage(
const CryptoHandshakeMessage& message,
EncryptionLevel level) {
QUIC_DVLOG(1) << ENDPOINT << "Sending " << message.DebugString();
session()->NeuterUnencryptedData();
session()->OnCryptoHandshakeMessageSent(message);
last_sent_handshake_message_tag_ = message.tag();
const QuicData& data = message.GetSerialized();
stream_->WriteCryptoData(level, data.AsStringPiece());
}
void QuicCryptoHandshaker::OnError(CryptoFramer* framer) {
QUIC_DLOG(WARNING) << "Error processing crypto data: "
<< QuicErrorCodeToString(framer->error());
}
void QuicCryptoHandshaker::OnHandshakeMessage(
const CryptoHandshakeMessage& message) {
QUIC_DVLOG(1) << ENDPOINT << "Received " << message.DebugString();
session()->OnCryptoHandshakeMessageReceived(message);
}
CryptoMessageParser* QuicCryptoHandshaker::crypto_message_parser() {
return &crypto_framer_;
}
size_t QuicCryptoHandshaker::BufferSizeLimitForLevel(EncryptionLevel) const {
return GetQuicFlag(FLAGS_quic_max_buffered_crypto_bytes);
}
#undef ENDPOINT // undef for jumbo builds
} // namespace quic
|
